summaryrefslogtreecommitdiff
path: root/lib
diff options
context:
space:
mode:
authorPixel <Pixel>2001-11-20 11:57:12 +0000
committerPixel <Pixel>2001-11-20 11:57:12 +0000
commit0497d21e5b7b483259642aad1f23392995863c17 (patch)
tree3be88d03b903df7e6c716ca5eb66cdfb71f11bb8 /lib
parentcca213f6493119ab3f642e08dba798f557630f53 (diff)
WaitFor, added sticky flag
Diffstat (limited to 'lib')
-rw-r--r--lib/CopyJob.cc4
-rw-r--r--lib/HttpServ.cc2
-rw-r--r--lib/ReadJob.cc4
-rw-r--r--lib/Task.cc16
4 files changed, 13 insertions, 13 deletions
diff --git a/lib/CopyJob.cc b/lib/CopyJob.cc
index 9dc9978..55fe59d 100644
--- a/lib/CopyJob.cc
+++ b/lib/CopyJob.cc
@@ -2,8 +2,8 @@
#include "General.h"
CopyJob::CopyJob(Handle * as, Handle * ad, ssize_t asiz, bool ads) : s(as), d(ad), siz(asiz), ds(ads), cursiz(0), r(0) {
- WaitFor(s);
- WaitFor(d);
+ WaitFor(s, W4_STICKY);
+ WaitFor(d, W4_STICKY);
}
CopyJob::~CopyJob() { }
diff --git a/lib/HttpServ.cc b/lib/HttpServ.cc
index fe48f54..cda572d 100644
--- a/lib/HttpServ.cc
+++ b/lib/HttpServ.cc
@@ -371,7 +371,7 @@ HttpServ::HttpServ(Action * ap, int port, const String & nname) throw (GeneralEx
}
Listener.SetNonBlock();
- WaitFor(&Listener);
+ WaitFor(&Listener, W4_STICKY);
cerr << "Mini HTTP-Server '" << name << "' ready and listening for port " << port << endl;
}
diff --git a/lib/ReadJob.cc b/lib/ReadJob.cc
index 9f037d9..f2749bb 100644
--- a/lib/ReadJob.cc
+++ b/lib/ReadJob.cc
@@ -2,8 +2,8 @@
#include "HttpServ.h"
ReadJob::ReadJob(Handle * as, Handle * ad) : s(as), d(ad) {
- WaitFor(s);
- WaitFor(d);
+ WaitFor(s, W4_STICKY);
+ WaitFor(d, W4_STICKY);
}
ReadJob::~ReadJob() { }
diff --git a/lib/Task.cc b/lib/Task.cc
index 4978bde..a56a2ff 100644
--- a/lib/Task.cc
+++ b/lib/Task.cc
@@ -49,20 +49,20 @@ void Task::Suspend() throw (GeneralException) {
throw TaskSwitch();
}
-void Task::WaitFor(Handle * h) {
- w4ha.push_back(h);
+void Task::WaitFor(Handle * h, int flags) {
+ w4ha.push_back(w4ha_t(h, flags));
}
-void Task::WaitFor(Task * t) {
- w4ta.push_back(t);
+void Task::WaitFor(Task * t, int flags) {
+ w4ta.push_back(w4ta_t(t, flags));
}
-void Task::WaitFor(pid_t p) {
- w4pr.push_back(p);
+void Task::WaitFor(pid_t p, int flags) {
+ w4pr.push_back(w4pr_t(p, flags));
}
-void Task::WaitFor(timeval t) {
- w4to.push_back(t);
+void Task::WaitFor(timeval t, int flags) {
+ w4to.push_back(w4to_t(t, flags));
}
void Task::SetBurst() {