aboutsummaryrefslogtreecommitdiff
path: root/src/transport/transport-testing.c
diff options
context:
space:
mode:
authorMatthias Wachs <wachs@net.in.tum.de>2011-08-11 23:32:53 +0000
committerMatthias Wachs <wachs@net.in.tum.de>2011-08-11 23:32:53 +0000
commit96c4f70b09d1413e2fedba83b2dcbeba13c9b1f7 (patch)
tree95c39e90930e3e5a725c341093fba98b047beae2 /src/transport/transport-testing.c
parentcb11932b64344bc9bde5f5163eefdfc059946c9a (diff)
downloadgnunet-96c4f70b09d1413e2fedba83b2dcbeba13c9b1f7.tar.gz
gnunet-96c4f70b09d1413e2fedba83b2dcbeba13c9b1f7.zip
version with connecting peer working
Diffstat (limited to 'src/transport/transport-testing.c')
-rw-r--r--src/transport/transport-testing.c24
1 files changed, 12 insertions, 12 deletions
diff --git a/src/transport/transport-testing.c b/src/transport/transport-testing.c
index 910d9a6d8..25e173b4a 100644
--- a/src/transport/transport-testing.c
+++ b/src/transport/transport-testing.c
@@ -40,9 +40,6 @@ notify_connect (void *cls,
40 const struct GNUNET_TRANSPORT_ATS_Information *ats, 40 const struct GNUNET_TRANSPORT_ATS_Information *ats,
41 uint32_t ats_count) 41 uint32_t ats_count)
42{ 42{
43 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Peer `%s' connected \n",
44 GNUNET_i2s (peer));
45
46 struct PeerContext * p = cls; 43 struct PeerContext * p = cls;
47 if (p == NULL) 44 if (p == NULL)
48 return; 45 return;
@@ -53,9 +50,6 @@ notify_connect (void *cls,
53static void 50static void
54notify_disconnect (void *cls, const struct GNUNET_PeerIdentity *peer) 51notify_disconnect (void *cls, const struct GNUNET_PeerIdentity *peer)
55{ 52{
56 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Peer `%s' disconnected \n",
57 GNUNET_i2s (peer));
58
59 struct PeerContext * p = cls; 53 struct PeerContext * p = cls;
60 if (p == NULL) 54 if (p == NULL)
61 return; 55 return;
@@ -70,8 +64,6 @@ notify_receive (void *cls,
70 const struct GNUNET_TRANSPORT_ATS_Information *ats, 64 const struct GNUNET_TRANSPORT_ATS_Information *ats,
71 uint32_t ats_count) 65 uint32_t ats_count)
72{ 66{
73 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Receiving\n");
74
75 struct PeerContext * p = cls; 67 struct PeerContext * p = cls;
76 if (p == NULL) 68 if (p == NULL)
77 return; 69 return;
@@ -97,6 +89,7 @@ exchange_hello_last (void *cls,
97 GNUNET_HELLO_get_id ((const struct GNUNET_HELLO_Message *) 89 GNUNET_HELLO_get_id ((const struct GNUNET_HELLO_Message *)
98 message, &me->id)); 90 message, &me->id));
99 GNUNET_TRANSPORT_offer_hello (p1->th, message, NULL, NULL); 91 GNUNET_TRANSPORT_offer_hello (p1->th, message, NULL, NULL);
92 GNUNET_TRANSPORT_get_hello_cancel (me->th, &exchange_hello_last, cc);
100} 93}
101 94
102 95
@@ -117,6 +110,7 @@ exchange_hello (void *cls,
117 (int) GNUNET_HELLO_size((const struct GNUNET_HELLO_Message *)message), 110 (int) GNUNET_HELLO_size((const struct GNUNET_HELLO_Message *)message),
118 GNUNET_i2s (&me->id)); 111 GNUNET_i2s (&me->id));
119 GNUNET_TRANSPORT_offer_hello (p2->th, message, NULL, NULL); 112 GNUNET_TRANSPORT_offer_hello (p2->th, message, NULL, NULL);
113 GNUNET_TRANSPORT_get_hello_cancel (me->th, &exchange_hello, cc);
120} 114}
121 115
122static void 116static void
@@ -134,9 +128,9 @@ try_connect (void *cls,
134 &p1->id); 128 &p1->id);
135 GNUNET_TRANSPORT_try_connect (p1->th, 129 GNUNET_TRANSPORT_try_connect (p1->th,
136 &p2->id); 130 &p2->id);
137 cc->tct = GNUNET_SCHEDULER_add_delayed (GNUNET_TIME_UNIT_SECONDS, 131// cc->tct = GNUNET_SCHEDULER_add_delayed (GNUNET_TIME_UNIT_SECONDS,
138 &try_connect, 132// &try_connect,
139 cc); 133// cc);
140} 134}
141 135
142struct PeerContext * 136struct PeerContext *
@@ -157,7 +151,13 @@ GNUNET_TRANSPORT_TESTING_start_peer (const char * cfgname,
157 GNUNET_DISK_directory_remove (p->servicehome); 151 GNUNET_DISK_directory_remove (p->servicehome);
158 p->arm_proc = GNUNET_OS_start_process (NULL, NULL, "gnunet-service-arm", 152 p->arm_proc = GNUNET_OS_start_process (NULL, NULL, "gnunet-service-arm",
159 "gnunet-service-arm", 153 "gnunet-service-arm",
160 "-c", cfgname, NULL); 154 "-c", cfgname,
155#if VERBOSE_PEERS
156 "-L", "DEBUG",
157#else
158 "-L", "ERROR",
159#endif
160 NULL);
161 p->nc = nc; 161 p->nc = nc;
162 p->nd = nd; 162 p->nd = nd;
163 p->rec = rec; 163 p->rec = rec;