general/channel.h

Go to the documentation of this file.

/* $Id: channel.h jjs $ */
/*
   Copyright (C) 2007 by Jurjen Stellingwerff <jurjen@stwerff.xs4all.nl>
   Part of the Moros Project http://moros.sourceforge.net/

   This program is free software; you can redistribute it and/or modify
   it under the terms of the GNU General Public License.
   This program is distributed in the hope that it will be useful,
   but WITHOUT ANY WARRANTY.

   See the COPYING file for more details.
*/
#ifndef __CHANNEL_H
#define __CHANNEL_H

#include "buffer.h"
#include <list>
#include <vector>
#include <sigc++/signal.h>

typedef long size;


using namespace std;


class connection {
public:
    virtual int read(char *buffer, size length)=0;

    virtual int write(const char *buffer, size length)=0;

    virtual void close()=0;

    virtual size length()=0;
    virtual ~connection() {}
};

#define TYPE_SOCKET 1
#define TYPE_FILE 2
#define TYPE_SERVER 3
#define TYPE_IMPORT 4


class channel {
  private:
    buffer *input_;
    size to_input_;
    buffer *output_;
    long last_;
    enum READY_STATE { STATE_CLOSED, STATE_WAITING, STATE_READING, STATE_WRITING};
    int state;
    bool check_session();
    list<std::string> write_files;
    int readf;
    int writef;
    void file_poll(long time);
    int errors;


  public:
    channel(int channeltype, long time);

    void *payload;

    void close(void);
    std::string key;
    std::string value;
    std::string ip;
    int port;
    unsigned int id;

    bool next();
    bool peek(string key);
    void write(const std::string key, const std::string value);
    void write(const std::string key, const long value);
    void send();
    void fread(const std::string file);
    void fwrite(const std::string file);
    void finish();

    void poll(long time);
    connection *stream;
    bool finished;
    sigc::signal<void, channel*> handler;

    int type;

    void send_session(long time);
    class communicate *comm;
    bool lock;

};

#endif // __CHANNEL_H

Generated on Tue Jan 1 17:30:00 2008 for general/channel.h Source File by     Visit the project page on