transport-testing-communicator.h

Go to the documentation of this file.

/*
     This file is part of GNUnet.
     Copyright (C) 2019 GNUnet e.V.
 
     GNUnet is free software: you can redistribute it and/or modify it
     under the terms of the GNU Affero General Public License as published
     by the Free Software Foundation, either version 3 of the License,
     or (at your option) any later version.
 
     GNUnet is distributed in the hope that it will be useful, but
     WITHOUT ANY WARRANTY; without even the implied warranty of
     MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
     Affero General Public License for more details.
 
     You should have received a copy of the GNU Affero General Public License
     along with this program.  If not, see <http://www.gnu.org/licenses/>.
 
     SPDX-License-Identifier: AGPL3.0-or-later
 */
 
#include "platform.h"
#include "gnunet_util_lib.h"
#include "gnunet_ats_transport_service.h"
#include "transport.h"
 
struct GNUNET_TRANSPORT_TESTING_TransportCommunicatorQueue;
 
 
struct GNUNET_TRANSPORT_TESTING_TransportCommunicatorTransmission;
 
typedef struct GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle *
(*GNUNET_TRANSPORT_TESTING_BackchannelCallback)(void *cls,
                                                struct GNUNET_MessageHeader *msg,
                                                struct GNUNET_PeerIdentity *pid);
 
 
typedef void
(*GNUNET_TRANSPORT_TESTING_CommunicatorAvailableCallback)(void *cls,
                                                          struct
                                                          GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle
                                                          *tc_h,
                                                          enum
                                                          GNUNET_TRANSPORT_CommunicatorCharacteristics
                                                          cc,
                                                          char *address_prefix);
 
 
typedef 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);
 
 
typedef void
(*GNUNET_TRANSPORT_TESTING_QueueCreateReplyCallback)(void *cls,
                                                     struct
                                                     GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle
                                                     *tc_h,
                                                     int will_try);
 
 
typedef void
(*GNUNET_TRANSPORT_TESTING_AddQueueCallback)(void *cls,
                                             struct
                                             GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle
                                             *tc_h,
                                             struct
                                             GNUNET_TRANSPORT_TESTING_TransportCommunicatorQueue
                                             *tc_queue,
                                             size_t mtu);
 
 
typedef void
(*GNUNET_TRANSPORT_TESTING_IncomingMessageCallback)(void *cls,
                                                    struct
                                                    GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle
                                                    *tc_h,
                                                    const char*payload,
                                                    size_t payload_len);
 
struct GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle
{
  struct MyClient *client_head;
  struct MyClient *client_tail;
 
  struct GNUNET_MQ_Handle *c_mq;
 
  struct GNUNET_CONFIGURATION_Handle *cfg;
 
  char *cfg_filename;
 
  struct GNUNET_PeerIdentity peer_id;
 
  struct GNUNET_SERVICE_Handle *tsh;
 
  struct GNUNET_SCHEDULER_Task *ts_shutdown_task;
 
 
  struct GNUNET_OS_Process *c_proc;
 
  struct GNUNET_OS_Process *nat_proc;
 
  struct GNUNET_OS_Process *resolver_proc;
 
  struct GNUNET_OS_Process *stat_proc;
 
  struct GNUNET_OS_Process *ps_proc;
 
  struct GNUNET_SCHEDULER_Task *c_shutdown_task;
 
  enum GNUNET_TRANSPORT_CommunicatorCharacteristics c_characteristics;
 
  char *c_addr_prefix;
 
  char *c_address;
 
  struct GNUNET_TRANSPORT_TESTING_TransportCommunicatorQueue *queue_head;
 
  struct GNUNET_TRANSPORT_TESTING_TransportCommunicatorQueue *queue_tail;
 
  /* Callbacks + Closures */
  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_msg_cb;
 
  GNUNET_TRANSPORT_TESTING_BackchannelCallback bc_cb;
 
  struct GNUNET_SERVICE_Handle *sh;
 
  void *cb_cls;
 
  GNUNET_SCHEDULER_TaskCallback cont;
 
  void *cont_cls;
 
  int bc_enabled;
};
 
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);
 
 
void
GNUNET_TRANSPORT_TESTING_transport_communicator_service_stop (
  struct GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle *tc_h);
 
 
void
GNUNET_TRANSPORT_TESTING_transport_communicator_open_queue (struct
                                                            GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle
                                                            *tc_h,
                                                            const struct
                                                            GNUNET_PeerIdentity
                                                            *peer_id,
                                                            const char *address);
 
 
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);