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