X-Git-Url: http://bilbo.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/8065b83e3317c2162066e7d541682a6df037bae4..ce8a9fdb7cad584a5e27d0d4af32b844d3e5420b:/examples/msg/bittorrent/messages.h diff --git a/examples/msg/bittorrent/messages.h b/examples/msg/bittorrent/messages.h index 507364057a..2a87b7c624 100644 --- a/examples/msg/bittorrent/messages.h +++ b/examples/msg/bittorrent/messages.h @@ -7,6 +7,21 @@ #ifndef BITTORRENT_MESSAGES_H_ #define BITTORRENT_MESSAGES_H_ #include + +/** + * Message sizes + */ +#define MESSAGE_HANDSHAKE_SIZE 68 +#define MESSAGE_CHOKE_SIZE 5 +#define MESSAGE_UNCHOKE_SIZE 5 +#define MESSAGE_INTERESTED_SIZE 5 +#define MESSAGE_NOTINTERESTED_SIZE 5 +#define MESSAGE_HAVE_SIZE 9 +#define MESSAGE_BITFIELD_SIZE 5 +#define MESSAGE_REQUEST_SIZE 17 +#define MESSAGE_PIECE_SIZE 13 +#define MESSAGE_CANCEL_SIZE 17 + /** * Types of messages exchanged between two peers. */ @@ -41,20 +56,21 @@ typedef struct s_message { */ msg_task_t task_message_new(e_message_type type, const char *issuer_host_name, - const char *mailbox, int peer_id); + const char *mailbox, int peer_id, + int size); /** * Builds a new "have/piece" message */ msg_task_t task_message_index_new(e_message_type type, const char *issuer_host_name, const char *mailbox, int peer_id, - int index); + int index, int varsize); /** * Builds a new bitfield message */ msg_task_t task_message_bitfield_new(const char *issuer_host_name, const char *mailbox, int peer_id, - char *bitfield); + char *bitfield, int bitfield_size); /** * Builds a new "request" message */ @@ -68,9 +84,11 @@ msg_task_t task_message_request_new(const char *issuer_host_name, msg_task_t task_message_piece_new(const char *issuer_host_name, const char *mailbox, int peer_id, int index, int stalled, int block_index, - int block_length); + int block_length, int block_size); /** * Free a message task */ void task_message_free(void *); + +int task_message_size(e_message_type type); #endif /* BITTORRENT_MESSAGES_H_ */