diff --git a/Include/Zmq/Socket.mqh b/Include/Zmq/Socket.mqh index 2bb2aa6..cb8df99 100644 --- a/Include/Zmq/Socket.mqh +++ b/Include/Zmq/Socket.mqh @@ -141,9 +141,6 @@ public: bool send(ZmqMsg &msg,bool nowait=false,bool more=false); bool recv(ZmqMsg &msg,bool nowait=false); - void register(PollItem &pollitem,bool read=false,bool write=false); - void register(PollItem &pollitems[],int index,bool read=false,bool write=false); - //--- monitor socket events bool monitor(string addr,int events); @@ -263,26 +260,6 @@ bool Socket::monitor(string addr,int events) //+------------------------------------------------------------------+ //| | //+------------------------------------------------------------------+ -void Socket::register(PollItem &pollitem,bool read=false,bool write=false) - { - ZeroMemory(pollitem); - pollitem.socket=m_ref; - if(read) pollitem.events|=ZMQ_POLLIN; - if(write) pollitem.events|=ZMQ_POLLOUT; - } -//+------------------------------------------------------------------+ -//| | -//+------------------------------------------------------------------+ -void Socket::register(PollItem &pollitems[],int index,bool read=false,bool write=false) - { - ZeroMemory(pollitems[index]); - pollitems[index].socket=m_ref; - if(read) pollitems[index].events|=ZMQ_POLLIN; - if(write) pollitems[index].events|=ZMQ_POLLOUT; - } -//+------------------------------------------------------------------+ -//| | -//+------------------------------------------------------------------+ bool Socket::proxy(Socket *frontend,Socket *backend,Socket *capture) { intptr_t frontend_ref= CheckPointer(frontend)==POINTER_DYNAMIC?frontend.ref():0;