Skip to content
This repository

HTTPS clone URL

Subversion checkout URL

You can clone with HTTPS or Subversion.

Download ZIP
tree: 37fd1a77a6
Fetching contributors…

Cannot retrieve contributors at this time

file 104 lines (78 sloc) 3.253 kb
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104
/*
Copyright (c) 2007-2010 iMatix Corporation

This file is part of 0MQ.

0MQ is free software; you can redistribute it and/or modify it under
the terms of the Lesser GNU General Public License as published by
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
Lesser GNU General Public License for more details.

You should have received a copy of the Lesser GNU General Public License
along with this program. If not, see <http://www.gnu.org/licenses/>.
*/

#ifndef __ZMQ_SESSION_HPP_INCLUDED__
#define __ZMQ_SESSION_HPP_INCLUDED__

#include "i_inout.hpp"
#include "i_endpoint.hpp"
#include "owned.hpp"
#include "options.hpp"
#include "blob.hpp"

namespace zmq
{

    class session_t : public owned_t, public i_inout, public i_endpoint
    {
    public:

        // Creates unnamed session.
        session_t (object_t *parent_, socket_base_t *owner_,
            const options_t &options_);

        // Creates named session.
        session_t (object_t *parent_, socket_base_t *owner_,
            const options_t &options_, const blob_t &peer_identity_);

        // i_inout interface implementation.
        bool read (::zmq_msg_t *msg_);
        bool write (::zmq_msg_t *msg_);
        void flush ();
        void detach (owned_t *reconnecter_);
        class io_thread_t *get_io_thread ();
        class socket_base_t *get_owner ();
        uint64_t get_ordinal ();

        // i_endpoint interface implementation.
        void attach_pipes (class reader_t *inpipe_, class writer_t *outpipe_,
            const blob_t &peer_identity_);
        void detach_inpipe (class reader_t *pipe_);
        void detach_outpipe (class writer_t *pipe_);
        void kill (class reader_t *pipe_);
        void revive (class reader_t *pipe_);
        void revive (class writer_t *pipe_);

    private:

        ~session_t ();

        // Handlers for incoming commands.
        void process_plug ();
        void process_unplug ();
        void process_attach (struct i_engine *engine_,
            const blob_t &peer_identity_);

        // Inbound pipe, i.e. one the session is getting messages from.
        class reader_t *in_pipe;

        // This flag is true if the remainder of the message being processed
        // is still in the in pipe.
        bool incomplete_in;

        // If true, in_pipe is active. Otherwise there are no messages to get.
        bool active;

        // Outbound pipe, i.e. one the socket is sending messages to.
        class writer_t *out_pipe;

        struct i_engine *engine;

        // Session is identified by ordinal in the case when it was created
        // before connection to the peer was established and thus we are
        // unaware of peer's identity.
        uint64_t ordinal;

        // Identity of the peer.
        blob_t peer_identity;

        // Inherited socket options.
        options_t options;

        session_t (const session_t&);
        void operator = (const session_t&);
    };

}

#endif
Something went wrong with that request. Please try again.