aboutsummaryrefslogtreecommitdiff
path: root/src/conversation/gnunet-service-conversation.c
diff options
context:
space:
mode:
authorChristian Grothoff <christian@grothoff.org>2013-10-02 21:05:48 +0000
committerChristian Grothoff <christian@grothoff.org>2013-10-02 21:05:48 +0000
commit875342e4d0114e626dcf502362787d048d5e12fc (patch)
tree9ae7e303b3310a892c219b702f36005336ad5eff /src/conversation/gnunet-service-conversation.c
parent18b62beec7902acecaad00c0470f2f1d4d98b244 (diff)
downloadgnunet-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.c55
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*/
131struct GNUNET_CONTAINER_SList *missed_calls; 131static 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*/
136struct GNUNET_CONTAINER_SList *peers_to_notify; 136static struct GNUNET_CONTAINER_SList *peers_to_notify;
137 137
138/** 138/**
139* Audio buffer (outgoing) 139* Audio buffer (outgoing)
140*/ 140*/
141struct GNUNET_CONTAINER_SList *audio_buffer; 141static 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*/
146GNUNET_SCHEDULER_TaskIdentifier audio_task; 146static 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*/
151GNUNET_SCHEDULER_TaskIdentifier timeout_task; 151static GNUNET_SCHEDULER_TaskIdentifier timeout_task;
152 152
153/** 153/**
154* Sequencenumber for the pakets (for evaltuation purposes) 154 * Timestamp for call statistics
155*/ 155 */
156int SequenceNumber = 0;
157
158/**
159* Timestamp for call statistics
160*/
161static struct GNUNET_TIME_Absolute start_time; 156static 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
1387process_record_messages (void *cls GNUNET_UNUSED, void *client, 1366process_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}