Open Source Projects Europe

 *   You should have received a copy of the GNU General Public License

 *   You should have received a copy of the GNU General Public License

 *   along with this program; if not, write to the

 *   along with this program; if not, write to the

 *   Free Software Foundation, Inc.,

 *   Free Software Foundation, Inc.,

 *   59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.

 *   59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.

 */

 */

#include <sys/time.h>

#include <sys/time.h>

#include <map>

#include <map>

#include <string>

#include <string>

/// A set of classes to manage client-server communication over a

/// A set of classes to manage client-server communication over a

/// connection-oriented network, or a pipe.

/// connection-oriented network, or a pipe.

///

///

/// The listening/connection-accepting code currently only uses

/// The listening/connection-accepting code currently only uses

/// timeout-protected/asynchronous io using a given fd (ie a pipe

/// timeout-protected/asynchronous io using a given fd (ie a pipe

/// descriptor)

/// descriptor)

/// Base class for all network endpoints:

/// Base class for all network endpoints:

class Netcon;

class Netcon;

class SelectLoop;

class SelectLoop;

class Netcon {

class Netcon {

public:

public:

    enum Event {NETCONPOLL_READ = 0x1, NETCONPOLL_WRITE = 0x2};

    enum Event {NETCONPOLL_READ = 0x1, NETCONPOLL_WRITE = 0x2};

    /// Read a line of text on an ascii connection. Returns -1 or byte count

    /// Read a line of text on an ascii connection. Returns -1 or byte count

    /// including final 0. \n is kept

    /// including final 0. \n is kept

    virtual int getline(char *buf, int cnt, int timeo = -1);

    virtual int getline(char *buf, int cnt, int timeo = -1);

    /// Set handler to be called when the connection is placed in the

    /// Set handler to be called when the connection is placed in the

    /// selectloop and an event occurs.

    /// selectloop and an event occurs.

        m_user = user;

        m_user = user;

    }

    }

private:

private:

    char *m_buf;    // Buffer. Only used when doing getline()s

    char *m_buf;    // Buffer. Only used when doing getline()s

    char *m_bufbase;    // Pointer to current 1st byte of useful data

    char *m_bufbase;    // Pointer to current 1st byte of useful data

    int m_bufbytes; // Bytes of data.

    int m_bufbytes; // Bytes of data.

    int m_bufsize;  // Total buffer size

    int m_bufsize;  // Total buffer size

    virtual int cando(Netcon::Event reason); // Selectloop slot

    virtual int cando(Netcon::Event reason); // Selectloop slot

};

};

/// Network endpoint, client side.

/// Network endpoint, client side.

class NetconCli : public NetconData {

class NetconCli : public NetconData {

    /// connections. It will usually call NetconServLis::accept(), and

    /// connections. It will usually call NetconServLis::accept(), and

    /// insert the new connection in the selectloop.

    /// insert the new connection in the selectloop.

    virtual int cando(Netcon::Event reason);

    virtual int cando(Netcon::Event reason);

    // Empty if port was numeric, else service name or socket path

    // Empty if port was numeric, else service name or socket path

    std::string m_serv;

private:

private:

#ifdef NETCON_ACCESSCONTROL

#ifdef NETCON_ACCESSCONTROL

    int permsinit;

    int permsinit;

    struct intarrayparam okaddrs;

    struct intarrayparam okaddrs;