【问题标题】:How should an undef error be interpreted in Erlang?在 Erlang 中应该如何解释 undef 错误?
【发布时间】:2020-11-04 04:49:53
【问题描述】:

我正在尝试理解以下错误:

4> c(sv).
{ok,sv}
5> B=sv:start().
<0.93.0>
6> =ERROR REPORT==== 14-Jul-2020::21:44:13.256000 ===
Error in process <0.93.0> with exit value:
{undef,[{common,createProcess,
                [{monitor,monitor,
                          {monstate,undefined,undefined,undefined,true,
                                    undefined,false}}],
                []},
        {sv,server,1,[{file,"sv.erl"},{line,14}]}]}

我有一个sv 模块,它从monitor 模块实例化一个进程,然后从worker 模块实例化一个进程。 通过调用common 模块进行实例化。 svmonitor 都使用在 .hrl 模块中定义的记录。

sv.erl -> monitor.erl -> worker.erl
 |            |
   common.erl
   records.hrl

common.erl

%%% common functionality module
-module(common).
-export([createProcess/1]).
-import(worker,[worker/1]).
-import(monitor,[monitor/1]).
-include("records.hrl").

createProcess({M,F,A})->
    Pid=spawn(M,F,[A]),
    Ref=erlang:monitor(process,Pid),
    {Pid,Ref}.

records.hrl

-record(monstate,{
    queue,
    qc,
    wpid,
    free=true,
    wref,
    init=false
}).

-record(sstate,{
    init=false,
    mpid=null,
    mref=null
}).

sv.erl

-module(sv).
-import(common,[createProcess/1]).
-include("records.hrl").
-export([start/0,server/1]).



start()->
    spawn(?MODULE,server,[#sstate{init=false}]).

server(State=#sstate{init=I})when I=:=false ->
    {MPid,MRef}=createProcess({monitor,monitor,#monstate{init=false}}),
    server(State#sstate{init=true,mpid=MPid,mref=MRef});

server(State=#sstate{mpid=MPid,mref=MRef})->
    receive
           {From,state}->From ! State,
                            server(State);
           {From,Message}-> MPid ! {request,{From,Message}},
                            server(State);
                
            {'DOWN',MRef,process,MPid,_}-> {NewMPid,NewMRef}=createProcess({?MODULE,monitor,#monstate{init=false}}),
                                            server(State#sstate{mpid=NewMPid,mref=NewMRef});
            _ ->exit(invalid_message)
                                    
    end.

monitor.erl

%%% servers as both a gen_server that can be queried  and a supervisor for its worker process
-module(monitor).
-export([monitor/1]).
-import(common,[createProcess/1]).

-include("records.hrl").

-define(QUEUE_SIZE,5).

tryEnqueue(Message,MState=#monstate{queue=Q,qc=C}) when C<?QUEUE_SIZE->
    NewQueue=queue:in(Message,Q),
    {queued,MState#monstate{qc=C+1,queue=NewQueue}};
tryEnqueue(_,MState)->{queue_full,MState}.

monitor(MState=#monstate{wpid=_,wref=_,init=I}) when I=:= false ->
    {WorkerPid,WorkerRef}=createProcess({worker,worker,self()}),
    monitor(MState#monstate{wpid=WorkerPid,wref=WorkerRef,init=true,qc=0,queue=queue:new()});

monitor(MState=#monstate{wpid=W,free=Free,wref=Ref,queue=Q,qc=C})->
    receive
        
        {request,{From ,Message}} -> case Free of 
                                            true -> W ! {From,Message},
                                                    monitor(MState#monstate{free=false});
                                                                             
                                            false -> 
                                                     St=case tryEnqueue({From,Message},MState) of 
                                                            {queue_full,S} -> From ! {queue_full,Message},S;
                                                            {queued,S} -> S
                                                        end,
                                                      monitor(St)
                                      end;
                                         
                                        
                                      
                                  
        {worker,{finished,_}}-> case queue:out(Q) of
                                    {{_,Element},Rest} -> W ! Element,
                                                          monitor(MState#monstate{free=false,queue=Rest,qc=C-1});
                                    {empty,Rest}       -> monitor(MState#monstate{free=true,queue=Rest})
                                end;

        {'DOWN',Ref,process,_,_}->
             {NewWorkerPid,NewWorkerRef}=createProcess({?MODULE,worker,self()}),
             monitor(MState#monstate{wpid=NewWorkerPid,wref=NewWorkerRef,free=true});

        _->exit(invalid_message)

    end.

所以我不知道如何解释错误:

  • 有一个对 common 模块的调用,该模块的 MFA 为:[{monitor,monitor,{monstate,undefined,undefined,.....}]{ } 中的内容看起来不错,但我没有得到包含的 [ ]

PS我的common 模块从svmonitor 模块生成进程,其中导入了这些模块,并且也包含了它们的相关记录。我不明白这个问题。

【问题讨论】:

    标签: erlang undef


    【解决方案1】:

    错误表明common:createProcess/1 未定义。 这很可能是因为模块 common 之前未在代码服务器中加载。
    也运行c(common).

    请记住 -import 编译指令仅表示 Calls in this module to the funcion X/Y are to be performed by the module Module as Module:X/Y ,但不会创建模块依赖项

    【讨论】:

    • 如果模块 A 导入模块 B 仍然没有得到,为什么我需要单独编译模块 B?无论如何,在我编译了common 模块后,我得到了一个无限循环,仍然是undef。我的模块应该在哪里导入?他们不应该在调用 spawn 的模块中吗? (在我的情况下是 common )。
    • @BercoviciAdrian Erlang import 一点也不像 Python import;不需要能够调用另一个模块的函数。事实上,它从来都不需要——它只是为了方便而提供的,坦率地说,你永远不应该使用它。在 Erlang 中,import 所做的只是使另一个模块的函数可以在没有 module: 前缀的情况下调用。更多解释请参见this answer
    • @BercoviciAdrian 如果监视器模块也未加载,则生成的进程将终止,提示生成另一个进程......等等。 (另外,+1 以避免使用 import, 这会极大地损害易读性,因为您必须检查它以了解呼叫是本地还是远程,并且某些模块非常大)
    • 那么当有很多模块时,你会一一加载它们吗?这似乎不切实际。
    • @BercoviciAdrian 你不相信多节点、>80 个模块、erlang 服务是以这种方式启动的,对吗?模块在应用程序中分组,这些应用程序又形成一个版本。 rrelease 是具有编译代码和引导脚本的版本。检查learn you some erlang chapter on applications 和下面的那些
    猜你喜欢
    • 2018-08-26
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 2021-12-26
    • 2019-10-16
    • 2016-06-30
    • 1970-01-01
    • 1970-01-01
    相关资源
    最近更新 更多