diff options
Diffstat (limited to 'src/pgm_socket.hpp')
| -rw-r--r-- | src/pgm_socket.hpp | 14 |
1 files changed, 13 insertions, 1 deletions
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}; |