30 #ifndef __ZMQ_PGM_SENDER_HPP_INCLUDED__ 31 #define __ZMQ_PGM_SENDER_HPP_INCLUDED__ 33 #include "platform.hpp" 35 #if defined ZMQ_HAVE_OPENPGM 37 #ifdef ZMQ_HAVE_WINDOWS 55 class pgm_sender_t :
public io_object_t,
public i_engine
63 int init (
bool udp_encapsulation_,
const char *network_);
69 void restart_input ();
70 void restart_output ();
71 void zap_msg_available () {}
76 void timer_event (
int token);
84 enum {tx_timer_id = 0xa0, rx_timer_id = 0xa1};
90 session_base_t *session;
101 pgm_socket_t pgm_socket;
108 handle_t uplink_handle;
109 handle_t rdata_notify_handle;
110 handle_t pending_notify_handle;
113 unsigned char *out_buffer;
116 size_t out_buffer_size;
122 pgm_sender_t (
const pgm_sender_t&);
123 const pgm_sender_t &operator = (
const pgm_sender_t&);
static char encoder[85+1]