1 /* 2 Copyright (c) 2007-2010 iMatix Corporation 3 4 This file is part of 0MQ. 5 6 0MQ is free software; you can redistribute it and/or modify it under 7 the terms of the GNU Lesser General Public License as published by 8 the Free Software Foundation; either version 3 of the License, or 9 (at your option) any later version. 10 11 0MQ is distributed in the hope that it will be useful, 12 but WITHOUT ANY WARRANTY; without even the implied warranty of 13 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the 14 GNU Lesser General Public License for more details. 15 16 You should have received a copy of the GNU Lesser General Public License 17 along with this program. If not, see <http://www.gnu.org/licenses/>. 18 */ 19 20 #ifndef __ZMQ_PULL_HPP_INCLUDED__ 21 #define __ZMQ_PULL_HPP_INCLUDED__ 22 23 #include "socket_base.hpp" 24 #include "fq.hpp" 25 26 namespace zmq 27 { 28 29 class pull_t : public socket_base_t 30 { 31 public: 32 33 pull_t (class ctx_t *parent_, uint32_t tid_); 34 ~pull_t (); 35 36 protected: 37 38 // Overloads of functions from socket_base_t. 39 void xattach_pipes (class reader_t *inpipe_, class writer_t *outpipe_, 40 const blob_t &peer_identity_); 41 int xrecv (zmq_msg_t *msg_, int flags_); 42 bool xhas_in (); 43 44 private: 45 46 // Hook into the termination process. 47 void process_term (int linger_); 48 49 // Fair queueing object for inbound pipes. 50 fq_t fq; 51 52 pull_t (const pull_t&); 53 const pull_t &operator = (const pull_t&); 54 55 }; 56 57 } 58 59 #endif 60