diff options
author | Pixel <Pixel> | 2001-11-20 11:57:12 +0000 |
---|---|---|
committer | Pixel <Pixel> | 2001-11-20 11:57:12 +0000 |
commit | 0497d21e5b7b483259642aad1f23392995863c17 (patch) | |
tree | 3be88d03b903df7e6c716ca5eb66cdfb71f11bb8 /lib | |
parent | cca213f6493119ab3f642e08dba798f557630f53 (diff) |
WaitFor, added sticky flag
Diffstat (limited to 'lib')
-rw-r--r-- | lib/CopyJob.cc | 4 | ||||
-rw-r--r-- | lib/HttpServ.cc | 2 | ||||
-rw-r--r-- | lib/ReadJob.cc | 4 | ||||
-rw-r--r-- | lib/Task.cc | 16 |
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() { |