00001
00002
00003
00004
00005
00006
00007
00008
00009
00010
00011
00012
00013
00014
00015
00016
00017
00018
00019
00020
00021
00022 #ifndef __connection_h__
00023 #define __connection_h__
00024
00025 #include <tdelibs_export.h>
00026
00027 #include <sys/types.h>
00028
00029 #include <stdio.h>
00030 #include <tqptrlist.h>
00031 #include <tqobject.h>
00032
00033 class TDESocket;
00034 class TQSocketNotifier;
00035
00036 namespace TDEIO {
00037
00038 struct TDEIO_EXPORT Task {
00039 int cmd;
00040 TQByteArray data;
00041 };
00042
00049 class TDEIO_EXPORT Connection : public TQObject
00050 {
00051 Q_OBJECT
00052 public:
00057 Connection();
00058 virtual ~Connection();
00059
00065 void init(TDESocket *sock);
00073 void init(int fd_in, int fd_out);
00074 void connect(TQObject *receiver = 0, const char *member = 0);
00076 void close();
00077
00082 int fd_from() const { return fd_in; }
00087 int fd_to() const { return fileno( f_out ); }
00088
00094 bool inited() const { return (fd_in != -1) && (f_out != 0); }
00095
00101 void send(int cmd, const TQByteArray &arr = TQByteArray());
00102
00109 bool sendnow( int _cmd, const TQByteArray &data );
00110
00119 int read( int* _cmd, TQByteArray &data );
00120
00124 void suspend();
00125
00129 void resume();
00130
00135 bool suspended() const { return m_suspended; }
00136
00137 protected slots:
00138 void dequeue();
00139
00140 protected:
00141
00142
00143 private:
00144 int fd_in;
00145 FILE *f_out;
00146 TDESocket *socket;
00147 TQSocketNotifier *notifier;
00148 TQObject *receiver;
00149 const char *member;
00150 TQPtrList<Task> tasks;
00151 bool m_suspended;
00152 private:
00153 class ConnectionPrivate* d;
00154 };
00155
00156 }
00157
00158 #endif