diff options
author | Matthias Wachs <wachs@net.in.tum.de> | 2013-09-16 15:10:51 +0000 |
---|---|---|
committer | Matthias Wachs <wachs@net.in.tum.de> | 2013-09-16 15:10:51 +0000 |
commit | 64bc1ae7763fd4f4e2ad4fb7acb4a1a2292bf988 (patch) | |
tree | e563e1dcbd7c8251438415558bc2869076f77b94 /src/transport/gnunet-service-transport_manipulation.c | |
parent | 75633a91d79403d921ef534bbb462697ce275733 (diff) | |
download | gnunet-64bc1ae7763fd4f4e2ad4fb7acb4a1a2292bf988.tar.gz gnunet-64bc1ae7763fd4f4e2ad4fb7acb4a1a2292bf988.zip |
fixing indent
Diffstat (limited to 'src/transport/gnunet-service-transport_manipulation.c')
-rw-r--r-- | src/transport/gnunet-service-transport_manipulation.c | 120 |
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 | ||