aboutsummaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
authorMatthias Wachs <wachs@net.in.tum.de>2013-09-16 15:10:51 +0000
committerMatthias Wachs <wachs@net.in.tum.de>2013-09-16 15:10:51 +0000
commit64bc1ae7763fd4f4e2ad4fb7acb4a1a2292bf988 (patch)
treee563e1dcbd7c8251438415558bc2869076f77b94 /src
parent75633a91d79403d921ef534bbb462697ce275733 (diff)
downloadgnunet-64bc1ae7763fd4f4e2ad4fb7acb4a1a2292bf988.tar.gz
gnunet-64bc1ae7763fd4f4e2ad4fb7acb4a1a2292bf988.zip
fixing indent
Diffstat (limited to 'src')
-rw-r--r--src/transport/gnunet-service-transport_manipulation.c120
1 files changed, 60 insertions, 60 deletions
diff --git a/src/transport/gnunet-service-transport_manipulation.c b/src/transport/gnunet-service-transport_manipulation.c
index f66d15d82..0ebe18c55 100644
--- a/src/transport/gnunet-service-transport_manipulation.c
+++ b/src/transport/gnunet-service-transport_manipulation.c
@@ -407,68 +407,68 @@ GST_manipulation_send (const struct GNUNET_PeerIdentity *target, const void *msg
407 size_t msg_size, struct GNUNET_TIME_Relative timeout, 407 size_t msg_size, struct GNUNET_TIME_Relative timeout,
408 GST_NeighbourSendContinuation cont, void *cont_cls) 408 GST_NeighbourSendContinuation cont, void *cont_cls)
409{ 409{
410 struct TM_Peer *tmp; 410 struct TM_Peer *tmp;
411 struct DelayQueueEntry *dqe; 411 struct DelayQueueEntry *dqe;
412 struct GNUNET_TIME_Relative delay; 412 struct GNUNET_TIME_Relative delay;
413 413
414 if (NULL != (tmp = GNUNET_CONTAINER_multihashmap_get (man_handle.peers, &target->hashPubKey))) 414 if (NULL != (tmp = GNUNET_CONTAINER_multihashmap_get (man_handle.peers, &target->hashPubKey)))
415 { 415 {
416 GNUNET_break (GNUNET_YES == GST_neighbours_test_connected(target)); 416 GNUNET_break (GNUNET_YES == GST_neighbours_test_connected(target));
417 /* Manipulate here */ 417 /* Manipulate here */
418 /* Delay */ 418 /* Delay */
419 if (UINT32_MAX != find_metric(tmp, GNUNET_ATS_QUALITY_NET_DELAY, TM_SEND)) 419 if (UINT32_MAX != find_metric(tmp, GNUNET_ATS_QUALITY_NET_DELAY, TM_SEND))
420 { 420 {
421 /* We have a delay */ 421 /* We have a delay */
422 delay.rel_value_us = find_metric (tmp, GNUNET_ATS_QUALITY_NET_DELAY, TM_SEND); 422 delay.rel_value_us = find_metric (tmp, GNUNET_ATS_QUALITY_NET_DELAY, TM_SEND);
423 dqe = GNUNET_malloc (sizeof (struct DelayQueueEntry) + msg_size); 423 dqe = GNUNET_malloc (sizeof (struct DelayQueueEntry) + msg_size);
424 dqe->id = *target; 424 dqe->id = *target;
425 dqe->tmp = tmp; 425 dqe->tmp = tmp;
426 dqe->sent_at = GNUNET_TIME_absolute_add (GNUNET_TIME_absolute_get(), delay); 426 dqe->sent_at = GNUNET_TIME_absolute_add (GNUNET_TIME_absolute_get(), delay);
427 dqe->cont = cont; 427 dqe->cont = cont;
428 dqe->cont_cls = cont_cls; 428 dqe->cont_cls = cont_cls;
429 dqe->msg = &dqe[1]; 429 dqe->msg = &dqe[1];
430 dqe->msg_size = msg_size; 430 dqe->msg_size = msg_size;
431 dqe->timeout = timeout; 431 dqe->timeout = timeout;
432 memcpy (dqe->msg, msg, msg_size); 432 memcpy (dqe->msg, msg, msg_size);
433 GNUNET_CONTAINER_DLL_insert_tail (tmp->send_head, tmp->send_tail, dqe); 433 GNUNET_CONTAINER_DLL_insert_tail (tmp->send_head, tmp->send_tail, dqe);
434 if (GNUNET_SCHEDULER_NO_TASK == tmp->send_delay_task) 434 if (GNUNET_SCHEDULER_NO_TASK == tmp->send_delay_task)
435 tmp->send_delay_task =GNUNET_SCHEDULER_add_delayed (delay, &send_delayed, dqe); 435 tmp->send_delay_task =GNUNET_SCHEDULER_add_delayed (delay, &send_delayed, dqe);
436 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, 436 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
437 "Delaying %u byte message to peer `%s' with generic delay for %ms\n", 437 "Delaying %u byte message to peer `%s' with generic delay for %ms\n",
438 msg_size, GNUNET_i2s (target), 438 msg_size, GNUNET_i2s (target),
439 GNUNET_STRINGS_relative_time_to_string (delay, GNUNET_YES)); 439 GNUNET_STRINGS_relative_time_to_string (delay, GNUNET_YES));
440 return; 440 return;
441 } 441 }
442 } 442 }
443 else if (UINT32_MAX != find_metric (&man_handle.general, GNUNET_ATS_QUALITY_NET_DELAY, TM_SEND)) 443 else if (UINT32_MAX != find_metric (&man_handle.general, GNUNET_ATS_QUALITY_NET_DELAY, TM_SEND))
444 { 444 {
445 GNUNET_break (GNUNET_YES == GST_neighbours_test_connected(target)); 445 GNUNET_break (GNUNET_YES == GST_neighbours_test_connected(target));
446 /* We have a delay */ 446 /* We have a delay */
447 delay.rel_value_us = find_metric (&man_handle.general, GNUNET_ATS_QUALITY_NET_DELAY, TM_SEND); 447 delay.rel_value_us = find_metric (&man_handle.general, GNUNET_ATS_QUALITY_NET_DELAY, TM_SEND);
448 dqe = GNUNET_malloc (sizeof (struct DelayQueueEntry) + msg_size); 448 dqe = GNUNET_malloc (sizeof (struct DelayQueueEntry) + msg_size);
449 dqe->id = *target; 449 dqe->id = *target;
450 dqe->tmp = NULL; 450 dqe->tmp = NULL;
451 dqe->sent_at = GNUNET_TIME_absolute_add (GNUNET_TIME_absolute_get(), delay); 451 dqe->sent_at = GNUNET_TIME_absolute_add (GNUNET_TIME_absolute_get(), delay);
452 dqe->cont = cont; 452 dqe->cont = cont;
453 dqe->cont_cls = cont_cls; 453 dqe->cont_cls = cont_cls;
454 dqe->msg = &dqe[1]; 454 dqe->msg = &dqe[1];
455 dqe->msg_size = msg_size; 455 dqe->msg_size = msg_size;
456 dqe->timeout = timeout; 456 dqe->timeout = timeout;
457 memcpy (dqe->msg, msg, msg_size); 457 memcpy (dqe->msg, msg, msg_size);
458 GNUNET_CONTAINER_DLL_insert_tail (generic_dqe_head, generic_dqe_tail, dqe); 458 GNUNET_CONTAINER_DLL_insert_tail (generic_dqe_head, generic_dqe_tail, dqe);
459 if (GNUNET_SCHEDULER_NO_TASK == generic_send_delay_task) 459 if (GNUNET_SCHEDULER_NO_TASK == generic_send_delay_task)
460 { 460 {
461 generic_send_delay_task = GNUNET_SCHEDULER_add_delayed (delay, &send_delayed, dqe); 461 generic_send_delay_task = GNUNET_SCHEDULER_add_delayed (delay, &send_delayed, dqe);
462 } 462 }
463 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, 463 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
464 "Delaying %u byte message to peer `%s' with peer specific delay for %s\n", 464 "Delaying %u byte message to peer `%s' with peer specific delay for %s\n",
465 msg_size, GNUNET_i2s (target), 465 msg_size, GNUNET_i2s (target),
466 GNUNET_STRINGS_relative_time_to_string (delay, GNUNET_YES)); 466 GNUNET_STRINGS_relative_time_to_string (delay, GNUNET_YES));
467 return; 467 return;
468 } 468 }
469 469
470 /* Normal sending */ 470 /* Normal sending */
471 GST_neighbours_send (target, msg, msg_size, timeout, cont, cont_cls); 471 GST_neighbours_send (target, msg, msg_size, timeout, cont, cont_cls);
472} 472}
473 473
474 474