Kernel/lib/io.pl

1294 peer_queue_create(Name, Control, Sync, Direction, Event) :-
1296 	    peer_queue_create1(Name, Control, Sync, Direction, Event)
1300 peer_queue_create1(Name, Control, Sync, Direction, Event) :-
1301 	(atom(Name), atom(Control), is_event(Event) ->
1312 	create_peer_queue_type(Type, Name, Control, Sync, Direction, Event).
1313 peer_queue_create1(Name, Control, Sync, Direction, Event) :-
1315 	error(E, peer_queue_create(Name, Control, Sync, Direction, Event)).
1319     create_peer_queue_type(remote(PeerHost,LocalHost,TimeOut), Name, Control, Sync, Direction, Event) ?-
1328 	    connect_remote_queue(Status, Soc, Name, Control, Sync, Direction, Event, TimeOut, PeerHost, Return),
1335     create_peer_queue_type(embed(_,_,_), Name, _Peer, _Sync, Direction, Event) ?-
1336 	ecl_create_embed_queue(Name, Direction, Event),
1342     ecl_create_embed_queue(Name, Direction, Event) :-
1348 	    (Event == '' -> Options = [yield(on)] ; Options = [event(Event)]),
1360     connect_remote_queue(success, Soc, Name, Control, Sync, Direction, Event, TimeOut, RHost, StreamId) :-
1362 	      (create_remote_queue(Sync, Direction, Soc, Name, Control, TimeOut, RHost, Event) ->
1381     create_remote_queue(async, _, Soc, Name, Control, TimeOut, RHost, Event) ?-
1382 	remote_create_async_queue(Soc, Name, Control, TimeOut, RHost, Event).
1383     create_remote_queue(sync, fromec, Soc, Name, Control, TimeOut, RHost, Event) ?-
1384 	remote_create_fromec_queue(Soc, Name, Control, TimeOut, RHost, Event).
1385     create_remote_queue(sync, toec, Soc, Name, Control, TimeOut, RHost, Event) ?-
1386 	remote_create_toec_queue(Soc, Name, Control, TimeOut, RHost, Event).
1389     remote_create_toec_queue(Soc, Name, Control, TimeOut, RemoteHost, Event) :-
1394 	(Event == '' ->
1396         ;   set_stream_property(Name, event, Event)
1402     % Event is dummy for now, to be used for remote side requesting data
1410     remote_create_async_queue(Soc, Name, Control, TimeOut, RemoteHost, Event) :-
1413 	(Event == '' ->
1415         ;   set_stream_property(Name, event, Event)
1579 handle_control(queue_create(Name,Sync,Direction,Event), Control, NextMsg) :- -?-> !,
1581 	   peer_queue_create1(Name, Control, Sync, Direction, Event) -> true;true),
1626 	get_stream_info(Queue, event, Event),
1627 	error(Event, rem_flushio(Queue, Len)).