From cf6cc0128ff4d26e0059f399bbb8342ce259b996 Mon Sep 17 00:00:00 2001 From: malosek Date: Fri, 25 Sep 2009 17:50:12 +0200 Subject: pgm2 receiver working (partly) --- src/pgm_socket.hpp | 14 +++++++++++++- 1 file changed, 13 insertions(+), 1 deletion(-) (limited to 'src/pgm_socket.hpp') diff --git a/src/pgm_socket.hpp b/src/pgm_socket.hpp index 6c1ca10..5225e50 100644 --- a/src/pgm_socket.hpp +++ b/src/pgm_socket.hpp @@ -119,16 +119,28 @@ namespace zmq pgm_msgv_t *pgm_msgv; // How many bytes were read from pgm socket. +#ifdef ZMQ_HAVE_OPENPGM1 ssize_t nbytes_rec; +#elif defined ZMQ_HAVE_OPENPGM2 + size_t nbytes_rec; +#endif // How many bytes were processed from last pgm socket read. +#ifdef ZMQ_HAVE_OPENPGM1 ssize_t nbytes_processed; +#elif defined ZMQ_HAVE_OPENPGM2 + size_t nbytes_processed; +#endif // How many messages from pgm_msgv were already sent up. +#ifdef ZMQ_HAVE_OPENPGM1 ssize_t pgm_msgv_processed; +#elif defined ZMQ_HAVE_OPENPGM2 + size_t pgm_msgv_processed; +#endif // Size of pgm_msgv array. - ssize_t pgm_msgv_len; + size_t pgm_msgv_len; // Sender transport uses 2 fd. enum {pgm_sender_fd_count = 2}; -- cgit v1.2.3