diff options
author | Christian Grothoff <christian@grothoff.org> | 2013-10-02 21:05:48 +0000 |
---|---|---|
committer | Christian Grothoff <christian@grothoff.org> | 2013-10-02 21:05:48 +0000 |
commit | 875342e4d0114e626dcf502362787d048d5e12fc (patch) | |
tree | 9ae7e303b3310a892c219b702f36005336ad5eff /src/conversation/gnunet-service-conversation.c | |
parent | 18b62beec7902acecaad00c0470f2f1d4d98b244 (diff) | |
download | gnunet-875342e4d0114e626dcf502362787d048d5e12fc.tar.gz gnunet-875342e4d0114e626dcf502362787d048d5e12fc.zip |
-fix logging
Diffstat (limited to 'src/conversation/gnunet-service-conversation.c')
-rw-r--r-- | src/conversation/gnunet-service-conversation.c | 55 |
1 files changed, 17 insertions, 38 deletions
diff --git a/src/conversation/gnunet-service-conversation.c b/src/conversation/gnunet-service-conversation.c index 5575b23fc..4c4bdc133 100644 --- a/src/conversation/gnunet-service-conversation.c +++ b/src/conversation/gnunet-service-conversation.c | |||
@@ -128,36 +128,31 @@ static struct GNUNET_MESH_Tunnel *tunnel_unreliable; | |||
128 | /** | 128 | /** |
129 | * List for missed calls | 129 | * List for missed calls |
130 | */ | 130 | */ |
131 | struct GNUNET_CONTAINER_SList *missed_calls; | 131 | static struct GNUNET_CONTAINER_SList *missed_calls; |
132 | 132 | ||
133 | /** | 133 | /** |
134 | * List for peers to notify that we are available again | 134 | * List for peers to notify that we are available again |
135 | */ | 135 | */ |
136 | struct GNUNET_CONTAINER_SList *peers_to_notify; | 136 | static struct GNUNET_CONTAINER_SList *peers_to_notify; |
137 | 137 | ||
138 | /** | 138 | /** |
139 | * Audio buffer (outgoing) | 139 | * Audio buffer (outgoing) |
140 | */ | 140 | */ |
141 | struct GNUNET_CONTAINER_SList *audio_buffer; | 141 | static struct GNUNET_CONTAINER_SList *audio_buffer; |
142 | 142 | ||
143 | /** | 143 | /** |
144 | * The pointer to the task for sending audio | 144 | * The pointer to the task for sending audio |
145 | */ | 145 | */ |
146 | GNUNET_SCHEDULER_TaskIdentifier audio_task; | 146 | static GNUNET_SCHEDULER_TaskIdentifier audio_task; |
147 | 147 | ||
148 | /** | 148 | /** |
149 | * The pointer to the task for checking timeouts an calling a peer | 149 | * The pointer to the task for checking timeouts an calling a peer |
150 | */ | 150 | */ |
151 | GNUNET_SCHEDULER_TaskIdentifier timeout_task; | 151 | static GNUNET_SCHEDULER_TaskIdentifier timeout_task; |
152 | 152 | ||
153 | /** | 153 | /** |
154 | * Sequencenumber for the pakets (for evaltuation purposes) | 154 | * Timestamp for call statistics |
155 | */ | 155 | */ |
156 | int SequenceNumber = 0; | ||
157 | |||
158 | /** | ||
159 | * Timestamp for call statistics | ||
160 | */ | ||
161 | static struct GNUNET_TIME_Absolute start_time; | 156 | static struct GNUNET_TIME_Absolute start_time; |
162 | 157 | ||
163 | /** | 158 | /** |
@@ -891,8 +886,6 @@ transmit_mesh_message (void *cls, size_t size, void *buf) | |||
891 | { | 886 | { |
892 | struct VoIPMeshMessageHeader *msg_header = | 887 | struct VoIPMeshMessageHeader *msg_header = |
893 | (struct VoIPMeshMessageHeader *) cls; | 888 | (struct VoIPMeshMessageHeader *) cls; |
894 | msg_header->SequenceNumber = SequenceNumber += 1; | ||
895 | msg_header->time = GNUNET_TIME_absolute_get (); | ||
896 | 889 | ||
897 | GNUNET_log (GNUNET_ERROR_TYPE_INFO, _("Transmitting message over mesh\n")); | 890 | GNUNET_log (GNUNET_ERROR_TYPE_INFO, _("Transmitting message over mesh\n")); |
898 | 891 | ||
@@ -984,9 +977,6 @@ transmit_audio_task (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc) | |||
984 | iterator = GNUNET_CONTAINER_slist_begin (audio_buffer); | 977 | iterator = GNUNET_CONTAINER_slist_begin (audio_buffer); |
985 | msg = | 978 | msg = |
986 | (struct AudioMessage *) GNUNET_CONTAINER_slist_get (&iterator, NULL); | 979 | (struct AudioMessage *) GNUNET_CONTAINER_slist_get (&iterator, NULL); |
987 | msg->SequenceNumber = SequenceNumber += 1; | ||
988 | msg->time = GNUNET_TIME_absolute_get (); | ||
989 | |||
990 | GNUNET_CONTAINER_slist_erase (&iterator); | 980 | GNUNET_CONTAINER_slist_erase (&iterator); |
991 | GNUNET_CONTAINER_slist_iter_destroy (&iterator); | 981 | GNUNET_CONTAINER_slist_iter_destroy (&iterator); |
992 | } | 982 | } |
@@ -1344,30 +1334,19 @@ handle_mesh_audio_message (void *cls, struct GNUNET_MESH_Tunnel *tunnel, | |||
1344 | void **tunnel_ctx, | 1334 | void **tunnel_ctx, |
1345 | const struct GNUNET_MessageHeader *message) | 1335 | const struct GNUNET_MessageHeader *message) |
1346 | { | 1336 | { |
1337 | const struct AudioMessage *audio; | ||
1338 | audio = (const struct AudioMessage *) message; | ||
1347 | 1339 | ||
1348 | GNUNET_MESH_receive_done (tunnel); | 1340 | GNUNET_MESH_receive_done (tunnel); |
1349 | |||
1350 | if (CONNECTED != connection.status) | 1341 | if (CONNECTED != connection.status) |
1351 | return GNUNET_OK; | 1342 | return GNUNET_OK; |
1352 | 1343 | GNUNET_log (GNUNET_ERROR_TYPE_INFO, | |
1353 | 1344 | "[RECV] %dbytes\n", | |
1354 | struct AudioMessage *audio; | 1345 | ntohs (audio->header.size)); |
1355 | size_t msg_size; | ||
1356 | msg_size = sizeof (struct AudioMessage); | ||
1357 | |||
1358 | audio = (struct AudioMessage *) message; | ||
1359 | |||
1360 | GNUNET_log (GNUNET_ERROR_TYPE_INFO, "[RECV] %dbytes\n", audio->length); | ||
1361 | |||
1362 | if (NULL == playback_helper) | 1346 | if (NULL == playback_helper) |
1363 | return GNUNET_OK; | 1347 | return GNUNET_OK; |
1364 | |||
1365 | (void) GNUNET_HELPER_send (playback_helper, | 1348 | (void) GNUNET_HELPER_send (playback_helper, |
1366 | message, GNUNET_YES, NULL, NULL); | 1349 | message, GNUNET_YES, NULL, NULL); |
1367 | |||
1368 | data_received++; | ||
1369 | data_received_size += msg_size; | ||
1370 | |||
1371 | return GNUNET_OK; | 1350 | return GNUNET_OK; |
1372 | } | 1351 | } |
1373 | 1352 | ||
@@ -1387,14 +1366,14 @@ static int | |||
1387 | process_record_messages (void *cls GNUNET_UNUSED, void *client, | 1366 | process_record_messages (void *cls GNUNET_UNUSED, void *client, |
1388 | const struct GNUNET_MessageHeader *msg) | 1367 | const struct GNUNET_MessageHeader *msg) |
1389 | { | 1368 | { |
1390 | size_t msg_size; | 1369 | const struct AudioMessage *message = (const struct AudioMessage *) msg; |
1391 | struct AudioMessage *message = (struct AudioMessage *) msg; | ||
1392 | msg_size = sizeof (struct AudioMessage); | ||
1393 | 1370 | ||
1394 | GNUNET_log (GNUNET_ERROR_TYPE_INFO, " [REC] %dbyte\n", message->length); | 1371 | GNUNET_log (GNUNET_ERROR_TYPE_INFO, |
1372 | " [REC] %dbyte\n", | ||
1373 | ntohs (message->header.size)); | ||
1395 | GNUNET_CONTAINER_slist_add_end (audio_buffer, | 1374 | GNUNET_CONTAINER_slist_add_end (audio_buffer, |
1396 | GNUNET_CONTAINER_SLIST_DISPOSITION_TRANSIENT, | 1375 | GNUNET_CONTAINER_SLIST_DISPOSITION_TRANSIENT, |
1397 | message, msg_size); | 1376 | message, ntohs (message->header.size)); |
1398 | 1377 | ||
1399 | return GNUNET_OK; | 1378 | return GNUNET_OK; |
1400 | } | 1379 | } |