SHOW:
|
|
- or go back to the newest paste.
1 | load_netlayer:- | |
2 | create_netlayer_server(Socket, Port, Stream), | |
3 | thread_create(handle_incoming_connections(Stream), NetLayerThread, [detached(true)]). | |
4 | ||
5 | handle_incoming_connections(Stream):- | |
6 | write('waiting to connect'), | |
7 | tcp_accept(Stream, ClientSocket, ClientIP), | |
8 | write('accepted connection!'), | |
9 | thread_create(create_client(ClientSocket, ClientIP), ClientThread, [detatched(true)]), | |
10 | handle_incoming_connections(Stream). | |
11 | ||
12 | create_client(Socket, IP):- | |
13 | - | setup_call_cleanup(tcp_open_socket(Socket, Stream), handle_client(Socket, IP, Stream), close_connection(Stream)). |
13 | + | setup_call_cleanup(tcp_open_socket(Socket, In, Out), |
14 | handle_client(Socket, IP, In,Out), close_connection(Stream)). | |
15 | ||
16 | create_netlayer_server(Socket, Port, Stream):- | |
17 | Port = 42069, | |
18 | tcp_socket(Socket), | |
19 | tcp_bind(Socket, Port), | |
20 | tcp_listen(Socket, 5), | |
21 | tcp_open_socket(Socket, Stream). | |
22 | - | handle_client(Socket, IP, Stream):- |
22 | + | |
23 | - | writef('hello %w %w', [Socket, IP]). |
23 | + | handle_client(Socket, IP, In,Out):- |
24 | ||
25 | set_stream(In, close_on_abort(false)), | |
26 | set_stream(Out, close_on_abort(false)), | |
27 | writef(Out ,'hello %w %w', [Socket, IP]). | |
28 | ||
29 | close_connection(Stream):- | |
30 | close(Stream). |