summaryrefslogtreecommitdiffstats
path: root/knode/knnetaccess.h
blob: fb12949ee7214f02cfeb654c8f3e90d9e9e0ddf4 (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
/*
    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 TDEIO {
  class Job;
}

namespace KPIM {
  class ProgressItem;
}
using KPIM::ProgressItem;

class KNJobData;
class KNNntpClient;


class KNNetAccess : public TQObject  {

  TQ_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( TDEIO::Job *job );

    void slotCancelJob( KPIM::ProgressItem *item );

    void slotPasswordsChanged();

  private:
    /// jobs waiting for async wallet loading
    TQValueList<KNJobData*> mWalletQueue;

};

#endif