fix debugging info
This commit is contained in:
parent
980f6db84d
commit
3631439be9
@ -278,7 +278,6 @@ udp_receive(term_t Socket, term_t Data, term_t From, term_t options)
|
|||||||
if ( (n=nbio_recvfrom(socket, buf, sizeof(buf), flags,
|
if ( (n=nbio_recvfrom(socket, buf, sizeof(buf), flags,
|
||||||
(struct sockaddr*)&sockaddr, &alen)) == -1 )
|
(struct sockaddr*)&sockaddr, &alen)) == -1 )
|
||||||
return nbio_error(errno, TCP_ERRNO);
|
return nbio_error(errno, TCP_ERRNO);
|
||||||
|
|
||||||
if ( !PL_unify_chars(Data, as, n, buf) )
|
if ( !PL_unify_chars(Data, as, n, buf) )
|
||||||
return FALSE;
|
return FALSE;
|
||||||
|
|
||||||
|
@ -67,7 +67,6 @@ server(Port) :-
|
|||||||
run_server(Socket).
|
run_server(Socket).
|
||||||
|
|
||||||
run_server(Socket) :-
|
run_server(Socket) :-
|
||||||
writeln(before_main),
|
|
||||||
tcp_open_socket(Socket, In, _Out),
|
tcp_open_socket(Socket, In, _Out),
|
||||||
add_stream_to_pool(In, accept(Socket)),
|
add_stream_to_pool(In, accept(Socket)),
|
||||||
stream_pool_main_loop.
|
stream_pool_main_loop.
|
||||||
@ -185,7 +184,6 @@ receive_loop(Socket, Queue) :-
|
|||||||
repeat,
|
repeat,
|
||||||
udp_receive(Socket, Data, From, [as(atom)]),
|
udp_receive(Socket, Data, From, [as(atom)]),
|
||||||
thread_send_message(Queue, got(Data, From)),
|
thread_send_message(Queue, got(Data, From)),
|
||||||
writeln(before_main:Data:done),
|
|
||||||
Data == quit, !,
|
Data == quit, !,
|
||||||
tcp_close_socket(Socket).
|
tcp_close_socket(Socket).
|
||||||
|
|
||||||
@ -213,7 +211,6 @@ run_udp :-
|
|||||||
udp_send(S, 'quit', localhost:Port, []),
|
udp_send(S, 'quit', localhost:Port, []),
|
||||||
thread_get_message(got(Q, _)),
|
thread_get_message(got(Q, _)),
|
||||||
thread_join(ThreadId, Exit),
|
thread_join(ThreadId, Exit),
|
||||||
writeln(done),
|
|
||||||
tcp_close_socket(S),
|
tcp_close_socket(S),
|
||||||
assertion(X=='hello world'),
|
assertion(X=='hello world'),
|
||||||
assertion(Q=='quit'),
|
assertion(Q=='quit'),
|
||||||
|
Reference in New Issue
Block a user