GNUnet  0.11.x
transport-testing-communicator.c
Go to the documentation of this file.
1 /*
2  This file is part of GNUnet.
3  Copyright (C) 2019 GNUnet e.V.
4 
5  GNUnet is free software: you can redistribute it and/or modify it
6  under the terms of the GNU Affero General Public License as published
7  by the Free Software Foundation, either version 3 of the License,
8  or (at your option) any later version.
9 
10  GNUnet is distributed in the hope that it will be useful, but
11  WITHOUT ANY WARRANTY; without even the implied warranty of
12  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
13  Affero General Public License for more details.
14 
15  You should have received a copy of the GNU Affero General Public License
16  along with this program. If not, see <http://www.gnu.org/licenses/>.
17 
18  SPDX-License-Identifier: AGPL3.0-or-later
19  */
20 
27 #include "platform.h"
28 #include "gnunet_util_lib.h"
29 #include "gnunet_protocols.h"
30 #include "gnunet_constants.h"
33 #include "gnunet_hello_lib.h"
34 #include "gnunet_signatures.h"
35 #include "transport.h"
36 #include <inttypes.h>
37 
38 #define LOG(kind, ...) GNUNET_log_from (kind, "transport-testing2", __VA_ARGS__)
39 
40 struct MyClient
41 {
42  struct MyClient *prev;
43  struct MyClient *next;
48 
53 
58 
59 };
60 
65 {
70 
79 
84 
88  uint32_t qid;
89 
93  uint64_t mid;
94 
98  uint32_t nt;
99 
103  uint32_t mtu;
104 
108  uint64_t q_len;
109 
113  uint32_t priority;
114 
118  uint32_t cs;
119 
124 
129 };
130 
131 
136 {
137 };
138 
139 
149 static int
151  void *cls,
152  const struct GNUNET_TRANSPORT_CommunicatorAvailableMessage *msg)
153 {
154  uint16_t size;
155 
156  size = ntohs (msg->header.size) - sizeof(*msg);
157  if (0 == size)
158  return GNUNET_OK; /* receive-only communicator */
160  return GNUNET_OK;
161 }
162 
163 
172 static void
174  void *cls,
175  const struct GNUNET_TRANSPORT_CommunicatorAvailableMessage *msg)
176 {
177  struct MyClient *client = cls;
179  client->tc;
180  uint16_t size;
181  tc_h->c_mq = client->c_mq;
182 
183  size = ntohs (msg->header.size) - sizeof(*msg);
184  if (0 == size)
185  {
187  return; /* receive-only communicator */
188  }
189  tc_h->c_characteristics = ntohl (msg->cc);
190  tc_h->c_addr_prefix = GNUNET_strdup ((const char *) &msg[1]);
191  if (NULL != tc_h->communicator_available_cb)
192  {
193  LOG (GNUNET_ERROR_TYPE_DEBUG, "calling communicator_available_cb()\n");
194  tc_h->communicator_available_cb (tc_h->cb_cls,
195  tc_h,
196  tc_h->c_characteristics,
197  tc_h->c_addr_prefix);
198  }
200  LOG (GNUNET_ERROR_TYPE_DEBUG, "finished communicator_available_cb()\n");
201 
202 }
203 
204 
212 static int
214  const struct
215  GNUNET_TRANSPORT_CommunicatorBackchannel *msg)
216 {
217  // struct TransportClient *tc = cls;
218 
219  // if (CT_COMMUNICATOR != tc->type)
220  // {
221  // GNUNET_break (0);
222  // return GNUNET_SYSERR;
223  // }
224  // GNUNET_MQ_check_boxed_message (msg);
225  return GNUNET_OK;
226 }
227 
228 
237 static void
239  const struct
240  GNUNET_TRANSPORT_CommunicatorBackchannel *
241  bc_msg)
242 {
243  struct MyClient *client = cls;
245  client->tc;
247  struct GNUNET_MessageHeader *msg;
248  msg = (struct GNUNET_MessageHeader *) &bc_msg[1];
249  uint16_t isize = ntohs (msg->size);
250  const char *target_communicator = ((const char *) msg) + isize;
251  struct GNUNET_TRANSPORT_CommunicatorBackchannelIncoming *cbi;
252  struct GNUNET_MQ_Envelope *env;
253 
255  "Received backchannel message\n");
256  if (tc_h->bc_enabled != GNUNET_YES)
257  {
259  return;
260  }
261  /* Find client providing this communicator */
262  /* Finally, deliver backchannel message to communicator */
264  "Delivering backchannel message of type %u to %s\n",
265  ntohs (msg->type),
266  target_communicator);
267  other_tc_h = tc_h->bc_cb (tc_h, msg, (struct
268  GNUNET_PeerIdentity*) &bc_msg->pid);
270  cbi,
271  isize,
273  cbi->pid = tc_h->peer_id;
274  memcpy (&cbi[1], msg, isize);
275 
276 
277  GNUNET_MQ_send (other_tc_h->c_mq, env);
279 }
280 
281 
289 static int
290 check_add_address (void *cls,
291  const struct GNUNET_TRANSPORT_AddAddressMessage *msg)
292 {
293  // if (CT_COMMUNICATOR != tc->type)
294  // {
295  // GNUNET_break (0);
296  // return GNUNET_SYSERR;
297  // }
299  return GNUNET_OK;
300 }
301 
302 
311 static void
313  const struct GNUNET_TRANSPORT_AddAddressMessage *msg)
314 {
315  struct MyClient *client = cls;
317  client->tc;
318  uint16_t size;
319  size = ntohs (msg->header.size) - sizeof(*msg);
320  LOG (GNUNET_ERROR_TYPE_DEBUG, "received add address cb %u\n", size);
321  if (0 == size)
322  return; /* receive-only communicator */
323  LOG (GNUNET_ERROR_TYPE_DEBUG, "received add address cb %u\n", size);
324  tc_h->c_address = GNUNET_strdup ((const char *) &msg[1]);
325  if (NULL != tc_h->add_address_cb)
326  {
327  LOG (GNUNET_ERROR_TYPE_DEBUG, "calling add_address_cb()\n");
328  tc_h->add_address_cb (tc_h->cb_cls,
329  tc_h,
330  tc_h->c_address,
331  GNUNET_TIME_relative_ntoh (msg->expiration),
332  msg->aid,
333  ntohl (msg->nt));
334  }
336 }
337 
338 
346 static int
348  const struct GNUNET_TRANSPORT_IncomingMessage *msg)
349 {
350  // struct TransportClient *tc = cls;
351 
352  // if (CT_COMMUNICATOR != tc->type)
353  // {
354  // GNUNET_break (0);
355  // return GNUNET_SYSERR;
356  // }
358  return GNUNET_OK;
359 }
360 
361 
370 static void
372  const struct GNUNET_TRANSPORT_IncomingMessage *inc_msg)
373 {
374  struct MyClient *client = cls;
376  client->tc;
377  struct GNUNET_MessageHeader *msg;
378  msg = (struct GNUNET_MessageHeader *) &inc_msg[1];
379  size_t payload_len = ntohs (msg->size) - sizeof (struct
381  if (NULL != tc_h->incoming_msg_cb)
382  {
383  tc_h->incoming_msg_cb (tc_h->cb_cls,
384  tc_h,
385  (char*) &msg[1],
386  payload_len);
387  }
388  else
389  {
391  "Incoming message from communicator but no handler!\n");
392  }
393  if (GNUNET_YES == ntohl (inc_msg->fc_on))
394  {
395  /* send ACK when done to communicator for flow control! */
396  struct GNUNET_MQ_Envelope *env;
397  struct GNUNET_TRANSPORT_IncomingMessageAck *ack;
398 
400  GNUNET_assert (NULL != env);
401  ack->reserved = htonl (0);
402  ack->fc_id = inc_msg->fc_id;
403  ack->sender = inc_msg->sender;
404  GNUNET_MQ_send (tc_h->c_mq, env);
405  }
406 
408 }
409 
410 
417 static void
419  const struct GNUNET_TRANSPORT_CreateQueueResponse *msg)
420 {
421  struct MyClient *client = cls;
423  client->tc;
424 
425  if (NULL != tc_h->queue_create_reply_cb)
426  {
427  tc_h->queue_create_reply_cb (tc_h->cb_cls, tc_h, GNUNET_YES);
428  }
430 }
431 
432 
442 static void
444  void *cls,
445  const struct GNUNET_TRANSPORT_CreateQueueResponse *msg)
446 {
447  struct MyClient *client = cls;
449  client->tc;
450 
451  if (NULL != tc_h->queue_create_reply_cb)
452  {
453  tc_h->queue_create_reply_cb (tc_h->cb_cls, tc_h, GNUNET_NO);
454  }
456 }
457 
458 
465 static int
467  const struct GNUNET_TRANSPORT_AddQueueMessage *aqm)
468 {
470  return GNUNET_OK;
471 }
472 
473 
482 static void
484  const struct GNUNET_TRANSPORT_AddQueueMessage *msg)
485 {
486  struct MyClient *client = cls;
488  client->tc;
490 
492  "Got queue with ID %u\n", msg->qid);
493  for (tc_queue = tc_h->queue_head; NULL != tc_queue; tc_queue = tc_queue->next)
494  {
495  if (tc_queue->qid == msg->qid)
496  break;
497  }
498  if (NULL == tc_queue)
499  {
500  tc_queue =
502  tc_queue->tc_h = tc_h;
503  tc_queue->qid = msg->qid;
504  tc_queue->peer_id = msg->receiver;
506  }
507  GNUNET_assert (tc_queue->qid == msg->qid);
508  GNUNET_assert (0 == GNUNET_memcmp (&tc_queue->peer_id, &msg->receiver));
509  tc_queue->nt = msg->nt;
510  tc_queue->mtu = ntohl (msg->mtu);
511  tc_queue->cs = msg->cs;
512  tc_queue->priority = ntohl (msg->priority);
513  tc_queue->q_len = GNUNET_ntohll (msg->q_len);
514  if (NULL != tc_h->add_queue_cb)
515  {
516  tc_h->add_queue_cb (tc_h->cb_cls, tc_h, tc_queue, tc_queue->mtu);
517  }
519 }
520 
521 
530 static void
532  const struct
533  GNUNET_TRANSPORT_UpdateQueueMessage *msg)
534 {
535  struct MyClient *client = cls;
537  client->tc;
539 
541  "Received queue update message for %u with q_len %" PRIu64 "\n",
542  msg->qid, GNUNET_ntohll (msg->q_len));
543  tc_queue = tc_h->queue_head;
544  if (NULL != tc_queue)
545  {
546  while (tc_queue->qid != msg->qid)
547  {
548  tc_queue = tc_queue->next;
549  }
550  }
551  if (NULL == tc_queue)
552  {
554  return;
555  }
556  GNUNET_assert (tc_queue->qid == msg->qid);
557  GNUNET_assert (0 == GNUNET_memcmp (&tc_queue->peer_id, &msg->receiver));
558  tc_queue->nt = msg->nt;
559  tc_queue->mtu = ntohl (msg->mtu);
560  tc_queue->cs = msg->cs;
561  tc_queue->priority = ntohl (msg->priority);
562  // Uncomment this for alternativ 1 of backchannel functionality
563  tc_queue->q_len += GNUNET_ntohll (msg->q_len);
564  // Until here for alternativ 1
565  // Uncomment this for alternativ 2 of backchannel functionality
566  // tc_queue->q_len = GNUNET_ntohll (msg->q_len);
567  // Until here for alternativ 2
569 }
570 
571 
577 static void
578 shutdown_service (void *cls)
579 {
580  struct GNUNET_SERVICE_Handle *h = cls;
581 
583  "Shutting down service!\n");
584 
586 }
587 
588 
598 static void *
599 connect_cb (void *cls,
600  struct GNUNET_SERVICE_Client *client,
601  struct GNUNET_MQ_Handle *mq)
602 {
604  struct MyClient *new_c;
605 
606  LOG (GNUNET_ERROR_TYPE_DEBUG, "Client %p connected to %p.\n",
607  client, tc_h);
608  new_c = GNUNET_new (struct MyClient);
609  new_c->client = client;
610  new_c->c_mq = mq;
611  new_c->tc = tc_h;
613  tc_h->client_tail,
614  new_c);
615 
616  if (NULL == tc_h->queue_head)
617  return new_c;
618  /* Iterate over queues. They are yet to be opened. Request opening. */
619  for (struct
621  tc_h->queue_head;
622  NULL != tc_queue_iter;
623  tc_queue_iter = tc_queue_iter->next)
624  {
625  if (NULL == tc_queue_iter->open_queue_env)
626  continue;
627  /* Send the previously created mq envelope to request the creation of the
628  * queue. */
629  GNUNET_MQ_send (tc_h->c_mq,
630  tc_queue_iter->open_queue_env);
631  tc_queue_iter->open_queue_env = NULL;
632  }
633  return new_c;
634 }
635 
636 
644 static void
645 disconnect_cb (void *cls,
647  void *internal_cls)
648 {
649  struct MyClient *cl = cls;
651 
652  for (cl = tc_h->client_head; NULL != cl; cl = cl->next)
653  {
654  if (cl->client != client)
655  continue;
657  tc_h->client_tail,
658  cl);
659  if (cl->c_mq == tc_h->c_mq)
660  tc_h->c_mq = NULL;
661  GNUNET_free (cl);
662  break;
663  }
664  LOG (GNUNET_ERROR_TYPE_DEBUG, "Client disconnected.\n");
665 }
666 
667 
674 static void
676  const struct GNUNET_TRANSPORT_SendMessageToAck *sma)
677 {
678  struct MyClient *client = cls;
680  // NOP
681 }
682 
683 
691 static void
694 {
695  struct GNUNET_MQ_MessageHandler mh[] = {
696  GNUNET_MQ_hd_var_size (communicator_available,
698  struct GNUNET_TRANSPORT_CommunicatorAvailableMessage,
699  tc_h),
700  GNUNET_MQ_hd_var_size (communicator_backchannel,
702  struct GNUNET_TRANSPORT_CommunicatorBackchannel,
703  tc_h),
704  GNUNET_MQ_hd_var_size (add_address,
706  struct GNUNET_TRANSPORT_AddAddressMessage,
707  tc_h),
708  // GNUNET_MQ_hd_fixed_size (del_address,
709  // GNUNET_MESSAGE_TYPE_TRANSPORT_DEL_ADDRESS,
710  // struct GNUNET_TRANSPORT_DelAddressMessage,
711  // NULL),
712  GNUNET_MQ_hd_var_size (incoming_msg,
714  struct GNUNET_TRANSPORT_IncomingMessage,
715  tc_h),
716  GNUNET_MQ_hd_fixed_size (queue_create_ok,
718  struct GNUNET_TRANSPORT_CreateQueueResponse,
719  tc_h),
720  GNUNET_MQ_hd_fixed_size (queue_create_fail,
722  struct GNUNET_TRANSPORT_CreateQueueResponse,
723  tc_h),
724  GNUNET_MQ_hd_var_size (add_queue_message,
726  struct GNUNET_TRANSPORT_AddQueueMessage,
727  tc_h),
728  GNUNET_MQ_hd_fixed_size (update_queue_message,
730  struct GNUNET_TRANSPORT_UpdateQueueMessage,
731  tc_h),
732  // GNUNET_MQ_hd_fixed_size (del_queue_message,
733  // GNUNET_MESSAGE_TYPE_TRANSPORT_QUEUE_TEARDOWN,
734  // struct GNUNET_TRANSPORT_DelQueueMessage,
735  // NULL),
736  GNUNET_MQ_hd_fixed_size (send_message_ack,
738  struct GNUNET_TRANSPORT_SendMessageToAck,
739  tc_h),
741  };
742 
743 
744  tc_h->sh = GNUNET_SERVICE_start ("transport",
745  tc_h->cfg,
746  &connect_cb,
747  &disconnect_cb,
748  tc_h,
749  mh);
750  GNUNET_assert (NULL != tc_h->sh);
751 }
752 
753 
759 static void
761 {
762  if (0 != GNUNET_OS_process_kill (proc, SIGTERM))
763  {
765  "Error shutting down process with SIGERM, trying SIGKILL\n");
766  if (0 != GNUNET_OS_process_kill (proc, SIGKILL))
767  {
769  "Error shutting down process with SIGERM and SIGKILL\n");
770  }
771  }
773 }
774 
780 static void
782 {
783  struct GNUNET_OS_Process *proc = cls;
784  shutdown_process (proc);
785 }
786 
792 static void
794 {
795  struct GNUNET_OS_Process *proc = cls;
796  shutdown_process (proc);
797 }
798 
804 static void
806 {
807  struct GNUNET_OS_Process *proc = cls;
808  shutdown_process (proc);
809 }
810 
811 
817 static void
820  const char *binary_name)
821 {
822  char *binary;
823  char *loprefix;
824  char *section_name;
825 
826  LOG (GNUNET_ERROR_TYPE_DEBUG, "communicator_start\n");
827 
828  section_name = strchr (binary_name, '-');
829  section_name++;
830 
832  section_name,
833  "PREFIX",
834  &loprefix))
835  loprefix = GNUNET_strdup ("");
836 
837 
838  binary = GNUNET_OS_get_libexec_binary_path (binary_name);
840  NULL,
841  loprefix,
842  binary,
843  binary_name,
844  "-c",
845  tc_h->cfg_filename,
846  NULL);
847  if (NULL == tc_h->c_proc)
848  {
849  GNUNET_log (GNUNET_ERROR_TYPE_ERROR, "Failed to start communicator!");
850  return;
851  }
852  LOG (GNUNET_ERROR_TYPE_INFO, "started communicator\n");
853  GNUNET_free (binary);
854 }
855 
856 
862 static void
863 shutdown_nat (void *cls)
864 {
865  struct GNUNET_OS_Process *proc = cls;
866  shutdown_process (proc);
867 }
868 
869 
875 static void
876 shutdown_resolver (void *cls)
877 {
878  struct GNUNET_OS_Process *proc = cls;
879  shutdown_process (proc);
880 }
881 
882 
887 static void
890 {
891  char *binary;
892 
893  LOG (GNUNET_ERROR_TYPE_DEBUG, "resolver_start\n");
894  binary = GNUNET_OS_get_libexec_binary_path ("gnunet-service-resolver");
898  NULL,
899  NULL,
900  NULL,
901  binary,
902  "gnunet-service-resolver",
903  "-c",
904  tc_h->cfg_filename,
905  NULL);
906  if (NULL == tc_h->resolver_proc)
907  {
908  GNUNET_log (GNUNET_ERROR_TYPE_ERROR, "Failed to start resolver service!");
909  return;
910  }
911  LOG (GNUNET_ERROR_TYPE_INFO, "started resolver service\n");
912  GNUNET_free (binary);
913 
914 }
915 
920 static void
923 {
924  char *binary;
925 
926  binary = GNUNET_OS_get_libexec_binary_path ("gnunet-service-statistics");
928  NULL,
929  NULL,
930  NULL,
931  binary,
932  "gnunet-service-statistics",
933  "-c",
934  tc_h->cfg_filename,
935  NULL);
936  if (NULL == tc_h->stat_proc)
937  {
938  GNUNET_log (GNUNET_ERROR_TYPE_ERROR, "Failed to start Statistics!");
939  return;
940  }
941  LOG (GNUNET_ERROR_TYPE_INFO, "started Statistics\n");
942  GNUNET_free (binary);
943 }
944 
949 static void
952 {
953  char *binary;
954 
955  binary = GNUNET_OS_get_libexec_binary_path ("gnunet-service-peerstore");
957  NULL,
958  NULL,
959  NULL,
960  binary,
961  "gnunet-service-peerstore",
962  "-c",
963  tc_h->cfg_filename,
964  NULL);
965  if (NULL == tc_h->ps_proc)
966  {
967  GNUNET_log (GNUNET_ERROR_TYPE_ERROR, "Failed to start Peerstore!");
968  return;
969  }
970  LOG (GNUNET_ERROR_TYPE_INFO, "started Peerstore\n");
971  GNUNET_free (binary);
972 }
973 
978 static void
981 {
982  char *binary;
983 
984  LOG (GNUNET_ERROR_TYPE_DEBUG, "nat_start\n");
985  binary = GNUNET_OS_get_libexec_binary_path ("gnunet-service-nat");
988  NULL,
989  NULL,
990  NULL,
991  binary,
992  "gnunet-service-nat",
993  "-c",
994  tc_h->cfg_filename,
995  NULL);
996  if (NULL == tc_h->nat_proc)
997  {
998  GNUNET_log (GNUNET_ERROR_TYPE_ERROR, "Failed to start NAT!");
999  return;
1000  }
1001  LOG (GNUNET_ERROR_TYPE_INFO, "started NAT\n");
1002  GNUNET_free (binary);
1003 }
1004 
1005 
1020  const char *service_name,
1021  const char *binary_name,
1022  const char *cfg_filename,
1023  const struct GNUNET_PeerIdentity *peer_id,
1031  void *cb_cls)
1032 {
1034 
1036  "Starting new transport/communicator combo with config %s\n",
1037  cfg_filename);
1038  tc_h =
1041  tc_h->cfg = GNUNET_CONFIGURATION_create ();
1043  {
1045  _ ("Malformed configuration file `%s', exit ...\n"),
1046  cfg_filename);
1047  GNUNET_free (tc_h->cfg_filename);
1049  GNUNET_free (tc_h);
1050  return NULL;
1051  }
1053  "communicator-test",
1054  "BACKCHANNEL_ENABLED");
1058  tc_h->add_queue_cb = add_queue_cb;
1059  tc_h->incoming_msg_cb = incoming_message_cb;
1060  tc_h->bc_cb = bc_cb;
1061  tc_h->peer_id = *peer_id;
1062  tc_h->cb_cls = cb_cls;
1063 
1064  /* Start communicator part of service */
1066  /* Start NAT */
1067  nat_start (tc_h);
1068  /* Start resolver service */
1069  resolver_start (tc_h);
1070  /* Start peerstore service */
1071  peerstore_start (tc_h);
1072  /* Start statistic service */
1073  statistics_start (tc_h);
1074  /* Schedule start communicator */
1075  communicator_start (tc_h,
1076  binary_name);
1077  return tc_h;
1078 }
1079 
1080 
1081 void
1084 {
1085  shutdown_communicator (tc_h->c_proc);
1086  shutdown_service (tc_h->sh);
1087  shutdown_nat (tc_h->nat_proc);
1089  shutdown_peerstore (tc_h->ps_proc);
1092  GNUNET_free (tc_h);
1093 }
1094 
1095 
1103 void
1106  const struct GNUNET_PeerIdentity *peer_id,
1107  const char *address)
1108 {
1110  static uint32_t idgen;
1111  char *prefix;
1112  struct GNUNET_TRANSPORT_CreateQueue *msg;
1113  struct GNUNET_MQ_Envelope *env;
1114  size_t alen;
1115 
1116  tc_queue =
1118  tc_queue->tc_h = tc_h;
1120  if (NULL == prefix)
1121  {
1122  GNUNET_break (0); /* We got an invalid address!? */
1123  GNUNET_free (tc_queue);
1124  return;
1125  }
1126  GNUNET_free (prefix);
1127  alen = strlen (address) + 1;
1128  env =
1130  msg->request_id = htonl (idgen++);
1131  tc_queue->qid = msg->request_id;
1132  msg->receiver = *peer_id;
1133  tc_queue->peer_id = *peer_id;
1134  memcpy (&msg[1], address, alen);
1135  if (NULL != tc_h->c_mq)
1136  {
1138  "Sending queue create immediately\n");
1139  GNUNET_MQ_send (tc_h->c_mq, env);
1140  }
1141  else
1142  {
1143  tc_queue->open_queue_env = env;
1144  }
1145  GNUNET_CONTAINER_DLL_insert (tc_h->queue_head, tc_h->queue_tail, tc_queue);
1146 }
1147 
1148 
1158 void
1162  void *cont_cls,
1163  const void *payload,
1164  size_t payload_size)
1165 {
1166  struct GNUNET_MessageHeader *mh;
1167  struct GNUNET_TRANSPORT_SendMessageTo *msg;
1168  struct GNUNET_MQ_Envelope *env;
1169  size_t inbox_size;
1172 
1173  tc_queue = NULL;
1174  for (tc_queue_tmp = tc_h->queue_head;
1175  NULL != tc_queue_tmp;
1176  tc_queue_tmp = tc_queue_tmp->next)
1177  {
1178  if (tc_queue_tmp->q_len <= 0)
1179  continue;
1180  if (NULL == tc_queue)
1181  {
1183  "Selecting queue with prio %u, len %" PRIu64 " and MTU %u\n",
1184  tc_queue_tmp->priority,
1185  tc_queue_tmp->q_len,
1186  tc_queue_tmp->mtu);
1187  tc_queue = tc_queue_tmp;
1188  continue;
1189  }
1190  if (tc_queue->priority < tc_queue_tmp->priority)
1191  {
1193  "Selecting queue with prio %u, len %" PRIu64 " and MTU %u\n",
1194  tc_queue_tmp->priority,
1195  tc_queue_tmp->q_len,
1196  tc_queue_tmp->mtu);
1197  tc_queue = tc_queue_tmp;
1198  }
1199  }
1200  GNUNET_assert (NULL != tc_queue);
1201  // Uncomment this for alternativ 1 of backchannel functionality
1203  tc_queue->q_len--;
1204  // Until here for alternativ 1
1206  "Sending message\n");
1207  inbox_size = sizeof (struct GNUNET_MessageHeader) + payload_size;
1209  inbox_size,
1211  GNUNET_assert (NULL != env);
1212  msg->qid = htonl (tc_queue->qid);
1213  msg->mid = tc_queue->mid++;
1214  msg->receiver = tc_queue->peer_id;
1215  mh = (struct GNUNET_MessageHeader *) &msg[1];
1216  mh->size = htons (inbox_size);
1217  mh->type = GNUNET_MESSAGE_TYPE_DUMMY;
1218  memcpy (&mh[1],
1219  payload,
1220  payload_size);
1221  if (NULL != cont)
1223  cont,
1224  cont_cls);
1225  GNUNET_MQ_send (tc_queue->tc_h->c_mq,
1226  env);
1227 }
struct GNUNET_MQ_Handle * mq
Definition: 003.c:5
struct GNUNET_MessageHeader * msg
Definition: 005.c:2
struct GNUNET_MQ_Envelope * env
Definition: 005.c:1
static struct GNUNET_ARM_Handle * h
Connection with ARM.
Definition: gnunet-arm.c:99
static char * cfg_filename
Name of the configuration file.
static char * peer_id
Option –peer.
Definition: gnunet-cadet.c:42
static struct GNUNET_CADET_Handle * mh
Cadet handle.
Definition: gnunet-cadet.c:92
static int prefix
If printing the value of PREFIX has been requested.
Definition: gnunet-config.c:53
static char * address
GNS address for this phone.
static char * section_name
Name of section in configuration file to use for additional options.
Definition: gnunet-nat.c:40
static unsigned long long payload
How much data are we currently storing in the database?
static char * service_name
Option -s: service name (hash to get service descriptor)
Definition: gnunet-vpn.c:51
Bandwidth allocation API for the transport service.
#define GNUNET_log(kind,...)
uint64_t GNUNET_ntohll(uint64_t n)
Convert unsigned 64-bit integer to host byte order.
Definition: common_endian.c:53
#define GNUNET_memcmp(a, b)
Compare memory in a and b, where both must be of the same pointer type.
@ GNUNET_OK
Definition: gnunet_common.h:95
@ GNUNET_YES
Definition: gnunet_common.h:97
@ GNUNET_NO
Definition: gnunet_common.h:94
@ GNUNET_SYSERR
Definition: gnunet_common.h:93
struct GNUNET_CONFIGURATION_Handle * GNUNET_CONFIGURATION_create(void)
Create a new configuration object.
void GNUNET_CONFIGURATION_destroy(struct GNUNET_CONFIGURATION_Handle *cfg)
Destroy configuration object.
enum GNUNET_GenericReturnValue GNUNET_CONFIGURATION_get_value_yesno(const struct GNUNET_CONFIGURATION_Handle *cfg, const char *section, const char *option)
Get a configuration value that should be in a set of "YES" or "NO".
enum GNUNET_GenericReturnValue GNUNET_CONFIGURATION_get_value_string(const struct GNUNET_CONFIGURATION_Handle *cfg, const char *section, const char *option, char **value)
Get a configuration value that should be a string.
enum GNUNET_GenericReturnValue GNUNET_CONFIGURATION_load(struct GNUNET_CONFIGURATION_Handle *cfg, const char *filename)
Load configuration.
#define GNUNET_CONTAINER_DLL_remove(head, tail, element)
Remove an element from a DLL.
#define GNUNET_CONTAINER_DLL_insert(head, tail, element)
Insert an element at the head of a DLL.
char * GNUNET_HELLO_address_to_prefix(const char *address)
Given an address as a string, extract the prefix that identifies the communicator offering transmissi...
Definition: hello-ng.c:189
#define GNUNET_assert(cond)
Use this for fatal errors that cannot be handled.
#define GNUNET_break(cond)
Use this for internal assertion violations that are not fatal (can be handled) but should not occur.
@ GNUNET_ERROR_TYPE_WARNING
@ GNUNET_ERROR_TYPE_ERROR
@ GNUNET_ERROR_TYPE_DEBUG
@ GNUNET_ERROR_TYPE_INFO
#define GNUNET_strdup(a)
Wrapper around GNUNET_xstrdup_.
#define GNUNET_new(type)
Allocate a struct or union of the given type.
#define GNUNET_free(ptr)
Wrapper around free.
void GNUNET_MQ_send(struct GNUNET_MQ_Handle *mq, struct GNUNET_MQ_Envelope *ev)
Send a message with the given message queue.
Definition: mq.c:355
#define GNUNET_MQ_handler_end()
End-marker for the handlers array.
#define GNUNET_MQ_check_zero_termination(m)
Insert code for a "check_" function that verifies that a given variable-length message received over ...
void * cls
Closure for mv and cb.
#define GNUNET_MQ_msg_extra(mvar, esize, type)
Allocate an envelope, with extra space allocated after the space needed by the message struct.
Definition: gnunet_mq_lib.h:52
#define GNUNET_MQ_check_boxed_message(m)
Insert code for a "check_" function that verifies that a given variable-length message received over ...
#define GNUNET_MQ_msg(mvar, type)
Allocate a GNUNET_MQ_Envelope.
Definition: gnunet_mq_lib.h:67
#define GNUNET_MQ_hd_var_size(name, code, str, ctx)
void GNUNET_MQ_notify_sent(struct GNUNET_MQ_Envelope *ev, GNUNET_SCHEDULER_TaskCallback cb, void *cb_cls)
Call a callback once the envelope has been sent, that is, sending it can not be canceled anymore.
Definition: mq.c:787
#define GNUNET_MQ_hd_fixed_size(name, code, str, ctx)
char * GNUNET_OS_get_libexec_binary_path(const char *progname)
Given the name of a gnunet-helper, gnunet-service or gnunet-daemon binary, try to prefix it with the ...
struct GNUNET_OS_Process * GNUNET_OS_start_process(enum GNUNET_OS_InheritStdioFlags std_inheritance, struct GNUNET_DISK_PipeHandle *pipe_stdin, struct GNUNET_DISK_PipeHandle *pipe_stdout, struct GNUNET_DISK_PipeHandle *pipe_stderr, const char *filename,...)
Start a process.
Definition: os_priority.c:678
struct GNUNET_OS_Process * GNUNET_OS_start_process_s(enum GNUNET_OS_InheritStdioFlags std_inheritance, const int *lsocks, const char *filename,...)
Start a process.
Definition: os_priority.c:747
void GNUNET_OS_process_destroy(struct GNUNET_OS_Process *proc)
Cleans up process structure contents (OS-dependent) and deallocates it.
Definition: os_priority.c:286
int GNUNET_OS_process_kill(struct GNUNET_OS_Process *proc, int sig)
Sends a signal to the process.
Definition: os_priority.c:224
@ GNUNET_OS_INHERIT_STD_OUT_AND_ERR
When these flags are set, the child process will inherit stdout and stderr of the parent.
Definition: gnunet_os_lib.h:97
@ GNUNET_OS_USE_PIPE_CONTROL
Should a pipe be used to send signals to the child?
#define GNUNET_MESSAGE_TYPE_TRANSPORT_INCOMING_MSG_ACK
transport acknowledges processing an incoming message
#define GNUNET_MESSAGE_TYPE_DUMMY
Dummy messages for testing / benchmarking.
#define GNUNET_MESSAGE_TYPE_TRANSPORT_NEW_COMMUNICATOR
Message sent to indicate to the transport which address prefix is supported by a communicator.
#define GNUNET_MESSAGE_TYPE_TRANSPORT_QUEUE_CREATE_FAIL
Response from communicator: address bogus, will not try to create queue.
#define GNUNET_MESSAGE_TYPE_TRANSPORT_QUEUE_CREATE
transport tells communicator it wants a queue
#define GNUNET_MESSAGE_TYPE_TRANSPORT_COMMUNICATOR_BACKCHANNEL
Tell transport that it should assist with exchanging a message between communicators.
#define GNUNET_MESSAGE_TYPE_TRANSPORT_INCOMING_MSG
inform transport about an incoming message
#define GNUNET_MESSAGE_TYPE_TRANSPORT_QUEUE_CREATE_OK
Response from communicator: will try to create queue.
#define GNUNET_MESSAGE_TYPE_TRANSPORT_COMMUNICATOR_BACKCHANNEL_INCOMING
Transport signalling incoming backchannel message to a communicator.
#define GNUNET_MESSAGE_TYPE_TRANSPORT_SEND_MSG_ACK
communicator tells transports that message was sent
#define GNUNET_MESSAGE_TYPE_TRANSPORT_ADD_ADDRESS
inform transport to add an address of this peer
#define GNUNET_MESSAGE_TYPE_TRANSPORT_SEND_MSG
transport tells communicator it wants to transmit
#define GNUNET_MESSAGE_TYPE_TRANSPORT_QUEUE_SETUP
inform transport that a queue was setup to talk to some peer
#define GNUNET_MESSAGE_TYPE_TRANSPORT_QUEUE_UPDATE
inform transport that a queue was updated
void(* GNUNET_SCHEDULER_TaskCallback)(void *cls)
Signature of the main function of a task.
void GNUNET_SERVICE_stop(struct GNUNET_SERVICE_Handle *srv)
Stops a service that was started with GNUNET_SERVICE_start().
Definition: service.c:1908
struct GNUNET_SERVICE_Handle * GNUNET_SERVICE_start(const char *service_name, const struct GNUNET_CONFIGURATION_Handle *cfg, GNUNET_SERVICE_ConnectHandler connect_cb, GNUNET_SERVICE_DisconnectHandler disconnect_cb, void *cls, const struct GNUNET_MQ_MessageHandler *handlers)
Low-level function to start a service if the scheduler is already running.
Definition: service.c:1875
void GNUNET_SERVICE_client_continue(struct GNUNET_SERVICE_Client *c)
Continue receiving further messages from the given client.
Definition: service.c:2244
struct GNUNET_TIME_Relative GNUNET_TIME_relative_ntoh(struct GNUNET_TIME_RelativeNBO a)
Convert relative time from network byte order.
Definition: time.c:454
#define GNUNET_TRANSPORT_QUEUE_LENGTH_UNLIMITED
Queue length.
static unsigned int size
Size of the "table".
Definition: peer.c:67
#define _(String)
GNU gettext support macro.
Definition: platform.h:177
Handle to a message queue.
Definition: mq.c:86
Message handler for a specific message type.
Header for all communications.
uint16_t type
The type of the message (GNUNET_MESSAGE_TYPE_XXXX), in big-endian format.
uint16_t size
The length of the struct (in bytes, including the length field itself), in big-endian format.
The identity of the host (wraps the signing key of the peer).
Handle to a client that is connected to a service.
Definition: service.c:251
Handle to a service.
Definition: service.c:117
struct GNUNET_TRANSPORT_TESTING_TransportCommunicatorQueue * queue_head
Head of the DLL of queues associated with this communicator.
struct GNUNET_TRANSPORT_TESTING_TransportCommunicatorQueue * queue_tail
Tail of the DLL of queues associated with this communicator.
struct GNUNET_SERVICE_Handle * sh
Our service handle.
struct GNUNET_OS_Process * stat_proc
statistics service process
GNUNET_TRANSPORT_TESTING_BackchannelCallback bc_cb
Backchannel callback.
GNUNET_TRANSPORT_TESTING_QueueCreateReplyCallback queue_create_reply_cb
Callback called when a new communicator connects.
struct GNUNET_MQ_Handle * c_mq
Handle to the client.
GNUNET_TRANSPORT_TESTING_AddAddressCallback add_address_cb
Callback called when a new communicator connects.
struct GNUNET_CONFIGURATION_Handle * cfg
Handle to the configuration.
struct GNUNET_OS_Process * resolver_proc
resolver service process
struct GNUNET_OS_Process * ps_proc
peerstore service process
struct GNUNET_OS_Process * c_proc
Process of the communicator.
GNUNET_TRANSPORT_TESTING_CommunicatorAvailableCallback communicator_available_cb
Callback called when a new communicator connects.
GNUNET_TRANSPORT_TESTING_AddQueueCallback add_queue_cb
Callback called when a new communicator connects.
enum GNUNET_TRANSPORT_CommunicatorCharacteristics c_characteristics
Characteristics of the communicator.
GNUNET_TRANSPORT_TESTING_IncomingMessageCallback incoming_msg_cb
Callback called when a new communicator connects.
uint32_t cs
An enum GNUNET_TRANSPORT_ConnectionStatus in NBO.
struct GNUNET_TRANSPORT_TESTING_TransportCommunicatorQueue * prev
Previous element inside a DLL.
struct GNUNET_TRANSPORT_TESTING_TransportCommunicatorQueue * next
Next element inside a DLL.
struct GNUNET_MQ_Envelope * open_queue_env
Envelope to a message that requests the opening of the queue.
struct GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle * tc_h
Handle to the TransportCommunicator.
struct GNUNET_PeerIdentity peer_id
Peer ID of the peer on the other side of the queue.
struct GNUNET_SERVICE_Client * client
Handle to the client.
struct GNUNET_MQ_Handle * c_mq
Handle to the client.
struct GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle * tc
The TCH.
struct MyClient * prev
struct MyClient * next
void GNUNET_TRANSPORT_TESTING_transport_communicator_send(struct GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle *tc_h, GNUNET_SCHEDULER_TaskCallback cont, void *cont_cls, const void *payload, size_t payload_size)
Instruct communicator to send data.
static void shutdown_peerstore(void *cls)
Task run at shutdown to kill the peerstore process.
static void shutdown_communicator(void *cls)
Task run at shutdown to kill a communicator process.
static void nat_start(struct GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle *tc_h)
Start NAT.
static void handle_incoming_msg(void *cls, const struct GNUNET_TRANSPORT_IncomingMessage *inc_msg)
Receive an incoming message.
static void shutdown_statistics(void *cls)
Task run at shutdown to kill the statistics process.
static void resolver_start(struct GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle *tc_h)
Start Resolver.
static int check_add_queue_message(void *cls, const struct GNUNET_TRANSPORT_AddQueueMessage *aqm)
New queue became available.
struct GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle * GNUNET_TRANSPORT_TESTING_transport_communicator_service_start(const char *service_name, const char *binary_name, const char *cfg_filename, const struct GNUNET_PeerIdentity *peer_id, GNUNET_TRANSPORT_TESTING_CommunicatorAvailableCallback communicator_available_cb, GNUNET_TRANSPORT_TESTING_AddAddressCallback add_address_cb, GNUNET_TRANSPORT_TESTING_QueueCreateReplyCallback queue_create_reply_cb, GNUNET_TRANSPORT_TESTING_AddQueueCallback add_queue_cb, GNUNET_TRANSPORT_TESTING_IncomingMessageCallback incoming_message_cb, GNUNET_TRANSPORT_TESTING_BackchannelCallback bc_cb, void *cb_cls)
Start communicator part of transport service and communicator.
static int check_communicator_backchannel(void *cls, const struct GNUNET_TRANSPORT_CommunicatorBackchannel *msg)
Incoming message.
static int check_add_address(void *cls, const struct GNUNET_TRANSPORT_AddAddressMessage *msg)
Address of our peer added.
void GNUNET_TRANSPORT_TESTING_transport_communicator_open_queue(struct GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle *tc_h, const struct GNUNET_PeerIdentity *peer_id, const char *address)
Instruct communicator to open a queue.
static void handle_update_queue_message(void *cls, const struct GNUNET_TRANSPORT_UpdateQueueMessage *msg)
Handle new queue.
static void shutdown_resolver(void *cls)
Task run at shutdown to kill the resolver process.
static void * connect_cb(void *cls, struct GNUNET_SERVICE_Client *client, struct GNUNET_MQ_Handle *mq)
Callback called when new Client (Communicator) connects.
static void handle_queue_create_fail(void *cls, const struct GNUNET_TRANSPORT_CreateQueueResponse *msg)
Communicator informs that it won't try establishing requested queue.
static void handle_queue_create_ok(void *cls, const struct GNUNET_TRANSPORT_CreateQueueResponse *msg)
Communicator informs that it tries to establish requested queue.
static void handle_communicator_backchannel(void *cls, const struct GNUNET_TRANSPORT_CommunicatorBackchannel *bc_msg)
Receive an incoming message.
static void shutdown_nat(void *cls)
Task run at shutdown to kill communicator and clean up.
static void shutdown_service(void *cls)
Shut down the service.
static void disconnect_cb(void *cls, struct GNUNET_SERVICE_Client *client, void *internal_cls)
Callback called when Client disconnects.
static int check_incoming_msg(void *cls, const struct GNUNET_TRANSPORT_IncomingMessage *msg)
Incoming message.
static void handle_send_message_ack(void *cls, const struct GNUNET_TRANSPORT_SendMessageToAck *sma)
Message was transmitted.
static void transport_communicator_start(struct GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle *tc_h)
Start the communicator part of the transport service.
static void handle_add_queue_message(void *cls, const struct GNUNET_TRANSPORT_AddQueueMessage *msg)
Handle new queue.
void GNUNET_TRANSPORT_TESTING_transport_communicator_service_stop(struct GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle *tc_h)
static void statistics_start(struct GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle *tc_h)
Start Statistics.
static void shutdown_process(struct GNUNET_OS_Process *proc)
Task run at shutdown to kill communicator and clean up.
static void communicator_start(struct GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle *tc_h, const char *binary_name)
Start the communicator.
static void peerstore_start(struct GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle *tc_h)
Start Peerstore.
static void handle_add_address(void *cls, const struct GNUNET_TRANSPORT_AddAddressMessage *msg)
The communicator informs about an address.
static int check_communicator_available(void *cls, const struct GNUNET_TRANSPORT_CommunicatorAvailableMessage *msg)
Check whether incoming msg indicating available communicator is correct.
#define LOG(kind,...)
static void handle_communicator_available(void *cls, const struct GNUNET_TRANSPORT_CommunicatorAvailableMessage *msg)
Handle new communicator.
functions and structures related to testing-tng
void(* GNUNET_TRANSPORT_TESTING_IncomingMessageCallback)(void *cls, struct GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle *tc_h, const char *payload, size_t payload_len)
Handle an incoming message.
void(* GNUNET_TRANSPORT_TESTING_AddQueueCallback)(void *cls, struct GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle *tc_h, struct GNUNET_TRANSPORT_TESTING_TransportCommunicatorQueue *tc_queue, size_t mtu)
Handle opening of queue.
void(* GNUNET_TRANSPORT_TESTING_QueueCreateReplyCallback)(void *cls, struct GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle *tc_h, int will_try)
Get informed about the success of a queue request.
struct GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle *(* GNUNET_TRANSPORT_TESTING_BackchannelCallback)(void *cls, struct GNUNET_MessageHeader *msg, struct GNUNET_PeerIdentity *pid)
Function signature for callbacks that are called when new backchannel message arrived.
void(* GNUNET_TRANSPORT_TESTING_AddAddressCallback)(void *cls, struct GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle *tc_h, const char *address, struct GNUNET_TIME_Relative expiration, uint32_t aid, enum GNUNET_NetworkType nt)
Receive information about the address of a communicator.
void(* GNUNET_TRANSPORT_TESTING_CommunicatorAvailableCallback)(void *cls, struct GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle *tc_h, enum GNUNET_TRANSPORT_CommunicatorCharacteristics cc, char *address_prefix)
Function signature for callbacks that are called when new communicators become available.
common internal definitions for transport service