pgm_sender.hpp 2.72 KB
Newer Older
malosek's avatar
malosek committed
1
/*
2 3
    Copyright (c) 2007-2011 iMatix Corporation
    Copyright (c) 2007-2011 Other contributors as noted in the AUTHORS file
malosek's avatar
malosek committed
4 5 6 7

    This file is part of 0MQ.

    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
malosek's avatar
malosek committed
9 10 11 12 13 14
    the Free Software Foundation; either version 3 of the License, or
    (at your option) any later version.

    0MQ is distributed in the hope that it will be useful,
    but WITHOUT ANY WARRANTY; without even the implied warranty of
    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
15
    GNU Lesser General Public License for more details.
malosek's avatar
malosek committed
16

17
    You should have received a copy of the GNU Lesser General Public License
malosek's avatar
malosek committed
18 19 20
    along with this program.  If not, see <http://www.gnu.org/licenses/>.
*/

malosek's avatar
malosek committed
21 22
#ifndef __ZMQ_PGM_SENDER_HPP_INCLUDED__
#define __ZMQ_PGM_SENDER_HPP_INCLUDED__
malosek's avatar
malosek committed
23 24 25

#include "platform.hpp"

malosek's avatar
malosek committed
26
#if defined ZMQ_HAVE_OPENPGM
malosek's avatar
malosek committed
27

28 29 30 31
#ifdef ZMQ_HAVE_WINDOWS
#include "windows.hpp"
#endif

malosek's avatar
malosek committed
32 33 34 35 36
#include "stdint.hpp"
#include "io_object.hpp"
#include "i_engine.hpp"
#include "options.hpp"
#include "pgm_socket.hpp"
37
#include "encoder.hpp"
malosek's avatar
malosek committed
38 39 40 41 42 43 44 45

namespace zmq
{

    class pgm_sender_t : public io_object_t, public i_engine
    {

    public:
Martin Sustrik's avatar
Martin Sustrik committed
46

47
        pgm_sender_t (class io_thread_t *parent_, const options_t &options_);
malosek's avatar
malosek committed
48 49
        ~pgm_sender_t ();

50
        int init (bool udp_encapsulation_, const char *network_);
malosek's avatar
malosek committed
51 52

        //  i_engine interface implementation.
53
        void plug (class io_thread_t *io_thread_, struct i_inout *inout_);
malosek's avatar
malosek committed
54
        void unplug ();
55 56 57
        void terminate ();
        void activate_in ();
        void activate_out ();
malosek's avatar
malosek committed
58 59 60 61

        //  i_poll_events interface implementation.
        void in_event ();
        void out_event ();
62
        void timer_event (int token);
malosek's avatar
malosek committed
63 64 65

    private:

66 67 68 69
        //  TX and RX timeout timer ID's.
        enum {tx_timer_id = 0xa0, rx_timer_id = 0xa1};

        //  Timers are running.
70 71
        bool has_tx_timer;
        bool has_rx_timer;
72

malosek's avatar
malosek committed
73
        //  Message encoder.
74
        encoder_t encoder;
malosek's avatar
malosek committed
75 76 77 78 79 80 81 82 83 84

        //  PGM socket.
        pgm_socket_t pgm_socket;

        //  Socket options.
        options_t options;

        //  Poll handle associated with PGM socket.
        handle_t handle;
        handle_t uplink_handle;
malosek's avatar
malosek committed
85
        handle_t rdata_notify_handle;
86
        handle_t pending_notify_handle;
malosek's avatar
malosek committed
87 88 89 90 91 92 93

        //  Output buffer from pgm_socket.
        unsigned char *out_buffer;
        
        //  Output buffer size.
        size_t out_buffer_size;

Martin Sustrik's avatar
Martin Sustrik committed
94 95
        //  Number of bytes in the buffer to be written to the socket.
        //  If zero, there are no data to be sent.
malosek's avatar
malosek committed
96 97 98
        size_t write_size;

        pgm_sender_t (const pgm_sender_t&);
99
        const pgm_sender_t &operator = (const pgm_sender_t&);
malosek's avatar
malosek committed
100 101 102 103 104 105
    };

}
#endif

#endif