|
version 1.79, 2005/03/12 01:07:42
|
version 1.80, 2005/03/22 00:36:02
|
|
|
|
| struct timeval now; | struct timeval now; |
| gettimeofday(&now, NULL); | gettimeofday(&now, NULL); |
| Uint32 bodies = 0; | Uint32 bodies = 0; |
| AtomicInt needed(0); |
|
| | |
| if (_dying.value()) | if (_dying.value()) |
| { | { |
|
|
|
| th = (Thread*)idq.remove_last(); | th = (Thread*)idq.remove_last(); |
| } | } |
| | |
| Tracer::trace(TRC_THREAD, Tracer::LEVEL2, |
|
| "We need %u new threads", needed.value()); |
|
| while (needed.value() > 0) { |
|
| _link_pool(_init_thread()); |
|
| needed--; |
|
| pegasus_sleep(0); |
|
| } |
|
| return bodies; | return bodies; |
| } | } |
| catch (...) | catch (...) |
Return to
Thread.cpp
CVS log
Up to [Pegasus] / pegasus / src / Pegasus / Common