libplumbing/endpoint/client.h

Go to the documentation of this file.

//
// plumbing - C++ wrapper facades for Berkeley sockets
// Copyright (C) 2009 Peter Miller
//
// This program is free software; you can redistribute it and/or modify it
// under the terms of the GNU General Public License, version 3, as published
// by the Free Software Foundation.
//
// This program 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 GNU General Public License for
// more details.
//
// You should have received a copy of the GNU General Public License along
// with this program. If not, see <http://www.gnu.org/licenses/>.
//

#ifndef LIBPLUMBING_ENDPOINT_CLIENT_H
#define LIBPLUMBING_ENDPOINT_CLIENT_H

#include <ctime>
#include <deque>

#include <libplumbing/endpoint.h>

namespace plumbing {

class endpoint_client:
    public endpoint
{
public:
    virtual ~endpoint_client();

protected:
    endpoint_client(const std::string &hostname, int port);

    endpoint_client(const std::string &hostname, const std::string &port);

public:
    void write(const std::string &text);

    bool more_to_send() const { return !write_queue.empty(); }

    bool is_connected() const { return (fd >= 0 && !connecting); }

    int get_port() const { return port; }

    const std::string &get_host() const { return hostname; }

protected:
    // See base class for documentation.
    int get_read_file_descriptor();

    // See base class for documentation.
    void process_read();

    // See base class for documentation.
    int get_write_file_descriptor();

    // See base class for documentation.
    void process_write();

    virtual void data_received(const void *data, size_t nbytes) = 0;

private:
    std::string hostname;

    int port;

    void *sock_addr;

    int sock_addr_size;

    bool connecting;

    time_t retry_after;

    typedef std::deque<std::string> write_queue_t;

    write_queue_t write_queue;

    void try_to_connect();

    endpoint_client();

    endpoint_client(const endpoint_client &);

    endpoint_client &operator=(const endpoint_client &);
};

}

#endif // LIBPLUMBING_ENDPOINT_CLIENT_H
// vim: set ts=8 sw=4 et

---