src/include/gnunet_transport_service.h

   1 /*
   2      This file is part of GNUnet.
   3      (C) 2009 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 include/gnunet_transport_service.h
  23  * @brief low-level P2P IO
  24  * @author Christian Grothoff
  25  */
  26
  27 #ifndef GNUNET_TRANSPORT_SERVICE_H
  28 #define GNUNET_TRANSPORT_SERVICE_H
  29
  30 #ifdef __cplusplus
  31 extern "C"
  32 {
  33 #if 0                           /* keep Emacsens' auto-indent happy */
  34 }
  35 #endif
  36 #endif
  37
  38 #include "gnunet_bandwidth_lib.h"
  39 #include "gnunet_configuration_lib.h"
  40 #include "gnunet_crypto_lib.h"
  41 #include "gnunet_connection_lib.h"
  42 #include "gnunet_scheduler_lib.h"
  43 #include "gnunet_time_lib.h"
  44
  45 /**
  46  * Version number of the transport API.
  47  */
  48 #define GNUNET_TRANSPORT_VERSION 0x00000000
  49
  50
  51 /**
  52  * Enum defining all known property types for ATS Enum values are used
  53  * in the GNUNET_TRANSPORT_ATS_Information struct as
  54  * (key,value)-pairs.
  55  *
  56  * Cost are always stored in uint32_t, so all units used to define costs
  57  * have to be normalized to fit in uint32_t [0 .. 4.294.967.295]
  58  *
  59  * To keep the elements ordered
  60  *    1..1024 : Values with a relation to cost
  61  * 1025..2048 : Values with a relation to quality
  62  * 2049..3072 : Values with a relation to availability
  63  *
  64  */
  65 enum GNUNET_TRANSPORT_ATS_Property
  66 {
  67
  68   /**
  69    * End of the array.
  70    */
  71   GNUNET_TRANSPORT_ATS_ARRAY_TERMINATOR = 0,
  72
  73   /* Cost related values */
  74   /* =================== */
  75
  76   /**
  77    * Volume based cost in financial units to transmit data
  78    *
  79    * Note: This value is not bound to a specific currency or unit and only
  80    * used locally.
  81    * "cent" just refers the smallest amount of money in the respective
  82    * currency.
  83    *
  84    * Unit: [cent/MB]
  85    *
  86    * Interpretation: less is better
  87    *
  88    * Examples:
  89    * LAN:  0 [cent/MB]
  90    * 2G : 10 [cent/MB]
  91    */
  92   GNUNET_TRANSPORT_ATS_COST_FINANCIAL_PER_VOLUME = 1,
  93
  94   /**
  95    * Time based cost in financial units to transmit data
  96    *
  97    * Note: This value is not bound to a specific currency or unit and only
  98    * used locally.
  99    * "cent" just refers the smallest amount of money in the respective
 100    * currency.
 101    *
 102    * Unit: [cent/h]
 103    *
 104    * Interpretation: less is better
 105    *
 106    * Examples:
 107    * LAN   :  0 [cent/h]
 108    * Dialup: 10 [cent/h]
 109    */
 110   GNUNET_TRANSPORT_ATS_COST_FINANCIAL_PER_TIME = 2,
 111
 112   /**
 113    * Computational costs
 114    *
 115    * Effort of preparing data to be sent with this transport
 116    * Includes encoding, encryption and conversion of data
 117    * Partial values can be summed up: c_sum = c_enc + c_enc + c_conv
 118    * Resulting values depend on local system properties, e.g. CPU
 119    *
 120    * Unit: [ms/GB]
 121    *
 122    * Interpretation: less is better
 123    *
 124    * Examples:
 125    *
 126    * HTTPS with AES CBC-256:    7,382
 127    * HTTPS with AES CBC-128:    5,279
 128    * HTTPS with RC4-1024:       2,652
 129    */
 130   GNUNET_TRANSPORT_ATS_COST_COMPUTATIONAL = 3,
 131
 132   /**
 133    * Energy consumption
 134    *
 135    * Energy consumption using this transport when sending with a certain
 136    * power at a certain bitrate. This is only an approximation based on:
 137    * Energy consumption E = P / D
 138    *
 139    * with:
 140    * Power P in Watt (J/s)
 141    * Datarate D in MBit/s
 142    *
 143    * Conversion between power P and dBm used by WLAN in radiotap's dBm TX power:
 144    *
 145    * Lp(dbm) = 10 log10 (P/ 1mW)
 146    *
 147    * => P = 1 mW  * 10^(Lp(dbm)/10)
 148    *
 149    * Unit: [mJ/MB]
 150    *
 151    * Interpretation: less is better
 152    *
 153    * Examples:
 154    *
 155    * LAN:       0
 156    * WLAN:      89 (600 mW @ 802.11g /w 54 MBit/s)
 157    * Bluetooth: 267 (100 mW @ BT2.0 EDR /w 3 MBit/s)
 158    */
 159   GNUNET_TRANSPORT_ATS_COST_ENERGY_CONSUMPTION = 4,
 160
 161   /**
 162    * Connect cost
 163    * How many bytes are transmitted to initiate a new connection using
 164    * this transport?
 165    *
 166    * Unit: [bytes]
 167    *
 168    * Interpretation: less is better
 169    *
 170    * Examples:
 171    *
 172    * UDP (No connection)      :
 173    *     0 bytes
 174    * TCP (TCP 3-Way handshake):
 175    *   220 bytes Ethernet,  172 bytes TCP/IP,  122 bytes TCP
 176    * HTTP (TCP + Header)      :
 177    *   477 bytes Ethernet,  429 bytes TCP/IP,  374 bytes TCP,  278 bytes HTTP
 178    * HTTPS  HTTP+TLS Handshake:
 179    *  2129 bytes Ethernet, 1975 bytes TCP/IP, 1755 bytes TCP, 1403 bytes HTTPS
 180    *
 181    * */
 182   GNUNET_TRANSPORT_ATS_COST_CONNECT = 5,
 183
 184   /**
 185    * Bandwidth cost
 186    *
 187    * How many bandwidth is available to consume?
 188    * Used to calculate which impact sending data with this transport has
 189    *
 190    * Unit: [kB/s]
 191    *
 192    * Interpretation: more is better
 193    *
 194    * Examples:
 195    * LAN:     12,800  (100 MBit/s)
 196    * WLAN:    6,912   (54 MBit/s)
 197    * Dial-up: 8       (64 Kbit/s)
 198    *
 199    */
 200   GNUNET_TRANSPORT_ATS_COST_BANDWITH_AVAILABLE = 6,
 201
 202   /**
 203    *  Network overhead
 204    *
 205    * How many bytes are sent over the wire when 1 kilobyte (1024 bytes)
 206    * of application data is transmitted?
 207    * A factor used with connect cost, bandwidth cost and energy cost
 208    * to describe the overhead produced by the transport protocol
 209    *
 210    * Unit: [bytes/kb]
 211    *
 212    * Interpretation: less is better
 213    *
 214    * Examples:
 215    *
 216    * TCP/IPv4 over Ethernet: 1024 + 38 + 20 + 20 = 1102 [bytes/kb]
 217    * TCP/IPv6 over Ethernet: 1024 + 38 + 20 + 40 = 1122 [bytes/kb]
 218    * UDP/IPv4 over Ethernet: 1024 + 38 + 20 + 8  = 1090 [bytes/kb]
 219    * UDP/IPv6 over Ethernet: 1024 + 38 + 40 + 8  = 1110 [bytes/kb]
 220    */
 221   GNUNET_TRANSPORT_ATS_COST_NETWORK_OVERHEAD = 7,
 222
 223
 224   /* Quality related values */
 225   /* ====================== */
 226
 227   /* Physical layer quality properties */
 228
 229   /**
 230    * Signal strength on physical layer
 231    *
 232    * Unit: [dBm]
 233    */
 234   GNUNET_TRANSPORT_ATS_QUALITY_PHY_SIGNAL_STRENGTH = 1025,
 235
 236   /**
 237    * Collision rate on physical layer
 238    *
 239    * Unit: [B/s]
 240    */
 241   GNUNET_TRANSPORT_ATS_QUALITY_PHY_COLLISION_RATE = 1026,
 242
 243   /**
 244    * Error rate on physical layer
 245    *
 246    * Unit: [B/s]
 247    */
 248   GNUNET_TRANSPORT_ATS_QUALITY_PHY_ERROR_RATE = 1027,
 249
 250   /* Network layer quality properties */
 251
 252   /**
 253    * Delay
 254    * Time between when the time packet is sent and the packet arrives
 255    *
 256    * Unit: [μs]
 257    *
 258    * Examples:
 259    *
 260    * LAN   :  180
 261    * Dialup: 4000
 262    * WLAN  : 7000
 263    */
 264   GNUNET_TRANSPORT_ATS_QUALITY_NET_DELAY = 1028,
 265
 266   /**
 267    * Jitter
 268    * Time variations of the delay
 269    * 1st derivative of a delay function
 270    *
 271    * Unit: [μs]
 272    */
 273   GNUNET_TRANSPORT_ATS_QUALITY_NET_JITTER = 1029,
 274
 275   /**
 276    * Error rate on network layer
 277    *
 278    * Unit: [B/s]
 279    *
 280    * Examples:
 281    *
 282    * LAN       :    0
 283    * WLAN      :  400
 284    * Bluetooth :  100
 285    * Note: This numbers are just assumptions as an example, not
 286    * measured or somehow determined
 287    */
 288   GNUNET_TRANSPORT_ATS_QUALITY_NET_ERRORRATE = 1030,
 289
 290   /**
 291    * Drop rate on network layer
 292    * Bytes actively dismissed by a network component during transmission
 293    * Reasons for dropped data can be full queues, congestion, quota violations...
 294    *
 295    * Unit: [B/s]
 296    *
 297    * Examples:
 298    *
 299    * LAN       :    0
 300    * WLAN      :  400
 301    * Bluetooth :  100
 302    * Note: This numbers are just assumptions as an example, not
 303    * measured or somehow determined
 304    */
 305   GNUNET_TRANSPORT_ATS_QUALITY_NET_DROPRATE = 1031,
 306
 307   /**
 308    * Loss rate on network layer
 309    * Bytes lost during transmission
 310    * Reasons can be collisions, ...
 311    *
 312    * Unit: [B/s]
 313    *
 314    * Examples:
 315    *
 316    * LAN       :    0
 317    * WLAN      :   40
 318    * Bluetooth :   10
 319    * Note: This numbers are just assumptions as an example, not measured
 320    * or somehow determined
 321    */
 322   GNUNET_TRANSPORT_ATS_QUALITY_NET_LOSSRATE = 1032,
 323
 324   /**
 325    * Throughput on network layer
 326    *
 327    * Unit: [kB/s]
 328    *
 329    * Examples:
 330    *
 331    * LAN   : 3400
 332    * WLAN  : 1200
 333    * Dialup:      4
 334    *
 335    */
 336   GNUNET_TRANSPORT_ATS_QUALITY_NET_THROUGHPUT = 1033,
 337
 338   /* Availability related values */
 339   /* =========================== */
 340
 341   /**
 342    * Is a peer reachable?
 343    */
 344   GNUNET_TRANSPORT_ATS_AVAILABILITY_REACHABLE = 2048,
 345
 346   /**
 347    * Is there a connection established to a peer using this transport
 348    */
 349   GNUNET_TRANSPORT_ATS_AVAILABILITY_CONNECTED = 2049
 350
 351 };
 352
 353
 354 /**
 355  * struct used to communicate the transport's properties like cost and
 356  * quality of service as well as high-level constraints on resource
 357  * consumption.
 358  *
 359  *                             +---+
 360  *  +-----------+ Constraints  |   |  Plugin properties +---------+
 361  *  | Highlevel |------------> |ATS| <------------------|Transport|
 362  *  | Component | ATS struct   |   |    ATS struct      | Plugin  |
 363  *  +-----------+              |   |                    +---------+
 364  *                             +---+
 365  *
 366  * This structure will be used by transport plugins to communicate
 367  * costs to ATS or by higher level components to tell ATS their
 368  * constraints.  Always a pair of (GNUNET_TRANSPORT_ATS_Property,
 369  * uint32_t value).  Value is always uint32_t, so all units used to
 370  * define costs have to be normalized to fit uint32_t.
 371  */
 372 struct GNUNET_TRANSPORT_ATS_Information
 373 {
 374   /**
 375    * ATS property type, in network byte order.
 376    */
 377   uint32_t type;
 378
 379   /**
 380    * ATS property value, in network byte order.
 381    */
 382   uint32_t value;
 383 };
 384
 385
 386
 387
 388 /**
 389  * Function called by the transport for each received message.
 390  *
 391  * @param cls closure
 392  * @param peer (claimed) identity of the other peer
 393  * @param message the message
 394  * @param latency estimated latency for communicating with the
 395  *             given peer (round-trip)
 396  * @param distance in overlay hops, as given by transport plugin
 397  */
 398 typedef void (*GNUNET_TRANSPORT_ReceiveCallback) (void *cls,
 399                                                   const struct
 400                                                   GNUNET_PeerIdentity * peer,
 401                                                   const struct
 402                                                   GNUNET_MessageHeader *
 403                                                   message,
 404                                 const struct GNUNET_TRANSPORT_ATS_Information *ats,
 405                                                   uint32_t ats_count);
 406
 407
 408 /**
 409  * Opaque handle to the service.
 410  */
 411 struct GNUNET_TRANSPORT_Handle;
 412
 413
 414 /**
 415  * Function called to notify transport users that another
 416  * peer connected to us.
 417  *
 418  * @param cls closure
 419  * @param peer the peer that connected
 420  * @param latency estimated latency for communicating with the
 421  *             given peer (round-trip)
 422  * @param distance in overlay hops, as given by transport plugin
 423  */
 424 typedef void
 425   (*GNUNET_TRANSPORT_NotifyConnect) (void *cls,
 426                                      const struct GNUNET_PeerIdentity * peer,
 427                                      const struct GNUNET_TRANSPORT_ATS_Information *ats,
 428                                      uint32_t ats_count);
 429
 430 /**
 431  * Function called to notify transport users that another
 432  * peer disconnected from us.
 433  *
 434  * @param cls closure
 435  * @param peer the peer that disconnected
 436  */
 437 typedef void
 438   (*GNUNET_TRANSPORT_NotifyDisconnect) (void *cls,
 439                                         const struct GNUNET_PeerIdentity *
 440                                         peer);
 441
 442
 443 /**
 444  * Function to call with a human-readable format of an address
 445  *
 446  * @param cls closure
 447  * @param address NULL on error, otherwise 0-terminated printable UTF-8 string
 448  */
 449 typedef void
 450 (*GNUNET_TRANSPORT_AddressLookUpCallback) (void *cls,
 451                                            const char *address);
 452
 453
 454 /**
 455  * Connect to the transport service.  Note that the connection may
 456  * complete (or fail) asynchronously.
 457  *
 458  * @param cfg configuration to use
 459  * @param self our own identity (API should check that it matches
 460  *             the identity found by transport), or NULL (no check)
 461  * @param cls closure for the callbacks
 462  * @param rec receive function to call
 463  * @param nc function to call on connect events
 464  * @param nd function to call on disconnect events
 465  * @return NULL on error
 466  */
 467 struct GNUNET_TRANSPORT_Handle *GNUNET_TRANSPORT_connect (const struct
 468                                                           GNUNET_CONFIGURATION_Handle
 469                                                           *cfg,
 470                                                           const struct GNUNET_PeerIdentity *self,
 471                                                           void *cls,
 472                                                           GNUNET_TRANSPORT_ReceiveCallback
 473                                                           rec,
 474                                                           GNUNET_TRANSPORT_NotifyConnect
 475                                                           nc,
 476                                                           GNUNET_TRANSPORT_NotifyDisconnect
 477                                                           nd);
 478
 479
 480 /**
 481  * Disconnect from the transport service.
 482  *
 483  * @param handle handle returned from connect
 484  */
 485 void GNUNET_TRANSPORT_disconnect (struct GNUNET_TRANSPORT_Handle *handle);
 486
 487
 488 /**
 489  * Set the share of incoming/outgoing bandwidth for the given
 490  * peer to the specified amount.
 491  *
 492  * @param handle connection to transport service
 493  * @param target who's bandwidth quota is being changed
 494  * @param quota_in incoming bandwidth quota
 495  * @param quota_out outgoing bandwidth quota
 496  * @param timeout how long to wait until signaling failure if
 497  *        we can not communicate the quota change
 498  * @param cont continuation to call when done, will be called
 499  *        either with reason "TIMEOUT" or with reason "PREREQ_DONE"
 500  * @param cont_cls closure for continuation
 501  */
 502 void
 503 GNUNET_TRANSPORT_set_quota (struct GNUNET_TRANSPORT_Handle *handle,
 504                             const struct GNUNET_PeerIdentity *target,
 505                             struct GNUNET_BANDWIDTH_Value32NBO quota_in,
 506                             struct GNUNET_BANDWIDTH_Value32NBO quota_out,
 507                             struct GNUNET_TIME_Relative timeout,
 508                             GNUNET_SCHEDULER_Task cont, void *cont_cls);
 509
 510
 511 /**
 512  * Opaque handle for a transmission-ready request.
 513  */
 514 struct GNUNET_TRANSPORT_TransmitHandle;
 515
 516
 517 /**
 518  * Check if we could queue a message of the given size for
 519  * transmission.  The transport service will take both its internal
 520  * buffers and bandwidth limits imposed by the other peer into
 521  * consideration when answering this query.
 522  *
 523  * @param handle connection to transport service
 524  * @param target who should receive the message
 525  * @param size how big is the message we want to transmit?
 526  * @param priority how important is the message?
 527  * @param timeout after how long should we give up (and call
 528  *        notify with buf NULL and size 0)?
 529  * @param notify function to call when we are ready to
 530  *        send such a message
 531  * @param notify_cls closure for notify
 532  * @return NULL if someone else is already waiting to be notified
 533  *         non-NULL if the notify callback was queued (can be used to cancel
 534  *         using GNUNET_TRANSPORT_notify_transmit_ready_cancel)
 535  */
 536 struct GNUNET_TRANSPORT_TransmitHandle
 537   *GNUNET_TRANSPORT_notify_transmit_ready (struct GNUNET_TRANSPORT_Handle
 538                                            *handle,
 539                                            const struct GNUNET_PeerIdentity
 540                                            *target, size_t size,
 541                                            uint32_t priority,
 542                                            struct GNUNET_TIME_Relative
 543                                            timeout,
 544                                            GNUNET_CONNECTION_TransmitReadyNotify
 545                                            notify, void *notify_cls);
 546
 547
 548 /**
 549  * Cancel the specified transmission-ready notification.
 550  *
 551  * @param h handle of the transmission notification request to cancel
 552  */
 553 void
 554 GNUNET_TRANSPORT_notify_transmit_ready_cancel (struct
 555                                                GNUNET_TRANSPORT_TransmitHandle
 556                                                *h);
 557
 558
 559
 560 /**
 561  * Function called whenever there is an update to the
 562  * HELLO of this peer.
 563  *
 564  * @param cls closure
 565  * @param hello our updated HELLO
 566  */
 567 typedef void (*GNUNET_TRANSPORT_HelloUpdateCallback)(void *cls,
 568                                                      const struct GNUNET_MessageHeader *hello);
 569
 570
 571 /**
 572  * Obtain updates on changes to the HELLO message for this peer.
 573  *
 574  * @param handle connection to transport service
 575  * @param rec function to call with the HELLO
 576  * @param rec_cls closure for rec
 577  */
 578 void
 579 GNUNET_TRANSPORT_get_hello (struct GNUNET_TRANSPORT_Handle *handle,
 580                             GNUNET_TRANSPORT_HelloUpdateCallback rec,
 581                             void *rec_cls);
 582
 583
 584 /**
 585  * Stop receiving updates about changes to our HELLO message.
 586  *
 587  * @param handle connection to transport service
 588  * @param rec function previously registered to be called with the HELLOs
 589  * @param rec_cls closure for rec
 590  */
 591 void
 592 GNUNET_TRANSPORT_get_hello_cancel (struct GNUNET_TRANSPORT_Handle *handle,
 593                                    GNUNET_TRANSPORT_HelloUpdateCallback rec,
 594                                    void *rec_cls);
 595
 596
 597 /**
 598  * Offer the transport service the HELLO of another peer.  Note that
 599  * the transport service may just ignore this message if the HELLO is
 600  * malformed or useless due to our local configuration.  If the HELLO
 601  * is working, we should add it to PEERINFO.
 602  *
 603  * @param handle connection to transport service
 604  * @param hello the hello message
 605  */
 606 void
 607 GNUNET_TRANSPORT_offer_hello (struct GNUNET_TRANSPORT_Handle *handle,
 608                               const struct GNUNET_MessageHeader *hello);
 609
 610
 611 /**
 612  * Convert a binary address into a human readable address.
 613  *
 614  * @param cfg configuration to use
 615  * @param address address to convert (binary format)
 616  * @param addressLen number of bytes in address
 617  * @param numeric should (IP) addresses be displayed in numeric form
 618  *                (otherwise do reverse DNS lookup)
 619  * @param nameTrans name of the transport to which the address belongs
 620  * @param timeout how long is the lookup allowed to take at most
 621  * @param aluc function to call with the results
 622  * @param aluc_cls closure for aluc
 623  */
 624 void
 625 GNUNET_TRANSPORT_address_lookup (const struct GNUNET_CONFIGURATION_Handle *cfg,
 626                                  const char * address,
 627                                  size_t addressLen,
 628                                  int numeric,
 629                                  const char * nameTrans,
 630                                  struct GNUNET_TIME_Relative timeout,
 631                                  GNUNET_TRANSPORT_AddressLookUpCallback aluc,
 632                                  void *aluc_cls);
 633
 634
 635
 636 /**
 637  * Handle for blacklisting peers.
 638  */
 639 struct GNUNET_TRANSPORT_Blacklist;
 640
 641
 642 /**
 643  * Function that decides if a connection is acceptable or not.
 644  *
 645  * @param cls closure
 646  * @param pid peer to approve or disapproave
 647  * @return GNUNET_OK if the connection is allowed
 648  */
 649 typedef int (*GNUNET_TRANSPORT_BlacklistCallback)(void *cls,
 650                                                   const struct GNUNET_PeerIdentity *pid);
 651
 652
 653 /**
 654  * Install a blacklist callback.  The service will be queried for all
 655  * existing connections as well as any fresh connections to check if
 656  * they are permitted.  If the blacklisting callback is unregistered,
 657  * all hosts that were denied in the past will automatically be
 658  * whitelisted again.  Cancelling the blacklist handle is also the
 659  * only way to re-enable connections from peers that were previously
 660  * blacklisted.
 661  *
 662  * @param cfg configuration to use
 663  * @param cb callback to invoke to check if connections are allowed
 664  * @param cb_cls closure for cb
 665  * @return NULL on error, otherwise handle for cancellation
 666  */
 667 struct GNUNET_TRANSPORT_Blacklist *
 668 GNUNET_TRANSPORT_blacklist (const struct GNUNET_CONFIGURATION_Handle *cfg,
 669                             GNUNET_TRANSPORT_BlacklistCallback cb,
 670                             void *cb_cls);
 671
 672
 673 /**
 674  * Abort the blacklist.  Note that this function is the only way for
 675  * removing a peer from the blacklist.
 676  *
 677  * @param br handle of the request that is to be cancelled
 678  */
 679 void
 680 GNUNET_TRANSPORT_blacklist_cancel (struct GNUNET_TRANSPORT_Blacklist *br);
 681
 682
 683
 684 #if 0                           /* keep Emacsens' auto-indent happy */
 685 {
 686 #endif
 687 #ifdef __cplusplus
 688 }
 689 #endif
 690
 691 /* ifndef GNUNET_TRANSPORT_SERVICE_H */
 692 #endif
 693 /* end of gnunet_transport_service.h */