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 <kdelibs_export.h> 00026 00027 #include <sys/types.h> 00028 00029 #include <stdio.h> 00030 #include <qptrlist.h> 00031 #include <qobject.h> 00032 00033 class KSocket; 00034 class QSocketNotifier; 00035 00036 namespace KIO { 00037 00038 struct KIO_EXPORT Task { 00039 int cmd; 00040 QByteArray data; 00041 }; 00042 00049 class KIO_EXPORT Connection : public QObject 00050 { 00051 Q_OBJECT 00052 public: 00057 Connection(); 00058 virtual ~Connection(); 00059 00065 void init(KSocket *sock); 00073 void init(int fd_in, int fd_out); // Used by KDENOX 00074 void connect(QObject *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 QByteArray &arr = QByteArray()); 00102 00109 bool sendnow( int _cmd, const QByteArray &data ); 00110 00119 int read( int* _cmd, QByteArray &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 KSocket *socket; 00147 QSocketNotifier *notifier; 00148 QObject *receiver; 00149 const char *member; 00150 QPtrList<Task> tasks; 00151 bool m_suspended; 00152 private: 00153 class ConnectionPrivate* d; 00154 }; 00155 00156 } 00157 00158 #endif