/include/nqueue.h

/* $Id: nqueue.h,v 1.41 2003/10/01 19:54:16 ndiin Exp $
 *
 * nqueue.h NQueue (and friends) class declaration.
 *
 * Copyright 2002-2003 Eric Andresen
 * See COPYING for license information
 */

#ifndef NQUEUE_H
#define NQUEUE_H

#include "nhostinfo.h"
#include "nnet.h"

#include <qlistview.h>
#include <qurl.h>
#include <qdatetime.h>
#include <qmap.h>
#include <qintdict.h>
#include <qpopupmenu.h>
#include <nqptrlist.h>

class NNet;
class QUrlInfo;

class NQueueHost : public QListViewItem
{
public:
   NQueueHost( QListView *parent, int hostId, NHostInfo hostInfo);
   virtual ~NQueueHost();
   void dieNow();

   virtual QString text( int c ) const;
   virtual const QPixmap* pixmap( int c ) const;
   virtual int rtti() const { return 2301; }

   const int id() const { return _id; }
   const NHostInfo hostInfo() const { return _hostInfo; }
   const bool isDone() const { return _done; }
   const bool inUse() const { return _inuse; }
   const bool failed() const { return _failed; }
   const int numCurrentConns() const { return _currentConnections; }

   inline void setInUse(bool s = true);
   inline void setDone(bool s = true);
   inline void setFailed(bool s = true) { _failed = s; }
   inline void incCurrentConns();
   inline void decCurrentConns(); 
   inline void setXferStats(uint size, int time, double rate)
      { _xferSize = size; _xferTime = time; _xferRate = rate; }
   void reset();
   void childDone(bool removed = false);
   void addChild();
   void childReset();
   void killChildren(int prune = 0);

private:
   int _id;                    
   NHostInfo _hostInfo;             
   bool _inuse;                
   bool _done;                 
   bool _failed;               
   QDateTime _placementTime;   
   QDateTime _startTime;       
   QDateTime _finishTime;      
   uint _xferSize;             
   double _xferRate;           
   int _xferTime;              
   int _currentConnections;    
   int childRemain;            
   int childTotal;             
};

class NQueueItem : public QListViewItem
{
public:
   NQueueItem( QListViewItem *parent, int id,
      int hid, QUrl src, QString srcName,
      QUrl dst, QString dstName,
      uint size, bool dir = false);
   virtual ~NQueueItem();
   void dieNow();

   virtual int compare( QListViewItem * i, int col, bool ascending ) const;
   virtual QString text( int c ) const;
   virtual const QPixmap* pixmap( int c ) const;
   virtual int rtti() const { return 2302; }

   const int id() const { return _id; }
   const int hostid() const { return _hostid; }
   const QUrl source() const { return _source; }
   const QUrl dest() const { return _dest; }
   const QString sourceFileName() const { return _sourceName; }
   const QString destFileName() const { return _destName; }
   const uint size() const { return _totalSize; }
   const uint progress() const { return _currentSize; }
   const bool isDir() const { return _dir; }
   const bool isDone() const { return _done;; }
   const bool inUse() const { return _inuse; }
   const bool failed() const { return _failed; }
   const int whichRemote() const;

   void totals(int *mytot, int *myrem);
   void childReset();
   void killChildren(int prune = 0);
   void setProgress(uint progress) { _currentSize = progress; }
   void setInUse(bool s = true);
   void setDone(bool s = true);
   void setFailed(bool s = true);
   void childDone(bool removed = false);
   void addChild();
   void reset(int *mytot = 0, int *myrem = 0);
   void setXferStats(uint size, int time, double rate)
      { _xferSize = size; _xferTime = time; _xferRate = rate; }

private:
   int _id;                    
   int _hostid;                
   QUrl _source;               
   QUrl _dest;                 
   QString _sourceName;        
   QString _destName;          
   uint _totalSize;            
   uint _currentSize;          
   bool _dir;                  
   bool _inuse;                
   bool _done;                 
   bool _failed;               
   QDateTime _placementTime;   
   QDateTime _startTime;       
   QDateTime _finishTime;      
   uint _xferSize;             
   double _xferRate;           
   int _xferTime;              
   int childRemain;            
   int childTotal;             
};

class NQueue : public QListView
{
   Q_OBJECT
public:
   NQueue(QWidget *parent = 0, const char *name = 0, WFlags f = 0);
   virtual ~NQueue();

   enum Side { Left=0, Right, Other };
   void cd(Side side, QString path);
   void get(Side side, QString name, QString localname);
   void put(Side side, QString name, QString localname);
   void queue(const QUrl srcUrl, const QUrlInfo srcInfo, const QUrl dstUrl, const QString dstName);
   NNet *newNNet(Side side, QString protocol);
   void delNNet(Side side);

public slots:
   void startQueue();
   void stopQueue();
   void pauseQueue();

signals:
   void log(NNet::logType, QString);

private:
   int addObject(QString);
   void setupSlots(NQueue::Side, NNet *);
   int matchHostId(NHostInfo hostInfo, bool create = true);
   void scheduleItem(NQueueItem *item);
   void scheduleItemPool(NQueueItem *item);
   void scheduleItemGui(NQueueItem *item);
   void scheduleNextItem(int nnetId);
   NQPtrList selectedItems() const;
   int checkConnections(NHostInfo checkHost);
   void autoClear(QListViewItem *litem);

private slots:
   void scheduleNextItem(NQueueHost *nextHost = NULL);
   void slotConnected(int, NHostInfo);
   void slotConnectionClosed(int, NHostInfo);
   void slotDirectoryListing(int, const QValueList<QUrlInfo> &);
   void slotLoginComplete(int);
   void slotTransferProgress(int, unsigned int, unsigned int);
   void slotTransferComplete(int, bool, uint, int, double);
   void slotMenuItemActivated(int);
   void slotContextMenuRequested( QListViewItem *, const QPoint&, int );
   void slotLog(int, NNet::logType, QString);

private:
   NNet *leftNNet, *rightNNet;

   int lastId;
   int nnetId;
   int hostId;
   QIntDict<NNet> objList;
   QIntDict<NQueueHost> hostDict;
   QIntDict<NQueueItem> itemDict;
   QMap<int, int> queueMap;
   QMap< int, QValueList<int> > hostMap;
   QPopupMenu *context;
   int numXfered;
   int numInUse;
   unsigned long totalSizeXfered;
   QDateTime queueStart;
   bool inProgress;
   int currConns;

   friend class NQueueItem;
   friend class NQueueHost;

   enum MenuIds {
      Remove=0,
      Reset,
      Prune,
      Clear,
      Start
   };
};

#endif // NQUEUE_H

---