From 85cbd7f83c10c70da8fa44fe7673143703f9710d Mon Sep 17 00:00:00 2001 From: malosek Date: Tue, 22 Sep 2009 15:12:51 +0200 Subject: added PGM bus functionality --- src/pgm_socket.hpp | 19 ++++++++----------- 1 file changed, 8 insertions(+), 11 deletions(-) (limited to 'src/pgm_socket.hpp') diff --git a/src/pgm_socket.hpp b/src/pgm_socket.hpp index fe4468b..c9d0feb 100644 --- a/src/pgm_socket.hpp +++ b/src/pgm_socket.hpp @@ -77,7 +77,7 @@ namespace zmq void free_buffer (void *data_); // Receive data from pgm socket. - ssize_t receive (void **data_); + ssize_t receive (void **data_, const pgm_tsi_t **tsi_); // POLLIN on sender side should mean NAK or SPMR receiving. // process_upstream function is used to handle such a situation. @@ -90,21 +90,18 @@ namespace zmq private: - // Associated socket options. - options_t options; - // Returns max tsdu size without fragmentation. size_t get_max_tsdu_size (void); // Returns maximum count of apdus which fills readbuf_size_ size_t get_max_apdu_at_once (size_t readbuf_size_); - // Return true if TSI has empty GSI ('\0') and sport 0. - bool tsi_empty (const pgm_tsi_t *tsi_); + // Compute gsi from string. + int pgm_create_custom_gsi (const char *data_, pgm_gsi_t *gsi_); - // Compare TSIs, return true if equal. - bool tsi_equal (const pgm_tsi_t *tsi_a_, const pgm_tsi_t *tsi_b_); - + // Associated socket options. + options_t options; + // true when pgm_socket should create receiving side. bool receiver; @@ -140,10 +137,10 @@ namespace zmq enum {pgm_receiver_fd_count = 2}; // TSI of the actual peer. - pgm_tsi_t tsi; +// pgm_tsi_t tsi; // Previous peer TSI. - pgm_tsi_t retired_tsi; +// pgm_tsi_t retired_tsi; #endif }; -- cgit v1.2.3