test_connection.c | test_connection.c | |||
---|---|---|---|---|
skipping to change at line 104 | skipping to change at line 104 | |||
GNUNET_TIME_relative_multiply | GNUNET_TIME_relative_multiply | |||
(GNUNET_TIME_UNIT_SECONDS, 5), &receive_chec k, | (GNUNET_TIME_UNIT_SECONDS, 5), &receive_chec k, | |||
cls); | cls); | |||
} | } | |||
else | else | |||
{ | { | |||
#if VERBOSE | #if VERBOSE | |||
GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Receive closes accepted socket\n" ); | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Receive closes accepted socket\n" ); | |||
#endif | #endif | |||
*ok = 0; | *ok = 0; | |||
GNUNET_CONNECTION_destroy (asock, GNUNET_YES); | GNUNET_CONNECTION_destroy (asock); | |||
GNUNET_CONNECTION_destroy (csock); | ||||
} | } | |||
} | } | |||
static void | static void | |||
run_accept (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc) | run_accept (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc) | |||
{ | { | |||
#if VERBOSE | #if VERBOSE | |||
GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Test accepts connection\n"); | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Test accepts connection\n"); | |||
#endif | #endif | |||
asock = GNUNET_CONNECTION_create_from_accept (NULL, NULL, ls); | asock = GNUNET_CONNECTION_create_from_accept (NULL, NULL, ls); | |||
GNUNET_assert (asock != NULL); | GNUNET_assert (asock != NULL); | |||
GNUNET_assert (GNUNET_YES == GNUNET_CONNECTION_check (asock)); | GNUNET_assert (GNUNET_YES == GNUNET_CONNECTION_check (asock)); | |||
#if VERBOSE | #if VERBOSE | |||
GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Test destroys listen socket\n"); | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Test destroys listen socket\n"); | |||
#endif | #endif | |||
GNUNET_CONNECTION_destroy (lsock, GNUNET_YES); | GNUNET_CONNECTION_destroy (lsock); | |||
#if VERBOSE | #if VERBOSE | |||
GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | |||
"Test asks to receive on accepted socket\n"); | "Test asks to receive on accepted socket\n"); | |||
#endif | #endif | |||
GNUNET_CONNECTION_receive (asock, 1024, | GNUNET_CONNECTION_receive (asock, 1024, | |||
GNUNET_TIME_relative_multiply | GNUNET_TIME_relative_multiply | |||
(GNUNET_TIME_UNIT_SECONDS, 5), &receive_check, | (GNUNET_TIME_UNIT_SECONDS, 5), &receive_check, | |||
cls); | cls); | |||
} | } | |||
skipping to change at line 143 | skipping to change at line 144 | |||
{ | { | |||
#if VERBOSE | #if VERBOSE | |||
GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | |||
"Test prepares to transmit on connect socket\n"); | "Test prepares to transmit on connect socket\n"); | |||
#endif | #endif | |||
GNUNET_assert (size >= 12); | GNUNET_assert (size >= 12); | |||
strcpy ((char *) buf, "Hello World"); | strcpy ((char *) buf, "Hello World"); | |||
#if VERBOSE | #if VERBOSE | |||
GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Test destroys client socket\n"); | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Test destroys client socket\n"); | |||
#endif | #endif | |||
GNUNET_CONNECTION_destroy (csock, GNUNET_YES); | ||||
return 12; | return 12; | |||
} | } | |||
static void | static void | |||
task (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc) | task (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc) | |||
{ | { | |||
ls = open_listen_socket (); | ls = open_listen_socket (); | |||
lsock = GNUNET_CONNECTION_create_from_existing (ls); | lsock = GNUNET_CONNECTION_create_from_existing (ls); | |||
GNUNET_assert (lsock != NULL); | GNUNET_assert (lsock != NULL); | |||
csock = GNUNET_CONNECTION_create_from_connect (cfg, "localhost", PORT); | csock = GNUNET_CONNECTION_create_from_connect (cfg, "localhost", PORT); | |||
End of changes. 3 change blocks. | ||||
3 lines changed or deleted | 3 lines changed or added | |||
This html diff was produced by rfcdiff 1.41. The latest version is available from http://tools.ietf.org/tools/rfcdiff/ |