connection.h
00001 // -*- c++ -*- 00002 /* This file is part of the KDE libraries 00003 Copyright (C) 2000 Stephan Kulow <coolo@kde.org> 00004 David Faure <faure@kde.org> 00005 00006 This library is free software; you can redistribute it and/or 00007 modify it under the terms of the GNU Library General Public 00008 License as published by the Free Software Foundation; either 00009 version 2 of the License, or (at your option) any later version. 00010 00011 This library is distributed in the hope that it will be useful, 00012 but WITHOUT ANY WARRANTY; without even the implied warranty of 00013 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU 00014 Library General Public License for more details. 00015 00016 You should have received a copy of the GNU Library General Public License 00017 along with this library; see the file COPYING.LIB. If not, write to 00018 the Free Software Foundation, Inc., 51 Franklin Street, Fifth Floor, 00019 Boston, MA 02110-1301, USA. 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); // Used by KDENOX 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