← Back to branch summary

~ubuntu-branches/ubuntu/saucy/zeromq3/saucy

« back to all changes in this revision

Viewing changes to src/xpub.hpp

  • Committer: Package Import Robot
  • Author(s): Alessandro Ghedini
  • Date: 2012-06-04 21:21:09 UTC
  • Revision ID: package-import@ubuntu.com-20120604212109-b7b3m0rn21o8oo2q
Tags: upstream-3.1.0~beta+dfsg
Import upstream version 3.1.0~beta+dfsg

Show diffs side-by-side

added added

removed removed

Lines of Context:
src/xpub.hpp
 
1
/*
 
2
    Copyright (c) 2010-2011 250bpm s.r.o.
 
3
    Copyright (c) 2010-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_XPUB_HPP_INCLUDED__
 
22
#define __ZMQ_XPUB_HPP_INCLUDED__
 
23
 
 
24
#include <deque>
 
25
#include <string>
 
26
 
 
27
#include "socket_base.hpp"
 
28
#include "session_base.hpp"
 
29
#include "mtrie.hpp"
 
30
#include "array.hpp"
 
31
#include "dist.hpp"
 
32
 
 
33
namespace zmq
 
34
{
 
35
 
 
36
    class ctx_t;
 
37
    class msg_t;
 
38
    class pipe_t;
 
39
    class io_thread_t;
 
40
 
 
41
    class xpub_t :
 
42
        public socket_base_t
 
43
    {
 
44
    public:
 
45
 
 
46
        xpub_t (zmq::ctx_t *parent_, uint32_t tid_);
 
47
        ~xpub_t ();
 
48
 
 
49
        //  Implementations of virtual functions from socket_base_t.
 
50
        void xattach_pipe (zmq::pipe_t *pipe_);
 
51
        int xsend (zmq::msg_t *msg_, int flags_);
 
52
        bool xhas_out ();
 
53
        int xrecv (zmq::msg_t *msg_, int flags_);
 
54
        bool xhas_in ();
 
55
        void xread_activated (zmq::pipe_t *pipe_);
 
56
        void xwrite_activated (zmq::pipe_t *pipe_);
 
57
        void xterminated (zmq::pipe_t *pipe_);
 
58
 
 
59
    private:
 
60
 
 
61
        //  Function to be applied to the trie to send all the subsciptions
 
62
        //  upstream.
 
63
        static void send_unsubscription (unsigned char *data_, size_t size_,
 
64
            void *arg_);
 
65
 
 
66
        //  Function to be applied to each matching pipes.
 
67
        static void mark_as_matching (zmq::pipe_t *pipe_, void *arg_);
 
68
 
 
69
        //  List of all subscriptions mapped to corresponding pipes.
 
70
        mtrie_t subscriptions;
 
71
 
 
72
        //  Distributor of messages holding the list of outbound pipes.
 
73
        dist_t dist;
 
74
 
 
75
        //  True if we are in the middle of sending a multi-part message.
 
76
        bool more;
 
77
 
 
78
        //  List of pending (un)subscriptions, ie. those that were already
 
79
        //  applied to the trie, but not yet received by the user.
 
80
        typedef std::basic_string <unsigned char> blob_t;
 
81
        typedef std::deque <blob_t> pending_t;
 
82
        pending_t pending;
 
83
 
 
84
        xpub_t (const xpub_t&);
 
85
        const xpub_t &operator = (const xpub_t&);
 
86
    };
 
87
 
 
88
    class xpub_session_t : public session_base_t
 
89
    {
 
90
    public:
 
91
 
 
92
        xpub_session_t (zmq::io_thread_t *io_thread_, bool connect_,
 
93
            socket_base_t *socket_, const options_t &options_,
 
94
            const char *protocol_, const char *address_);
 
95
        ~xpub_session_t ();
 
96
 
 
97
    private:
 
98
 
 
99
        xpub_session_t (const xpub_session_t&);
 
100
        const xpub_session_t &operator = (const xpub_session_t&);
 
101
    };
 
102
 
 
103
}
 
104
 
 
105
#endif