Kernel/lib/io.pl

949 %      PeerType: either remote or embed.
953 %                   remote(PeerHost,LocalHost,TimeOut)
960 %              What is used has implications for what the remote side can
963 %                   1) actual ECLiPSe side hostname: remote side must also
965 %                   2) localhost: remote side must used localhost for the
968 %                   3) not instantiated: remote side can use either
986 %      PeerType: peer type for the queue: Either embed or remote
989 %             sync(SocketName): synchronous remote queue, with socket
990 %             async           : asynchronous remote queue
994 % The above information is used to clean up a remote side when it is
998 % To ensure that the remote interface protocol is followed at all times,
1003 %	- remote flush (but not if inside ec_waitio)
1010 % First clause is the current version of the remote protocol.
1027 	    printf(warning_output, "Warning: Illegal events_defer nesting detected during remote protocol (%w)",[Goal]),
1080 	set_peer_property(Control, peer_info{type:remote,lang:RemoteLang,
1081                                      connect:remote(RemoteHost,Host,TimeOut)}),
1110 	     printf(error, "Incompatible remote protocol on remote side: %w%n",
1216 	peer_queue_get_property(PhysicalStream, peer, remote(ControlStream)),
1233 	recorda(Key, peer_queue{ptype:remote, pname:Control, qtype:Type, dir:Direction}).
1268     close_peer_queue_type(remote(Peer), StreamNum, QType) :-
1308 	 (Sync == async,  functor(Type,remote,_))
1319     create_peer_queue_type(remote(PeerHost,LocalHost,TimeOut), Name, Control, Sync, Direction, Event) ?-
1331 	 printf(error, "Unexpected control message %w while creating peer queue %w on remote side %w; disconnecting.%n", [ResumeMessage, Name, Control]),
1402     % Event is dummy for now, to be used for remote side requesting data
1411     % use Control to remember which remote process this stream is connected to
1433 		% unilateral disconnect from remote side; disconnect locally now
1436 	    ;   printf(error, "Unexpected incoming message %w on remote %w.\n", [InMessage,Control]),
1459           peer_get_property(Control,type,remote)
1467 	;   true  % Control is not a current remote peer...
1494     % wait for remote input to arrive, handle any messages before this,
1539 		    "Unexpected resume from remote peer %w while waiting for %w%n%b",
1586 	((current_stream(Queue),get_queue_info(Queue, Queue, remote(Control), QType, _)) ->
1588 	;   % not a remote queue, just ignore
1592 % remote side already disconnected, no acknowledgement
1596 % Control is disconnected. Assume remote side disconnected unexpectedly
1615 	    % handle events during remote flush
1621 	    printf(error, "Unexpected events_nodefer state in remote flush %w%n", [Queue])
1648 	printf(error, "Problem with cleaning up remote peer %w.%n", [Control]).
1656 	% get all the socket streams associated with this remote process
1668              get_queue_info(Queue, StreamNum, remote(Peer), QType, _Dir),
1801 % First case happens if a remote peer has disconnected. In this case, the
1802 % remote peer code should have cleaned up already