aboutsummaryrefslogtreecommitdiff
path: root/src/transport/test_plugin_transport_http.c
diff options
context:
space:
mode:
authorMatthias Wachs <wachs@net.in.tum.de>2010-07-06 12:45:34 +0000
committerMatthias Wachs <wachs@net.in.tum.de>2010-07-06 12:45:34 +0000
commit911c190c1f1ab50c31a697dc23231ae8a46955fe (patch)
treebc20340974186c1dace14c8ce048667a713058fb /src/transport/test_plugin_transport_http.c
parentb69bb95f086d08f716415add6d4f754943fd8c35 (diff)
downloadgnunet-911c190c1f1ab50c31a697dc23231ae8a46955fe.tar.gz
gnunet-911c190c1f1ab50c31a697dc23231ae8a46955fe.zip
Diffstat (limited to 'src/transport/test_plugin_transport_http.c')
-rw-r--r--src/transport/test_plugin_transport_http.c9
1 files changed, 6 insertions, 3 deletions
diff --git a/src/transport/test_plugin_transport_http.c b/src/transport/test_plugin_transport_http.c
index d72bfd3c2..fd56b335a 100644
--- a/src/transport/test_plugin_transport_http.c
+++ b/src/transport/test_plugin_transport_http.c
@@ -464,7 +464,6 @@ static void task_send_cont (void *cls,
464 { 464 {
465 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Message with max msg size succesfully sent!\n",fail_msgs_transmited_to_local_addrs); 465 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Message with max msg size succesfully sent!\n",fail_msgs_transmited_to_local_addrs);
466 fail_msg_transmited_max_size = GNUNET_NO; 466 fail_msg_transmited_max_size = GNUNET_NO;
467 //shutdown_clean();
468 } 467 }
469} 468}
470 469
@@ -500,7 +499,7 @@ receive (void *cls,
500 if (ntohs(message->size) == GNUNET_SERVER_MAX_MESSAGE_SIZE-1) 499 if (ntohs(message->size) == GNUNET_SERVER_MAX_MESSAGE_SIZE-1)
501 { 500 {
502 fail_msg_transmited_max_size = GNUNET_NO; 501 fail_msg_transmited_max_size = GNUNET_NO;
503 //shutdown_clean(); 502 shutdown_clean();
504 } 503 }
505 504
506 return GNUNET_TIME_UNIT_ZERO; 505 return GNUNET_TIME_UNIT_ZERO;
@@ -752,7 +751,7 @@ static int send_data( struct HTTP_Transfer * result, char * url)
752 return GNUNET_SYSERR; 751 return GNUNET_SYSERR;
753 } 752 }
754#if DEBUG_CURL 753#if DEBUG_CURL
755 curl_easy_setopt(curl_handle, CURLOPT_VERBOSE, 1L); 754 curl_easy_setopt(put_curl_handle, CURLOPT_VERBOSE, 1L);
756#endif 755#endif
757 curl_easy_setopt(curl_handle, CURLOPT_URL, url); 756 curl_easy_setopt(curl_handle, CURLOPT_URL, url);
758 curl_easy_setopt(curl_handle, CURLOPT_PUT, 1L); 757 curl_easy_setopt(curl_handle, CURLOPT_PUT, 1L);
@@ -976,6 +975,7 @@ static void run_connection_tests( int phase )
976 memcpy(tmp,&msg,sizeof(struct GNUNET_MessageHeader)); 975 memcpy(tmp,&msg,sizeof(struct GNUNET_MessageHeader));
977 api->send(api->cls, &my_identity, tmp, sizeof(struct GNUNET_MessageHeader), 0, TIMEOUT, NULL,tmp_addr->addr, tmp_addr->addrlen, GNUNET_YES, &task_send_cont, &fail_msgs_transmited_to_local_addrs); 976 api->send(api->cls, &my_identity, tmp, sizeof(struct GNUNET_MessageHeader), 0, TIMEOUT, NULL,tmp_addr->addr, tmp_addr->addrlen, GNUNET_YES, &task_send_cont, &fail_msgs_transmited_to_local_addrs);
978 tmp_addr = tmp_addr->next; 977 tmp_addr = tmp_addr->next;
978
979 count ++; 979 count ++;
980 type ++; 980 type ++;
981 } 981 }
@@ -984,6 +984,9 @@ static void run_connection_tests( int phase )
984 984
985 if (phase==2) 985 if (phase==2)
986 { 986 {
987 /* disconnect from peer, so new connections are created */
988 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,"Disconnect from peer: `%s'\n", GNUNET_i2s(&my_identity));
989 api->disconnect(api->cls, &my_identity);
987 990
988 struct GNUNET_MessageHeader msg; 991 struct GNUNET_MessageHeader msg;
989 char * tmp = GNUNET_malloc(sizeof(struct GNUNET_MessageHeader)); 992 char * tmp = GNUNET_malloc(sizeof(struct GNUNET_MessageHeader));