/* KNode, the KDE newsreader Copyright (c) 1999-2005 the KNode authors. See file AUTHORS for details This program is free software; you can redistribute it and/or modify it under the terms of the GNU General Public License as published by the Free Software Foundation; either version 2 of the License, or (at your option) any later version. You should have received a copy of the GNU General Public License along with this program; if not, write to the Free Software Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, US */ #ifndef KNNETACCESS_H #define KNNETACCESS_H #include <tqobject.h> #include <tqmutex.h> #include <tqvaluelist.h> class TQSocketNotifier; namespace KIO { class Job; } namespace KPIM { class ProgressItem; } using KPIM::ProgressItem; class KNJobData; class KNNntpClient; class KNNetAccess : public TQObject { Q_OBJECT public: KNNetAccess(TQObject *parent=0, const char *name=0); ~KNNetAccess(); void addJob(KNJobData *job); /** type==0 => all jobs */ void stopJobsNntp(int type); /** type==0 => all jobs */ void stopJobsSmtp(int type); void cancelAllJobs(); /** current statusbar message */ TQString currentMsg() const { return currMsg; } TQMutex& nntpMutex() { return nntp_Mutex; } protected: /** passes a signal through the ipc-pipe to the net-thread */ void triggerAsyncThread(int pipeFd); void startJobNntp(); void startJobSmtp(); void threadDoneNntp(); void threadDoneSmtp(); /** stores the current status message, so that it can be restored by the mainwindow */ TQString currMsg; KNNntpClient *nntpClient; TQValueList<KNJobData*> nntpJobQueue, smtpJobQueue; KNJobData *currentNntpJob, *currentSmtpJob; TQMutex nntp_Mutex; int nntpInPipe[2], nntpOutPipe[2]; TQSocketNotifier *nntpNotifier; protected slots: void slotThreadSignal(int i); signals: void netActive(bool); private: void cancelCurrentNntpJob( int type = 0 ); void cancelCurrentSmtpJob( int type = 0 ); /** Update activitiy status, i.e. emit netActive signal. */ void updateStatus(); private slots: void slotJobResult( KIO::Job *job ); void slotCancelJob( KPIM::ProgressItem *item ); void slotPasswordsChanged(); private: /// jobs waiting for async wallet loading TQValueList<KNJobData*> mWalletQueue; }; #endif