home *** CD-ROM | disk | FTP | other *** search
/ PC World 2000 February / PCWorld_2000-02_cd.bin / live / usr / include / apt-pkg / acquire-worker.h < prev    next >
C/C++ Source or Header  |  1999-06-21  |  2KB  |  89 lines
  1. // -*- mode: cpp; mode: fold -*-
  2. // Description                                /*{{{*/
  3. // $Id: acquire-worker.h,v 1.10 1999/05/23 06:47:43 jgg Exp $
  4. /* ######################################################################
  5.  
  6.    Acquire Worker - Worker process manager
  7.    
  8.    Each worker class is associated with exaclty one subprocess.
  9.    
  10.    ##################################################################### */
  11.                                     /*}}}*/
  12. #ifndef PKGLIB_ACQUIRE_WORKER_H
  13. #define PKGLIB_ACQUIRE_WORKER_H
  14.  
  15. #include <apt-pkg/acquire.h>
  16.  
  17. #ifdef __GNUG__
  18. #pragma interface "apt-pkg/acquire-worker.h"
  19. #endif 
  20.  
  21. // Interfacing to the method process
  22. class pkgAcquire::Worker
  23. {
  24.    friend pkgAcquire;
  25.    
  26.    protected:
  27.    friend Queue;
  28.  
  29.    /* Linked list starting at a Queue and a linked list starting
  30.       at Acquire */
  31.    Worker *NextQueue;
  32.    Worker *NextAcquire;
  33.    
  34.    // The access association
  35.    Queue *OwnerQ;
  36.    pkgAcquireStatus *Log;
  37.    MethodConfig *Config;
  38.    string Access;
  39.  
  40.    // This is the subprocess IPC setup
  41.    pid_t Process;
  42.    int InFd;
  43.    int OutFd;
  44.    bool InReady;
  45.    bool OutReady;
  46.    
  47.    // Various internal things
  48.    bool Debug;
  49.    vector<string> MessageQueue;
  50.    string OutQueue;
  51.    
  52.    // Private constructor helper
  53.    void Construct();
  54.    
  55.    // Message handling things
  56.    bool ReadMessages();
  57.    bool RunMessages();
  58.    bool InFdReady();
  59.    bool OutFdReady();
  60.    
  61.    // The message handlers
  62.    bool Capabilities(string Message);
  63.    bool SendConfiguration();
  64.    bool MediaChange(string Message);
  65.    
  66.    bool MethodFailure();
  67.    void ItemDone();
  68.    
  69.    public:
  70.    
  71.    // The curent method state
  72.    pkgAcquire::Queue::QItem *CurrentItem;
  73.    string Status;
  74.    unsigned long CurrentSize;
  75.    unsigned long TotalSize;
  76.    unsigned long ResumePoint;
  77.    
  78.    // Load the method and do the startup 
  79.    bool QueueItem(pkgAcquire::Queue::QItem *Item);
  80.    bool Start();
  81.    void Pulse();
  82.    
  83.    Worker(Queue *OwnerQ,MethodConfig *Config,pkgAcquireStatus *Log);
  84.    Worker(MethodConfig *Config);
  85.    ~Worker();
  86. };
  87.  
  88. #endif
  89.