acquire-worker.h

Go to the documentation of this file.

// -*- mode: cpp; mode: fold -*-
// Description                                                          /*{{{*/
/* ######################################################################
 
   Acquire Worker - Worker process manager
 
   Each worker class is associated with exactly one subprocess.
 
   ##################################################################### */
                                                                        /*}}}*/
 
#ifndef PKGLIB_ACQUIRE_WORKER_H
#define PKGLIB_ACQUIRE_WORKER_H
 
#include <apt-pkg/acquire.h>
#include <apt-pkg/weakptr.h>
 
#include <string>
#include <vector>
#include <sys/types.h>
 
class APT_PUBLIC pkgAcquire::Worker : public WeakPointable
{
   void * const d;
  
   friend class pkgAcquire;
   
   protected:
   friend class Queue;
 
   Worker *NextQueue;
 
   Worker *NextAcquire;
   
   Queue *OwnerQ;
 
   pkgAcquireStatus *Log;
 
   MethodConfig *Config;
 
   std::string Access;
 
   pid_t Process;
 
   int InFd;
 
   int OutFd;
 
   int PrivSepSocketFd;
   int PrivSepSocketFdChild;
 
   bool InReady;
 
   bool OutReady;
   
   bool Debug;
 
   std::vector<std::string> MessageQueue;
 
   std::string OutQueue;
   
   void Construct();
   
   bool ReadMessages();
 
   bool RunMessages();
 
   bool InFdReady();
 
   bool OutFdReady();
   
   bool Capabilities(std::string Message);
 
   bool SendConfiguration();
 
   bool MediaChange(std::string Message);
   
   bool MethodFailure();
 
   void ItemDone();
   
   public:
   
   pkgAcquire::Queue::QItem *CurrentItem;
 
   std::string Status;
 
   bool QueueItem(pkgAcquire::Queue::QItem *Item);
   APT_HIDDEN bool ReplyAux(pkgAcquire::ItemDesc const &Item);
 
   bool Start();
 
   void Pulse();
 
   inline const MethodConfig *GetConf() const {return Config;};
 
   Worker(Queue *OwnerQ,MethodConfig *Config,pkgAcquireStatus *Log);
 
   explicit Worker(MethodConfig *Config);
 
   virtual ~Worker();
 
private:
   APT_HIDDEN void PrepareFiles(char const * const caller, pkgAcquire::Queue::QItem const * const Itm);
   APT_HIDDEN void HandleFailure(std::vector<pkgAcquire::Item *> const &ItmOwners,
                                 pkgAcquire::MethodConfig *const Config, pkgAcquireStatus *const Log,
                                 std::string const &Message, bool const errTransient, bool const errAuthErr);
};
 
#endif