← Back to branch summary

~ubuntu-branches/ubuntu/wily/zeromq3/wily-proposed

« back to all changes in this revision

Viewing changes to src/router.hpp

  • Committer: Package Import Robot
  • Author(s): Alessandro Ghedini
  • Date: 2014-03-16 14:02:28 UTC
  • mfrom: (1.1.6) (6.1.1 experimental)
  • Revision ID: package-import@ubuntu.com-20140316140228-ig1sgh7czk59m9ux
Tags: 4.0.4+dfsg-1
* QA upload; orphan the package
  - Upload to unstable
* New upstream release
* Update repack.stub script
* Drop 02_fix-exported-symbols.patch and 03_fix-s390-rdtsc.patch
  (merged upstream)

Show diffs side-by-side

added added

removed removed

Lines of Context:
src/router.hpp
1
1
/*
2
 
    Copyright (c) 2009-2011 250bpm s.r.o.
3
 
    Copyright (c) 2011 iMatix Corporation
4
 
    Copyright (c) 2011 VMware, Inc.
5
 
    Copyright (c) 2007-2011 Other contributors as noted in the AUTHORS file
 
2
    Copyright (c) 2007-2013 Contributors as noted in the AUTHORS file
6
3
 
7
4
    This file is part of 0MQ.
8
5
 
48
45
        ~router_t ();
49
46
 
50
47
        //  Overloads of functions from socket_base_t.
51
 
        void xattach_pipe (zmq::pipe_t *pipe_, bool icanhasall_);
 
48
        void xattach_pipe (zmq::pipe_t *pipe_, bool subscribe_to_all_);
52
49
        int xsetsockopt (int option_, const void *optval_, size_t optvallen_);
53
 
        int xsend (msg_t *msg_, int flags_);
54
 
        int xrecv (msg_t *msg_, int flags_);
 
50
        int xsend (zmq::msg_t *msg_);
 
51
        int xrecv (zmq::msg_t *msg_);
55
52
        bool xhas_in ();
56
53
        bool xhas_out ();
57
54
        void xread_activated (zmq::pipe_t *pipe_);
58
55
        void xwrite_activated (zmq::pipe_t *pipe_);
59
 
        void xterminated (zmq::pipe_t *pipe_);
 
56
        void xpipe_terminated (zmq::pipe_t *pipe_);
60
57
 
61
58
    protected:
62
59
 
113
110
        // If true, report EAGAIN to the caller instead of silently dropping 
114
111
        // the message targeting an unknown peer.
115
112
        bool mandatory;
 
113
        bool raw_sock;
 
114
 
 
115
        // if true, send an empty message to every connected router peer
 
116
        bool probe_router;
116
117
 
117
118
        router_t (const router_t&);
118
119
        const router_t &operator = (const router_t&);
119
120
    };
120
121
 
121
 
    class router_session_t : public session_base_t
122
 
    {
123
 
    public:
124
 
 
125
 
        router_session_t (zmq::io_thread_t *io_thread_, bool connect_,
126
 
            socket_base_t *socket_, const options_t &options_,
127
 
            const address_t *addr_);
128
 
        ~router_session_t ();
129
 
 
130
 
    private:
131
 
 
132
 
        router_session_t (const router_session_t&);
133
 
        const router_session_t &operator = (const router_session_t&);
134
 
    };
135
 
 
136
122
}
137
123
 
138
124
#endif