1 /* 2 Copyright (c) 2007-2011 iMatix Corporation 3 Copyright (c) 2007-2011 Other contributors as noted in the AUTHORS file 4 5 This file is part of 0MQ. 6 7 0MQ is free software; you can redistribute it and/or modify it under 8 the terms of the GNU Lesser General Public License as published by 9 the Free Software Foundation; either version 3 of the License, or 10 (at your option) any later version. 11 12 0MQ is distributed in the hope that it will be useful, 13 but WITHOUT ANY WARRANTY; without even the implied warranty of 14 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the 15 GNU Lesser General Public License for more details. 16 17 You should have received a copy of the GNU Lesser General Public License 18 along with this program. If not, see <http://www.gnu.org/licenses/>. 19 */ 20 21 #ifndef __ZMQ_REQ_HPP_INCLUDED__ 22 #define __ZMQ_REQ_HPP_INCLUDED__ 23 24 #include "xreq.hpp" 25 26 namespace zmq 27 { 28 29 class req_t : public xreq_t 30 { 31 public: 32 33 req_t (class ctx_t *parent_, uint32_t tid_); 34 ~req_t (); 35 36 // Overloads of functions from socket_base_t. 37 int xsend (zmq_msg_t *msg_, int flags_); 38 int xrecv (zmq_msg_t *msg_, int flags_); 39 bool xhas_in (); 40 bool xhas_out (); 41 42 private: 43 44 // If true, request was already sent and reply wasn't received yet or 45 // was raceived partially. 46 bool receiving_reply; 47 48 // If true, we are starting to send/recv a message. The first part 49 // of the message must be empty message part (backtrace stack bottom). 50 bool message_begins; 51 52 req_t (const req_t&); 53 const req_t &operator = (const req_t&); 54 }; 55 56 } 57 58 #endif 59