Problem: PGM/NORM builds broken due to i_engine API change

Solution: implement get_endpoint in the NORM and PGM engines too
This commit is contained in:
Luca Boccassi
2017-08-08 15:18:07 +01:00
parent a6cef4ef86
commit 75fba539d0
6 changed files with 18 additions and 0 deletions

View File

@@ -728,5 +728,9 @@ zmq::norm_engine_t::NormRxStreamState* zmq::norm_engine_t::NormRxStreamState::Li
return nextItem; return nextItem;
} // end zmq::norm_engine_t::NormRxStreamState::List::Iterator::GetNextItem() } // end zmq::norm_engine_t::NormRxStreamState::List::Iterator::GetNextItem()
const char *zmq::norm_engine_t::get_endpoint () const
{
return "";
}
#endif // ZMQ_HAVE_NORM #endif // ZMQ_HAVE_NORM

View File

@@ -46,6 +46,8 @@ namespace zmq
virtual void zap_msg_available () {}; virtual void zap_msg_available () {};
virtual const char *get_endpoint () const;
// i_poll_events interface implementation. // i_poll_events interface implementation.
// (we only need in_event() for NormEvent notification) // (we only need in_event() for NormEvent notification)
// (i.e., don't have any output events or timers (yet)) // (i.e., don't have any output events or timers (yet))

View File

@@ -152,6 +152,11 @@ void zmq::pgm_receiver_t::restart_input ()
in_event (); in_event ();
} }
const char *zmq::pgm_receiver_t::get_endpoint () const
{
return "";
}
void zmq::pgm_receiver_t::in_event () void zmq::pgm_receiver_t::in_event ()
{ {
// Read data from the underlying pgm_socket. // Read data from the underlying pgm_socket.

View File

@@ -64,6 +64,7 @@ namespace zmq
void restart_input (); void restart_input ();
void restart_output (); void restart_output ();
void zap_msg_available () {} void zap_msg_available () {}
const char *get_endpoint () const;
// i_poll_events interface implementation. // i_poll_events interface implementation.
void in_event (); void in_event ();

View File

@@ -136,6 +136,11 @@ void zmq::pgm_sender_t::restart_input ()
zmq_assert (false); zmq_assert (false);
} }
const char *zmq::pgm_sender_t::get_endpoint () const
{
return "";
}
zmq::pgm_sender_t::~pgm_sender_t () zmq::pgm_sender_t::~pgm_sender_t ()
{ {
int rc = msg.close (); int rc = msg.close ();

View File

@@ -63,6 +63,7 @@ namespace zmq
void restart_input (); void restart_input ();
void restart_output (); void restart_output ();
void zap_msg_available () {} void zap_msg_available () {}
const char *get_endpoint () const;
// i_poll_events interface implementation. // i_poll_events interface implementation.
void in_event (); void in_event ();