Hi,
It looks like you are trying to send a tuple. Don't.
/Per
> Hello fabulous Erlang guys
>
> I'm using OTP R9-0 on a Win32 platform (winsock) W2K and XP
>
> When I run a balanced client-server program ( attached below) the
connection phase is resolved with no problems.
> But the data exchange never happens due to some strange error I have
been chasing now for a week or so,
> -until now with no luck.... :-(
>
> in Desperation I loaded the program with debug outputs : All the
debug output give approx. this result on both sides when connecting
from 'knud2' to 'lhl-pc'
>
> accsocket init <0.72.0>,knud2 6000
> accsocket: gen_tcp:connect(knud2,6000),{packet, 0},{active, true }
> Connect error {reason,econnrefused}
> gen_tcp:listen (6000,[binary, {packet, 0}, {active,true}])
> ok,ListenSocket ListenSocket=#Port<0.118> info ={error,enotconn}
> runing initServer got Connect Socket #Port<0.119> Info
{ok,{{192,168,2,253},
> 6000}}
> GETACCTABLE Socket#socket.socket #Port<0.119> Data {[255,0,0,2]}
> accsocket:send(#Port<0.119>,{[255,0,0,2]})
> accsock:error Reasson einval
>
> =ERROR REPORT==== 4-Feb-2003::11:23:55 ===
> Bad value on output port 'tcp_inet'
>
> - the ERROR thing text is repeated for every data send attempt
>
>
> regards
> Software developer
> Lars H. Larsen
> ICCC A/S
> Måløvhovedgade 88
> 2760 Måløv
> Denmark
> http://www.iccc.dk
> mailto:lhl@REDACTED
> tel:+45 44860400
> GSM +45 51901320
>
>
> here is a printout of the program accsocket.erl, the real fun
happens in function socketLoop/1
>
> ========================================================== cut here
>
> -define(module, accsocket). % The name of
this module.
> -module(?module).
> -compile({module_info, [{identity, '@(#)AccSocket/R4A01'}]}).
>
> -author('LMDPLU@REDACTED').
>
> -export([socketLoop/1, init/3, initServer/3]).
>
>
>
>
%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
%%%%%%%%
> %%%
> %%% Constants.
> %%%
>
%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
%%%%%%%%
>
> % Definition of the alarm numbers used in the alarmlist.def file
> -define(alarmbase, 1500 ).
> -define(unknownMessageReceived, ?alarmbase+1 ).
> -define(accGwWentDown, ?alarmbase+31).
> -define(socketTransmissionError, ?alarmbase+32).
>
>
>
%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
%%%%%%%%
> %%%
> %%% Records.
> %%%
>
%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
%%%%%%%%
>
> -define(loopRecordName, socket).% To be used in the record
definition and in
> % the debug.hrl file.
>
> -record( ?loopRecordName,
> { socket = unknown, % The Socket reference.
> gwPid, % The Pid of the 'ACCGW' process.
> ipAddress, % The ip address of the socket
process.
> socketPort, % The socket port used to
communicate ...
> restData = [], % The Pid of the 'ACCGW' process.
> hostType, % The type of the socket connection
[server|client].
> logSocketCommand = #log{eventLevel=210,
eventString="ACCSOCKET: Command decoded: "},
> logSocketData = #log{eventLevel=210,
eventString="ACCSOCKET: SocketData received: "},
> logAlarm = #log{eventLevel=255,
eventString="ACCSOCKET Alarm: "}
> }).
>
>
>
%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
%%%%%%%%
> %%%
> %%% Debug functions and records.
> %%%
>
%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
%%%%%%%%
>
> -define(regName, 'ACCSOCKET'). % The registerred name.
> -include("debug.hrl").
>
>
>
%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
%%%%%%%%%%%%%%%%%
> %%
> %% Function : init/3
> %% Purpose : initiates the socket from the gateway.
> %% Args : Port - Variable containing the port number the gateway
will use for sockets
> %% Return : Spawns 2 processes, a client and a server.
> %%
>
%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
%%%%%%%%%%%%%%%%%
> init(GwPid, IpAddress, Port) when pid(GwPid), atom(IpAddress),
integer(Port)->
> io:fwrite("accsocket init ~p,~p ~p ~n",[GwPid, IpAddress,
Port]),
> process_flag(trap_exit, true),
> register(?regName, self()),
> %LHL socket:start(),
> initClientLoop(#socket{gwPid=GwPid, ipAddress=IpAddress,
socketPort=Port, hostType=client});
>
> init(_, _, _) ->
> io:fwrite("Bad parameter").
>
>
> initClientLoop(SocketRec)->
> timer:sleep(100), % Please don't ask why !
>
> io:format("accsocket: gen_tcp:connect(~w,~w),{packet, 0},{active,
true }~n",[SocketRec#socket.ipAddress, SocketRec#socket.socketPort]),
> case catch gen_tcp:connect(SocketRec#socket.ipAddress,
SocketRec#socket.socketPort, [binary,{packet,0},{active,true}]) of
> {error, _R} ->
> io:format("Connect error {reason,~w} ~n",[_R]),
> ServerPid = spawn_link(?module, initServer, [self(),
SocketRec#socket.ipAddress, SocketRec#socket.socketPort]),
> initServerLoop(SocketRec#socket{hostType=server}, ServerPid);
>
> {'EXIT', _Reason} ->
> io:format("Connect EXIT {reason,~w} ~n",[_Reason]),
> ServerPid = spawn_link(?module, initServer, [self(),
SocketRec#socket.ipAddress, SocketRec#socket.socketPort]),
> initServerLoop(SocketRec#socket{hostType=server}, ServerPid);
> {ok,Socket} ->
> io:format("runing initclient got Connect ~p ~n",[Socket]),
> SocketRec#socket.gwPid ! {'SOCKETSTATE',active},
> socketLoop(SocketRec#socket{socket = Socket})
>
> end.
>
> initServerLoop(SocketRec, ServerPid)->
> receive
>
> {'EXIT', ServerPid, Reason} ->
> io:format("{'EXIT', ServerPid, Reason}: ~p ~n",[Reason]),
> initClientLoop(SocketRec#socket{hostType=client});
>
> {'EXIT', GwPid, Reason} ->
> alarmmgr:notify(?accGwWentDown, [?MODULE, ?LINE, Reason]),
> log(SocketRec, logAlarm, {notify, ?accGwWentDown, ?MODULE, ?LINE,
[Reason]}),
> exit(Reason);
>
> {'ACCSOCKETCONNECT', ServerPid, Socket} ->
> SocketRec#socket.gwPid ! {'SOCKETSTATE', active},
> socketLoop(SocketRec#socket{socket = Socket});
>
> {'UPDATECODE', Module} ->
> unlink(ServerPid),
> exit(ServerPid, kill),
> case Module of
> ?module ->
> ?module:initClientLoop(SocketRec#socket{hostType=client});
> _Module ->
> initClientLoop(SocketRec#socket{hostType=client})
> end;
>
> {'SHUTDOWN', Pid} ->
> unlink(ServerPid),
> exit(ServerPid, kill),
> % io:fwrite(' SHUTDOWN request sent from ACCGW '),
> Pid ! {'SHUTDOWNOK',self()},
> initClientLoop(SocketRec#socket{hostType=client});
>
> %------------------------ Debug Functionallity
--------------------------%
>
> {getLoopData, Pid} ->
> Pid ! {loopData, SocketRec},
> initServerLoop(SocketRec, ServerPid);
>
> {logState, LogRecord, NewValue} ->
> NewSocketRec = logStateChange(SocketRec, LogRecord,
NewValue),
> initServerLoop(NewSocketRec, ServerPid);
>
> {logToScreen, LogRecord, NewValue} ->
> NewSocketRec = logToScreenChange(SocketRec, LogRecord,
NewValue),
> initServerLoop(NewSocketRec, ServerPid);
>
> {logLevel, LogRecord, NewValue} ->
> NewSocketRec = logLevelChange(SocketRec, LogRecord,
NewValue),
> initServerLoop(NewSocketRec, ServerPid);
>
> exit ->
> ok;
>
> Other ->
> io:format("SocketLoop Other: ~p ~n",[Other]),
> alarmmgr:notify(?unknownMessageReceived, [?MODULE,
?LINE, Other]),
> log(SocketRec, logAlarm, {notify,
?unknownMessageReceived, ?MODULE, ?LINE, [Other]}),
> initServerLoop(SocketRec, ServerPid)
>
> % after TimeOut ->
> % unlink(ServerPid),
> % exit(ServerPid, kill),
> % initClientLoop(SocketRec#socket{hostType=client})
>
> end.
>
> initServer(Initiator, IpAddress, Port)->
> %LHL ListenSocket = socket:listen('STREAM', 'AF_INET', Port,
{packet, 0}),
>
> io:format("gen_tcp:listen (~w,[binary, {packet, 0},
{active,true}])~n",[Port]),
>
> case catch gen_tcp:listen(Port,[binary, {packet, 0},
{active,true}]) of
> {error,Reason} ->
> io:format("Exit in listen (~w) ~n",[Reason]),
> exit(normal);
>
> {ok,ListenSocket} ->
> io:format("ok,ListenSocket ListenSocket=~p info
=~p~n",[ListenSocket,inet:peername(ListenSocket)]),
> case catch gen_tcp:accept(ListenSocket) of
> {error, Reason} ->
> io:format("Error gen_tcp:accept Reason~p ~n",[Reason]),
> %gen_tcp:close(ListenSocket),
> exit(normal);
>
> {ok,Socket}->
> io:format("runing initServer got Connect Socket ~p Info
~~p~n",[Socket,inet:sockname(Socket)]),
> Initiator ! {'ACCSOCKETCONNECT', self(), Socket},
> %LHL socket:controlling_process(Socket, Initiator),
> gen_tcp:controlling_process(Socket, Initiator),
> unlink(Initiator),
> gen_tcp:close(ListenSocket),
> ok
> end
> end.
>
>
>
>
>
>
>
>
%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
%%%%%%%%%%%%%%%%%
> %%
> %% Function : socketLoop/4
> %% Purpose : Loop that sends and receive data.
> %% Args : Socket - loop data
> %% Return : --
> %%
>
%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
%%%%%%%%%%%%%%%%%
>
> socketLoop(Socket) ->
> receive
> {tcp,SocketPid, SocketData} when SocketPid == Socket#socket.socket
->
> log(Socket, logSocketData, SocketData),
>
> io:format("Data from socket ~p~n",[SocketData]),
> case
accDecode(lists:flatten([Socket#socket.restData|SocketData])) of
> {reply, Data} ->
> log(Socket, logSocketCommand, {'NEWACCTABLE', Data}),
> Socket#socket.gwPid ! {'NEWACCTABLE', Data},
> socketLoop(Socket#socket{restData=[]});
>
> {request} ->
> log(Socket, logSocketCommand, {'GETACCTABLE'}),
> Socket#socket.gwPid ! {'GETACCTABLE'},
> socketLoop(Socket#socket{restData=[]});
>
> {splitData, {reply, Data}, RestData} ->
> log(Socket, logSocketCommand, [{'NEWACCTABLE', Data},
RestData]),
> Socket#socket.gwPid ! {'NEWACCTABLE', Data},
> socketLoop(Socket#socket{restData=RestData});
>
> {splitData, {request}, RestData} ->
> log(Socket, logSocketCommand, [{'GETACCTABLE'}, RestData]),
> Socket#socket.gwPid ! {'GETACCTABLE'},
> socketLoop(Socket#socket{restData=RestData});
>
> {packetNotEnded, RestData} ->
> socketLoop(Socket#socket{restData=RestData});
>
> {error, invalidPacket} ->
> alarmmgr:notify(?socketTransmissionError, [?MODULE, ?LINE,
[Socket#socket.restData|SocketData]]),
> log(Socket, logAlarm, {notify, ?socketTransmissionError,
?MODULE, ?LINE, [Socket#socket.restData|SocketData]}),
> socketLoop(Socket#socket{restData=[]})
>
> end;
>
> {tcp_closed,SocketPid} when SocketPid == Socket#socket.socket ->
> io:format("socket_closed,normal~n"),
> exit(normal);
>
> {tcp_error,SocketPid,Error} when SocketPid ==
Socket#socket.socket ->
> io:format("socket_closed,Error ~p~n",[Error]),
> exit(Error);
>
> {'GETACCTABLE'} ->
> Data= {[255, 0, 0, 2]},
> io:format("GETACCTABLE Socket#socket.socket ~p Data
~~p~n",[Socket#socket.socket,Data]),
> send(Socket#socket.socket,Data),
> % LHL Socket#socket.socket ! {self(),{deliver,[255, 0, 0, 2]}},
> socketLoop(Socket);
>
>
> {'NEWACCTABLE', Data} ->
> Data1 = accEncode(Data),
> io:format("NEWACCTABLE Socket#socket.socket ~p Data1
~~p~n",[Socket#socket.socket,Data1]),
> send(Socket#socket.socket,Data1),
> socketLoop(Socket);
>
> {'EXIT', Pid, Reason} when Pid == Socket#socket.gwPid ->
> alarmmgr:notify(?accGwWentDown, [?MODULE, ?LINE, Reason]),
> log(Socket, logAlarm, {notify, ?accGwWentDown, ?MODULE,
?LINE, [Reason]}),
> exit(Reason);
>
> {'UPDATECODE', ?module} ->
> ?module:socketLoop(Socket);
>
> {'UPDATECODE', Module} ->
> socketLoop(Socket);
>
> {'SHUTDOWN', Pid} ->
> % io:fwrite(' SHUTDOWN request sent from ACCGW '),
> Pid ! {'SHUTDOWNOK',self()},
> socketLoop(Socket);
>
> %------------------------ Debug Functionallity
--------------------------%
>
> {getLoopData, Pid} ->
> Pid ! {loopData, Socket},
> socketLoop(Socket);
>
> {logState, LogRecord, NewValue} ->
> NewSocket = logStateChange(Socket, LogRecord, NewValue),
> socketLoop(NewSocket);
>
> {logToScreen, LogRecord, NewValue} ->
> NewSocket = logToScreenChange(Socket, LogRecord, NewValue),
> socketLoop(NewSocket);
>
> {logLevel, LogRecord, NewValue} ->
> NewSocket = logLevelChange(Socket, LogRecord, NewValue),
> socketLoop(NewSocket);
>
> exit ->
> ok;
>
> Other ->
> alarmmgr:notify(?unknownMessageReceived, [?MODULE, ?LINE,
Other]),
> log(Socket, logAlarm, {notify, ?unknownMessageReceived,
?MODULE, ?LINE, [Other]}),
> socketLoop(Socket)
>
> end.
>
>
%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
%%%%%%%%
> %%%
> %%% Function : accDecode/1
> %%%
> %%% Purpose : Checks and deocode the received packets from the other
call centre, and
> %%% sends them to Alternative Call Centre Gateway (ACCGW).
> %%%
> %%% Args : [255, Length1, Length2, Command | DataList] - The list,
which is received to be decoded.
> %%% 255 is a flag indicating start of the packet.
> %%% Lenght1 and Lenght2 are representing the total
> %%% lenght of the packet.
> %%% Command is type os the packet, which either is
> %%% 1 indicating "reply" or 2 indicating "request".
> %%% DataList is a list of tuples of Service Type and
> %%% the expected queuing time.
> %%% Return : error - The received packet is not valid.
> %%% {reply, decodeElements(DataList)} - "reply" is the type of
the packet,and the value of
> %%% decodeElements(DataList) is decoded received data.
> %%%
> %%% {request} - "request" is the type of the packet.
> %%%
> %%% {packetNotEnded, DataList} - "packetNotEnded" indicates that
the received packet is too short.
> %%%
> %%% {splitData, accDecode(NewDataList), RestData} - "splitData"
indicates the received packet had
>
> %%% been too long, and is splitet into "NewDataList"
> %%% and "RestData".
> %%%
>
%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
%%%%%%%%
> accDecode([255,0,0,2]) ->
> {request};
>
> accDecode([255, Length1, Length2, 1 | DataList]) ->
> Length = (Length1 * 256) + Length2,
> case decodeList(Length, DataList) of
> packetOK ->
> {reply, decodeElements(DataList)};
> packetNotEnded ->
> {packetNotEnded, DataList};
> {packetTooLong, {NewDataList, RestData}} ->
> {splitData, accDecode(NewDataList), RestData}
> end;
>
> accDecode(_) ->
> {error, invalidPacket}.
>
>
%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
%%%%%%%%
> %%%
> %%% Function : splitList/2
> %%%
> %%% Purpose : Split a list into two at a specified length.
> %%%
> %%% Args : List - The list, which is to be splitet into two.
> %%% Splitpoint - The number of enteries before splitting.
> %%%
> %%% Return : {FirstList, SecondList} - FirstList is the list before
the
> %%% split point. SecondList is the
> %%% remainder of the list after the split point.
> %%%
>
%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
%%%%%%%%
> splitList(List, SplitPoint) ->
> splitList(List, SplitPoint, []).
>
> splitList([H | RestOfList], N, FirstList) when N > 0 ->
> splitList(RestOfList, N - 1, [H | FirstList]);
>
> splitList(SecondList, 0, FirstList) ->
> {lists:reverse(FirstList), SecondList}.
>
>
%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
%%%%%%%%
> %%%
> %%% Function : decodeList/2
> %%%
> %%% Purpose : Checks the lenght of the data and call the split
fucntion, if the
> %%% data is too long.
> %%%
> %%% Args : Length - The total length of the data.
> %%%
> %%% Return : packetNotEnded - Indicates that the received packet is
too short.
> %%% {packetTooLong, splitList(DList, Length)} - "packetTooLong"
indicates
> %%% the list/data is too long,
> %%% and has to be splitet.
> %%%
>
%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
%%%%%%%%
> decodeList(Length, DList) ->
> ListLength = length(DList),
> case Length of
> ListLength ->
> packetOK;
> N when N > ListLength ->
> packetNotEnded;
> _ ->
> {packetTooLong, splitList(DList, Length)}
> end.
>
>
%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
%%%%%%%%
> %%%
> %%% Function : decodeElement/1
> %%%
> %%% Purpose : Decode the list into a list of tuples of two elements.
> %%%
> %%% Args : List - A flatten list.
> %%%
> %%% Return : Data - A list of tuples of Service Type and expected
queuing time..
> %%%
>
%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
%%%%%%%%
> decodeElements([]) ->
> [];
>
> decodeElements([ServT1, ServT2, QT1, QT2 | Tail]) ->
> decodeElements([ServT1, ServT2, QT1, QT2 | Tail], []).
>
>
> decodeElements([ServT1, ServT2, QT1, QT2 | Tail], Data) ->
> NewData = [{ServT1 * 256 + ServT2, QT1 *256 + QT2} | Data],
> decodeElements(Tail, NewData);
>
> decodeElements([], Data) ->
> Data.
>
>
>
%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
%%%%%%%%
> %%%
> %%% Function: accEncode/1 & /2
> %%%
> %%% Purpose : Encode the received OCC tuple to be a list of bytes
including
> %%% a start flag (255) length of data and 1 for request.
> %%%
> %%% Args : Data - A list of tuples to be encoded.
> %%%
> %%% Return : [255, 0, 0, 1] or [255, Length1, Length2, 1 |
EncodedData)]
> %%%
>
%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
%%%%%%%%
> accEncode(Data) ->
> accEncode(Data, []).
>
> accEncode([], []) ->
> [255, 0, 0, 1];
>
> accEncode([], EncodedData) ->
> Length = length(EncodedData),
> Length1 = Length div 256,
> Length2 = Length rem 256,
> [255, Length1, Length2, 1 | EncodedData];
>
> accEncode([{ServiceType, QueueTime}|RestData], EncodedData) ->
> accEncode(RestData, [ServiceType div 256, ServiceType rem 256,
QueueTime div 256, QueueTime rem 256 | EncodedData]).
>
>
> send(Socket, Data)->
> io:format("accsocket:send(~p,~p)~n",[Socket,Data]),
> erlang:ports(),
> case gen_tcp:send(Socket, Data) of
> % Socket ! {self(), Data}.
> ok ->
> io:format("accsock:send-> ok~n"),
> ok;
>
> {error, Reason} ->
> s io:format("accsock:error Reasson ~p~n",[Reason]),
> erlang:ports(),
> exit(Reason)
> end.
>
>
>
>
=========================================================
Per Bergqvist
Synapse Systems AB
Phone: +46 709 686 685
Email: per@REDACTED