X-Git-Url: https://git.librecmc.org/?a=blobdiff_plain;f=src%2Fmesh%2Fmesh_protocol.h;h=2d708eb6220b11144c963eac1b525937a790b92e;hb=0f6d24a229e9149db26a4e667ed25032d19f533a;hp=f01cb7d982a4a965b69ccca63ba5ed744f6cec75;hpb=7d8b54629029a4b7aea43db6af4cfaf188c856b8;p=oweals%2Fgnunet.git diff --git a/src/mesh/mesh_protocol.h b/src/mesh/mesh_protocol.h index f01cb7d98..2d708eb62 100644 --- a/src/mesh/mesh_protocol.h +++ b/src/mesh/mesh_protocol.h @@ -42,12 +42,12 @@ extern "C" GNUNET_NETWORK_STRUCT_BEGIN /** - * Message for mesh path management + * Message for mesh path creation. */ -struct GNUNET_MESH_ManipulatePath +struct GNUNET_MESH_CreateTunnel { /** - * Type: GNUNET_MESSAGE_TYPE_MESH_PATH_[CREATE|CHANGE|ADD|DEL] + * Type: GNUNET_MESSAGE_TYPE_MESH_PATH_CREATE * * Size: sizeof(struct GNUNET_MESH_ManipulatePath) + * path_length * sizeof (struct GNUNET_PeerIdentity) @@ -61,19 +61,32 @@ struct GNUNET_MESH_ManipulatePath uint32_t tid GNUNET_PACKED; /** + * Tunnel options (GNUNET_MESH_OPTION_*). + */ + uint32_t opt GNUNET_PACKED; + + /** + * Destination port. + */ + uint32_t port GNUNET_PACKED; + + /** + * FIXME do not add the first hop * path_length structs defining the *whole* path from the origin [0] to the * final destination [path_length-1]. */ /* struct GNUNET_PeerIdentity peers[path_length]; */ }; + /** - * Message for mesh data traffic to all tunnel targets. + * Message for mesh data traffic. */ -struct GNUNET_MESH_Multicast +struct GNUNET_MESH_Data { /** - * Type: GNUNET_MESSAGE_TYPE_MESH_MULTICAST + * Type: GNUNET_MESSAGE_TYPE_MESH_UNICAST, + * GNUNET_MESSAGE_TYPE_MESH_TO_ORIGIN */ struct GNUNET_MessageHeader header; @@ -88,7 +101,7 @@ struct GNUNET_MESH_Multicast uint32_t ttl GNUNET_PACKED; /** - * Unique ID of the packet + * ID of the packet */ uint32_t pid GNUNET_PACKED; @@ -97,6 +110,11 @@ struct GNUNET_MESH_Multicast */ struct GNUNET_PeerIdentity oid; + /** + * Unique ID of the payload message + */ + uint32_t mid GNUNET_PACKED; + /** * Payload follows */ @@ -104,53 +122,46 @@ struct GNUNET_MESH_Multicast /** - * Message for mesh data traffic to a particular destination from origin. + * Message to acknowledge end-to-end data. */ -struct GNUNET_MESH_Unicast +struct GNUNET_MESH_DataACK { - /** - * Type: GNUNET_MESSAGE_TYPE_MESH_UNICAST - */ + /** + * Type: GNUNET_MESSAGE_TYPE_MESH_DATA_ACK + */ struct GNUNET_MessageHeader header; - /** - * TID of the tunnel - */ + /** + * TID of the tunnel + */ uint32_t tid GNUNET_PACKED; - /** - * Number of hops to live - */ - uint32_t ttl GNUNET_PACKED; - - /** - * Unique ID of the packet - */ - uint32_t pid GNUNET_PACKED; - - /** - * OID of the tunnel - */ + /** + * OID of the tunnel + */ struct GNUNET_PeerIdentity oid; - /** - * Destination. - */ - struct GNUNET_PeerIdentity destination; - - /** - * Payload follows - */ + /** + * Bitfield of already-received newer messages + * pid + 1 @ LSB + * pid + 64 @ MSB + */ + uint64_t futures GNUNET_PACKED; + + /** + * Last message ID received. + */ + uint32_t mid GNUNET_PACKED; }; /** - * Message for mesh data traffic from a tunnel participant to origin. + * Message to acknowledge mesh data traffic. */ -struct GNUNET_MESH_ToOrigin +struct GNUNET_MESH_ACK { /** - * Type: GNUNET_MESSAGE_TYPE_MESH_TO_ORIGIN + * Type: GNUNET_MESSAGE_TYPE_MESH_ACK */ struct GNUNET_MessageHeader header; @@ -165,16 +176,38 @@ struct GNUNET_MESH_ToOrigin struct GNUNET_PeerIdentity oid; /** - * Sender of the message. - */ - struct GNUNET_PeerIdentity sender; - - /** - * Payload follows + * Maximum packet ID authorized. */ + uint32_t pid GNUNET_PACKED; }; +/** + * Message to query a peer about its Flow Control status regarding a tunnel. + */ +struct GNUNET_MESH_Poll +{ + /** + * Type: GNUNET_MESSAGE_TYPE_MESH_POLL + */ + struct GNUNET_MessageHeader header; + + /** + * TID of the tunnel + */ + uint32_t tid GNUNET_PACKED; + + /** + * OID of the tunnel + */ + struct GNUNET_PeerIdentity oid; + + /** + * Last packet sent. + */ + uint32_t pid GNUNET_PACKED; +}; + /** * Message for ack'ing a path */ @@ -200,6 +233,11 @@ struct GNUNET_MESH_PathACK */ struct GNUNET_PeerIdentity peer_id; + /** + * Initial ACK value for payload. + */ + uint32_t ack GNUNET_PACKED; + /* TODO: signature */ }; @@ -263,36 +301,28 @@ struct GNUNET_MESH_TunnelDestroy /** - * Message for mesh flow control + * Message to destroy a tunnel */ -struct GNUNET_MESH_SpeedNotify +struct GNUNET_MESH_TunnelKeepAlive { - /** - * Type: GNUNET_MESSAGE_TYPE_DATA_SPEED_NOTIFY - */ + /** + * Type: GNUNET_MESSAGE_TYPE_MESH_PATH_(FWD|BCK)_KEEPALIVE + */ struct GNUNET_MessageHeader header; - /** - * TID of the tunnel - */ + /** + * TID of the tunnel + */ uint32_t tid GNUNET_PACKED; - /** - * OID of the tunnel - */ + /** + * OID of the tunnel + */ struct GNUNET_PeerIdentity oid; +}; - /** - * Is the speed limited by the slowest peer?. - */ - int16_t speed_min; - /** - * Is the buffering allowed?. - */ - int16_t buffering; -}; GNUNET_NETWORK_STRUCT_END #if 0 /* keep Emacsens' auto-indent happy */