← Back to branch summary

~ubuntu-branches/ubuntu/maverick/zeromq/maverick

« back to all changes in this revision

Viewing changes to src/pub.hpp

  • Committer: Bazaar Package Importer
  • Author(s): Adrian von Bidder
  • Date: 2010-03-17 10:43:40 UTC
  • mfrom: (1.1.1 upstream)
  • Revision ID: james.westby@ubuntu.com-20100317104340-un1ne0oqe16w8eaq
Tags: 2.0.6beta.dfsg-1
http://bugs.debian.org/567513
http://bugs.debian.org/567848
* New upstream version.
  - Source doesn't include non-C/C++ language bindings anymore.
  - New versioning: 2.0.6 is official upstream version which is a beta.
* Repacked orig tar: removed non-free RFC documents (closes: #567513)
* Improved/corrected description and copyright file, added bzip2 build
  dependency.  Thanks to feedback from zeromq mailing list.
* Disable OpenPGM on non-x86 architectures (closes: #567848)

Show diffs side-by-side

added added

removed removed

Lines of Context:
src/pub.hpp
34
34
        ~pub_t ();
35
35
 
36
36
        //  Overloads of functions from socket_base_t.
37
 
        void xattach_pipes (class reader_t *inpipe_, class writer_t *outpipe_);
 
37
        void xattach_pipes (class reader_t *inpipe_, class writer_t *outpipe_,
 
38
            const blob_t &peer_identity_);
38
39
        void xdetach_inpipe (class reader_t *pipe_);
39
40
        void xdetach_outpipe (class writer_t *pipe_);
40
41
        void xkill (class reader_t *pipe_);
41
42
        void xrevive (class reader_t *pipe_);
 
43
        void xrevive (class writer_t *pipe_);
42
44
        int xsetsockopt (int option_, const void *optval_, size_t optvallen_);
43
45
        int xsend (zmq_msg_t *msg_, int flags_);
44
 
        int xflush ();
45
46
        int xrecv (zmq_msg_t *msg_, int flags_);
46
47
        bool xhas_in ();
47
48
        bool xhas_out ();
52
53
        typedef yarray_t <class writer_t> out_pipes_t;
53
54
        out_pipes_t out_pipes;
54
55
 
 
56
        //  Pointer to the pipe we are waiting for to became writable
 
57
        //  again; NULL if tha last send operation was successful.
 
58
        class writer_t *stalled_pipe;
 
59
 
 
60
        //  Check whether we can write a message to all pipes.
 
61
        bool check_write ();
 
62
 
55
63
        pub_t (const pub_t&);
56
64
        void operator = (const pub_t&);
57
65
    };