← Back to branch summary

~ubuntu-branches/ubuntu/trusty/zeromq3/trusty

« back to all changes in this revision

Viewing changes to src/pgm_sender.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/pgm_sender.hpp
1
1
/*
2
 
    Copyright (c) 2009-2011 250bpm s.r.o.
3
 
    Copyright (c) 2007-2009 iMatix Corporation
4
 
    Copyright (c) 2010-2011 Miru Limited
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
 
36
33
#include "i_engine.hpp"
37
34
#include "options.hpp"
38
35
#include "pgm_socket.hpp"
39
 
#include "encoder.hpp"
 
36
#include "v1_encoder.hpp"
 
37
#include "msg.hpp"
40
38
 
41
39
namespace zmq
42
40
{
58
56
        void plug (zmq::io_thread_t *io_thread_,
59
57
            zmq::session_base_t *session_);
60
58
        void terminate ();
61
 
        void activate_in ();
62
 
        void activate_out ();
 
59
        void restart_input ();
 
60
        void restart_output ();
 
61
        void zap_msg_available () {}
63
62
 
64
63
        //  i_poll_events interface implementation.
65
64
        void in_event ();
78
77
        bool has_tx_timer;
79
78
        bool has_rx_timer;
80
79
 
 
80
        session_base_t *session;
 
81
 
81
82
        //  Message encoder.
82
 
        encoder_t encoder;
 
83
        v1_encoder_t encoder;
 
84
 
 
85
        msg_t msg;
 
86
 
 
87
        //  Keeps track of message boundaries.
 
88
        bool more_flag;
83
89
 
84
90
        //  PGM socket.
85
91
        pgm_socket_t pgm_socket;