summaryrefslogtreecommitdiff
path: root/apt-pkg/acquire-worker.h
diff options
context:
space:
mode:
authorArch Librarian <arch@canonical.com>2004-09-20 16:51:09 +0000
committerArch Librarian <arch@canonical.com>2004-09-20 16:51:09 +0000
commit0a8a80e58374771acc225fe1e08ed8e0fe0016cc (patch)
treeafa40f2a73b369e2ba930e47c961992170a669b7 /apt-pkg/acquire-worker.h
parent93641593cafac296b9072288d8ef9e1a526d745b (diff)
Sync
Author: jgg Date: 1998-10-22 04:56:38 GMT Sync
Diffstat (limited to 'apt-pkg/acquire-worker.h')
-rw-r--r--apt-pkg/acquire-worker.h26
1 files changed, 22 insertions, 4 deletions
diff --git a/apt-pkg/acquire-worker.h b/apt-pkg/acquire-worker.h
index 28072373f..d128ec8b2 100644
--- a/apt-pkg/acquire-worker.h
+++ b/apt-pkg/acquire-worker.h
@@ -1,6 +1,6 @@
// -*- mode: cpp; mode: fold -*-
// Description /*{{{*/
-// $Id: acquire-worker.h,v 1.2 1998/10/20 02:39:14 jgg Exp $
+// $Id: acquire-worker.h,v 1.3 1998/10/22 04:56:42 jgg Exp $
/* ######################################################################
Acquire Worker - Worker process manager
@@ -21,10 +21,15 @@
// Interfacing to the method process
class pkgAcquire::Worker
{
+ friend pkgAcquire;
+
protected:
friend Queue;
- Worker *Next;
+ /* Linked list starting at a Queue and a linked list starting
+ at Acquire */
+ Worker *NextQueue;
+ Worker *NextAcquire;
// The access association
Queue *OwnerQ;
@@ -35,27 +40,40 @@ class pkgAcquire::Worker
pid_t Process;
int InFd;
int OutFd;
+ bool InReady;
+ bool OutReady;
// Various internal things
bool Debug;
vector<string> MessageQueue;
-
+ string OutQueue;
+
// Private constructor helper
void Construct();
// Message handling things
bool ReadMessages();
bool RunMessages();
+ bool InFdReady();
+ bool OutFdReady();
// The message handlers
bool Capabilities(string Message);
+ bool SendConfiguration();
+
+ bool MethodFailure();
public:
+ pkgAcquire::Queue::QItem *CurrentItem;
+
+ string Status;
+
// Load the method and do the startup
+ bool QueueItem(pkgAcquire::Queue::QItem *Item);
bool Start();
- Worker(Queue *OwnerQ,string Access);
+ Worker(Queue *OwnerQ,MethodConfig *Config);
Worker(MethodConfig *Config);
~Worker();
};