net_io_task.h

Go to the documentation of this file.

/*
 * Copyright (c) 2013-2014 ADTECH GmbH
 * Licensed under MIT (https://github.com/adtechlabs/libtasks/blob/master/COPYING)
 *
 * Author: Andreas Pohl
 */

#ifndef _TASKS_NET_IO_TASK_H_
#define _TASKS_NET_IO_TASK_H_

#include <tasks/io_task_base.h>
#include <tasks/net/socket.h>

namespace tasks {

class worker;

class net_io_task : public io_task_base {
  public:
    net_io_task(int events) : io_task_base(events) {}
    net_io_task(net::socket& socket, int events);
    virtual ~net_io_task();

    inline std::string get_string() const {
        std::ostringstream os;
        os << "net_io_task(" << this << "," << iob().fd() << ":" << events() << ")";
        return os.str();
    }

    inline net::socket& socket() {
        return m_socket;
    }
    inline const net::socket& socket() const {
        return m_socket;
    }

    static void add_task(net_io_task* task);

  protected:
    void add_task(worker* worker, net_io_task* task);

    io_base& iob() {
        return m_socket;
    }
    const io_base& iob() const {
        return m_socket;
    }
    void disable_auto_close() {
        m_auto_close = false;
    }

  private:
    net::socket m_socket;
    bool m_auto_close = true;
};

}  // tasks

#endif  // _TASKS_NET_IO_TASK_H_