src/testbed/testbed_api.h

   1 /*
   2       This file is part of GNUnet
   3       (C) 2012 Christian Grothoff (and other contributing authors)
   4
   5       GNUnet is free software; you can redistribute it and/or modify
   6       it under the terms of the GNU General Public License as published
   7       by the Free Software Foundation; either version 3, or (at your
   8       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       General Public License for more details.
  14
  15       You should have received a copy of the GNU General Public License
  16       along with GNUnet; see the file COPYING.  If not, write to the
  17       Free Software Foundation, Inc., 59 Temple Place - Suite 330,
  18       Boston, MA 02111-1307, USA.
  19  */
  20
  21 /**
  22  * @file testbed/testbed_api.h
  23  * @brief Interface for functions internally exported from testbed_api.c
  24  * @author Sree Harsha Totakura
  25  */
  26
  27 #ifndef TESTBED_API_H
  28 #define TESTBED_API_H
  29
  30 #include "gnunet_testbed_service.h"
  31 #include "testbed.h"
  32
  33 /**
  34  * Enumeration of operations
  35  */
  36 enum OperationType
  37 {
  38     /**
  39      * Peer create operation
  40      */
  41   OP_PEER_CREATE,
  42
  43     /**
  44      * Peer start operation
  45      */
  46   OP_PEER_START,
  47
  48     /**
  49      * Peer stop operation
  50      */
  51   OP_PEER_STOP,
  52
  53     /**
  54      * Peer destroy operation
  55      */
  56   OP_PEER_DESTROY,
  57
  58     /**
  59      * Get peer information operation
  60      */
  61   OP_PEER_INFO,
  62
  63     /**
  64      * Overlay connection operation
  65      */
  66   OP_OVERLAY_CONNECT,
  67
  68     /**
  69      * Forwarded operation
  70      */
  71   OP_FORWARDED,
  72
  73     /**
  74      * Link controllers operation
  75      */
  76   OP_LINK_CONTROLLERS,
  77
  78 };
  79
  80
  81 /**
  82  * Testbed operation structure
  83  */
  84 struct GNUNET_TESTBED_Operation
  85 {
  86   /**
  87    * next pointer for DLL
  88    */
  89   struct GNUNET_TESTBED_Operation *next;
  90
  91   /**
  92    * prev pointer for DLL
  93    */
  94   struct GNUNET_TESTBED_Operation *prev;
  95
  96   /**
  97    * The controller on which this operation operates
  98    */
  99   struct GNUNET_TESTBED_Controller *controller;
 100
 101   /**
 102    * The ID for the operation;
 103    */
 104   uint64_t operation_id;
 105
 106   /**
 107    * The type of operation
 108    */
 109   enum OperationType type;
 110
 111   /**
 112    * Data specific to OperationType
 113    */
 114   void *data;
 115 };
 116
 117
 118 /**
 119  * The message queue for sending messages to the controller service
 120  */
 121 struct MessageQueue;
 122
 123 /**
 124  * Structure for a controller link
 125  */
 126 struct ControllerLink;
 127
 128
 129 /**
 130  * Enumeration of states of OperationContext
 131  */
 132 enum OperationContextState
 133 {
 134     /**
 135      * The initial state where the associated operation has just been created
 136      * and is waiting in the operation queues to be started
 137      */
 138   OPC_STATE_INIT = 0,
 139
 140     /**
 141      * The operation has been started. It may occupy some resources which are to
 142      * be freed if cancelled.
 143      */
 144   OPC_STATE_STARTED,
 145
 146     /**
 147      * The operation has finished. The end results of this operation may occupy
 148      * some resources which are to be freed by operation_done
 149      */
 150   OPC_STATE_FINISHED
 151 };
 152
 153
 154 /**
 155  * Context information for GNUNET_TESTBED_Operation
 156  */
 157 struct OperationContext
 158 {
 159   /**
 160    * next ptr for DLL
 161    */
 162   struct OperationContext *next;
 163
 164   /**
 165    * prev ptr for DLL
 166    */
 167   struct OperationContext *prev;
 168
 169   /**
 170    * The controller to which this operation context belongs to
 171    */
 172   struct GNUNET_TESTBED_Controller *c;
 173
 174   /**
 175    * The operation
 176    */
 177   struct GNUNET_TESTBED_Operation *op;
 178
 179   /**
 180    * Data relevant to the operation
 181    */
 182   void *data;
 183
 184   /**
 185    * The id of the opearation
 186    */
 187   uint64_t id;
 188
 189   /**
 190    * The type of operation
 191    */
 192   enum OperationType type;
 193
 194   /**
 195    * The state of the operation
 196    */
 197   enum OperationContextState state;
 198 };
 199
 200
 201 /**
 202  * Handle to interact with a GNUnet testbed controller.  Each
 203  * controller has at least one master handle which is created when the
 204  * controller is created; this master handle interacts with the
 205  * controller process, destroying it destroys the controller (by
 206  * closing stdin of the controller process).  Additionally,
 207  * controllers can interact with each other (in a P2P fashion); those
 208  * links are established via TCP/IP on the controller's service port.
 209  */
 210 struct GNUNET_TESTBED_Controller
 211 {
 212
 213   /**
 214    * The host where the controller is running
 215    */
 216   struct GNUNET_TESTBED_Host *host;
 217
 218   /**
 219    * The controller callback
 220    */
 221   GNUNET_TESTBED_ControllerCallback cc;
 222
 223   /**
 224    * The closure for controller callback
 225    */
 226   void *cc_cls;
 227
 228   /**
 229    * The configuration to use while connecting to controller
 230    */
 231   struct GNUNET_CONFIGURATION_Handle *cfg;
 232
 233   /**
 234    * The client connection handle to the controller service
 235    */
 236   struct GNUNET_CLIENT_Connection *client;
 237
 238   /**
 239    * The head of the message queue
 240    */
 241   struct MessageQueue *mq_head;
 242
 243   /**
 244    * The tail of the message queue
 245    */
 246   struct MessageQueue *mq_tail;
 247
 248   /**
 249    * The head of the ControllerLink list
 250    */
 251   struct ControllerLink *cl_head;
 252
 253   /**
 254    * The tail of the ControllerLink list
 255    */
 256   struct ControllerLink *cl_tail;
 257
 258   /**
 259    * The client transmit handle
 260    */
 261   struct GNUNET_CLIENT_TransmitHandle *th;
 262
 263   /**
 264    * The host registration handle; NULL if no current registration requests are
 265    * present
 266    */
 267   struct GNUNET_TESTBED_HostRegistrationHandle *rh;
 268
 269   /**
 270    * The head of the opeartion context queue
 271    */
 272   struct OperationContext *ocq_head;
 273
 274   /**
 275    * The tail of the operation context queue
 276    */
 277   struct OperationContext *ocq_tail;
 278
 279   /**
 280    * Operation queue for simultaneous operations
 281    */
 282   struct OperationQueue *opq_parallel_operations;
 283
 284   /**
 285    * Operation queue for simultaneous service connections
 286    */
 287   struct OperationQueue *opq_parallel_service_connections;
 288
 289   /**
 290    * The operation id counter. use current value and increment
 291    */
 292   uint64_t operation_counter;
 293
 294   /**
 295    * The controller event mask
 296    */
 297   uint64_t event_mask;
 298
 299   /**
 300    * Did we start the receive loop yet?
 301    */
 302   int in_receive;
 303
 304   /**
 305    * Did we create the host for this?
 306    */
 307   int aux_host;
 308 };
 309
 310
 311 /**
 312  * Queues a message in send queue for sending to the service
 313  *
 314  * @param controller the handle to the controller
 315  * @param msg the message to queue
 316  */
 317 void
 318 GNUNET_TESTBED_queue_message_ (struct GNUNET_TESTBED_Controller *controller,
 319                                struct GNUNET_MessageHeader *msg);
 320
 321
 322 /**
 323  * Compresses given configuration using zlib compress
 324  *
 325  * @param config the serialized configuration
 326  * @param size the size of config
 327  * @param xconfig will be set to the compressed configuration (memory is fresly
 328  *          allocated)
 329  * @return the size of the xconfig
 330  */
 331 size_t
 332 GNUNET_TESTBED_compress_config_ (const char *config, size_t size,
 333                                  char **xconfig);
 334
 335
 336 /**
 337  * Adds an operation to the queue of operations
 338  *
 339  * @param op the operation to add
 340  */
 341 void
 342 GNUNET_TESTBED_operation_add_ (struct GNUNET_TESTBED_Operation *op);
 343
 344
 345 /**
 346  * Creates a helper initialization message. Only for testing.
 347  *
 348  * @param cname the ip address of the controlling host
 349  * @param cfg the configuration that has to used to start the testbed service
 350  *          thru helper
 351  * @return the initialization message
 352  */
 353 struct GNUNET_TESTBED_HelperInit *
 354 GNUNET_TESTBED_create_helper_init_msg_ (const char *cname,
 355                                         const struct GNUNET_CONFIGURATION_Handle
 356                                         *cfg);
 357
 358
 359 /**
 360  * Sends the given message as an operation. The given callback is called when a
 361  * reply for the operation is available.  Call
 362  * GNUNET_TESTBED_forward_operation_msg_cancel_() to cleanup the returned
 363  * operation context if the cc hasn't been called
 364  *
 365  * @param controller the controller to which the message has to be sent
 366  * @param operation_id the operation id of the message
 367  * @param msg the message to send
 368  * @param cc the callback to call when reply is available
 369  * @param cc_cls the closure for the above callback
 370  * @return the operation context which can be used to cancel the forwarded
 371  *           operation
 372  */
 373 struct OperationContext *
 374 GNUNET_TESTBED_forward_operation_msg_ (struct GNUNET_TESTBED_Controller
 375                                        *controller, uint64_t operation_id,
 376                                        const struct GNUNET_MessageHeader *msg,
 377                                        GNUNET_CLIENT_MessageHandler cc,
 378                                        void *cc_cls);
 379
 380 /**
 381  * Function to cancel an operation created by simply forwarding an operation
 382  * message.
 383  *
 384  * @param opc the operation context from GNUNET_TESTBED_forward_operation_msg_()
 385  */
 386 void
 387 GNUNET_TESTBED_forward_operation_msg_cancel_ (struct OperationContext *opc);
 388
 389
 390 /**
 391  * Generates configuration by parsing Peer configuration information reply message
 392  *
 393  * @param msg the peer configuration information message
 394  * @return handle to the parsed configuration
 395  */
 396 struct GNUNET_CONFIGURATION_Handle *
 397 GNUNET_TESTBED_get_config_from_peerinfo_msg_ (const struct
 398                                               GNUNET_TESTBED_PeerConfigurationInformationMessage
 399                                               *msg);
 400
 401 #endif
 402 /* end of testbed_api.h */