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/