1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
|
% Copyright 2008 Konrad-Zuse-Zentrum für Informationstechnik Berlin
%
% Licensed under the Apache License, Version 2.0 (the "License");
% you may not use this file except in compliance with the License.
% You may obtain a copy of the License at
%
% http://www.apache.org/licenses/LICENSE-2.0
%
% Unless required by applicable law or agreed to in writing, software
% distributed under the License is distributed on an "AS IS" BASIS,
% WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
% See the License for the specific language governing permissions and
% limitations under the License.
%%%-------------------------------------------------------------------
%%% File : comm_layer.erl
%%% Author : Thorsten Schuett <[email protected]>
%%% Description : Public interface to Communication Layer.
%%% Generic functions to send messages.
%%% Distinguishes on runtime whether the destination is in the
%%% same Erlang virtual machine (use ! for sending) or on a remote
%%% site (use comm_port:send()).
%%%
%%% Created : 04 Feb 2008 by Thorsten Schuett <[email protected]>
%%%-------------------------------------------------------------------
%% @author Thorsten Schuett <[email protected]>
%% @copyright 2008 Konrad-Zuse-Zentrum für Informationstechnik Berlin
%% @version $Id $
-module(comm_layer_dir.comm_layer).
-author('[email protected]').
-vsn('$Id: comm_layer.erl,v 1.1 2009/11/06 12:41:36 maria Exp $ ').
-export([start_link/0, send/2, this/0, here/1]).
-import(io).
-import(util).
-import(log).
-include("comm_layer.hrl").
% @TODO: should be ip
-type(process_id() :: {any(), integer(), pid()}).
%%====================================================================
%% public functions
%%====================================================================
%% @doc starts the communication port (for supervisor)
%% @spec start_link() -> {ok,Pid} | ignore | {error,Error}
start_link() ->
comm_port_sup:start_link().
%% @doc a process descriptor has to specify the erlang vm
%% + the process inside. {IP address, port, pid}
%% @type process_id() = {inet:ip_address(), int(), pid()}.
%% @spec send(process_id(), term()) -> ok
send({{_IP1, _IP2, _IP3, _IP4} = _IP, _Port, _Pid} = Target, Message) ->
{MyIP,MyPort} = comm_port:get_local_address_port(),
%io:format("send: ~p:~p -> ~p:~p(~p) : ~p\n", [MyIP, MyPort, _IP, _Port, _Pid, Message]),
IsLocal = (MyIP == _IP) and (MyPort == _Port),
if
IsLocal ->
?LOG_MESSAGE(erlang:element(1, Message), byte_size(term_to_binary(Message))),
_Pid ! Message;
true ->
comm_port:send(Target, Message)
end;
send(Target, Message) ->
log:log(error,"[ CC ] wrong call to cs_send:send: ~w ! ~w", [Target, Message]),
log:log(error,"[ CC ] stacktrace: ~w", [util:get_stacktrace()]),
ok.
%% @doc returns process descriptor for the calling process
-spec(this/0 :: () -> atom()).%process_id()).
this() ->
here(self()).
-spec(here/1 :: (pid()) -> process_id()).
here(Pid) ->
{LocalIP, LocalPort} = comm_port:get_local_address_port(),
{LocalIP, LocalPort, Pid}.
|
