gg_echo object ....
**/
:-object gg_echo.
broadcast(UserHost, UserName, Message) :-
%% format('~w : broadcast from ~q ~q~n', [this, UserHost, UserName]),
get_field(used_name_list, UserList),
broadcast_loop(UserList, user(UserHost,UserName), Message).
broadcast_loop([], _From, _) :-
!,
%% format('~w : end of broadcast from ~q~n', [this, From]),
true.
broadcast_loop([User|List], User, Message) :-
%% User = user(Host,Name),
%% !, %% skip sender, neck cut.
%% format('~w : broadcast queue skip of ~q~n', [this, User]),
!, %% skip sender, body cut.
broadcast_loop(List, User, Message).
broadcast_loop([User|List], FromUser, Message) :-
User = user(NextHost,NextName),
broadcast_mesg(NextHost, NextName, Message),
broadcast_loop(List, FromUser, Message).
broadcast_mesg(Host, Name, _Message) :-
%% skip "sensor" data.
queue_full(Host, Name),
format('~w : QUEUE ~w:~w FULL~n', [this,Host,Name]),
!.
broadcast_mesg(Host, Name, Message) :-
set_queue(Host, Name, Message),
queue_length(Host, Name, Length),
format('~w: queue of ~w on ~w (size = ~w)~n', [this, Name, Host, Length]),
true.
get_broadcasted_data(user(Host,Name), Attributes) :-
queue_empty(Host,Name),
!,
default_server_reply(Attributes),
% format('SS1: ~w~n',[Attributes]),
true.
get_broadcasted_data(user(Host,Name), Attributes) :-
get_queue(Host, Name, Message),
queue_length(Host, Name, Length),
Attributes = [Length, Message],
% format('SS2: ~w~n',[Attributes]),
true.
default_server_reply(Attributes) :- %% derived
get_field(ball, position, Position),
Data = [ball, Position],
Message = [tell, ball_position, Data],
sleep(200),
Attributes = [0, Message].
:-end_object gg_echo.
/**
gg_client object ....
**/
:-object gg_client.
var server_port = 4321.
var server_host = unknown.
var client_host = unknown.
var client_name = unknown.
gg_client_loop(ClientHost, ServerHost, ServerPort) :-
client_host := ClientHost,
server_host := ServerHost,
server_port := ServerPort,
tcp_client(ServerHost, ServerPort, 10, StreamIn, StreamOut),
format('~w : connection accepted from ~w~n', [this, ServerHost]),
format('~w : ~q client running~n', [this, client_host]),
client_loop(StreamIn, StreamOut),
tcp_close(StreamIn),
tcp_close(StreamOut).
gg_client_loop(_ClientHost, _ServerHost, _ServerPort) :-
format('~w : exit (2)~n', [this]).
client_loop(StreamIn, StreamOut) :-
client_request(ServerInput),
tcp_put_term(StreamOut, ServerInput),
tcp_get_term(StreamIn, ServerReply),
server_reply(ServerReply),
client_exit(ServerReply),
!.
client_request(_ClientRequest) :-
format('~n~w : client_request/1 not implemented~n', [this]).
server_reply(_ServerReply) :-
format('~n~w : server_reply/1 not implemented~n', [this]).
client_exit(_ServerReply) :-
format('~n~w : client_exit/1 not implemented~n', [this]).
main :-
text_area(TextArea),
set_output(TextArea),
code_base_host(ServerHost),
%% local_host(ClientHost, _),
ClientHost = 'a computer',
gg_client_loop(ClientHost, ServerHost, server_port),
format('end of ~w main~n', [this]).
:-end_object gg_client.
/**