|
version 1.10, 2002/03/14 13:28:18
|
version 1.11, 2002/03/14 16:42:29
|
|
|
|
| } | } |
| catch(IPCException &) | catch(IPCException &) |
| { | { |
| cout << " ipc exception returning thread to avail list" << endl; |
PEGASUS_STD(cout) << " ipc exception returning thread to avail list" << PEGASUS_STD(endl); |
| | |
| myself->exit_self(0); | myself->exit_self(0); |
| } | } |
|
|
|
| } | } |
| catch(IPCException &) | catch(IPCException &) |
| { | { |
| cout << " ipc exception returning thread to avail list" << endl; |
PEGASUS_STD(cout) << " ipc exception returning thread to avail list" << PEGASUS_STD(endl); |
| | |
| myself->exit_self(0); | myself->exit_self(0); |
| } | } |
|
|
|
| } | } |
| catch(IPCException &) | catch(IPCException &) |
| { | { |
| cout << " ipc exception returning thread to avail list" << endl; |
PEGASUS_STD(cout) << " ipc exception returning thread to avail list" << PEGASUS_STD(endl); |
| | |
| myself->exit_self(0); | myself->exit_self(0); |
| } | } |
|
|
|
| { | { |
| if(_current_threads < _max_threads) | if(_current_threads < _max_threads) |
| { | { |
| cout << "timeout in waiting for free thread, allocating new thread " << endl; |
PEGASUS_STD(cout) << "timeout in waiting for free thread, allocating new thread " << PEGASUS_STD(endl); |
| th = _init_thread(); | th = _init_thread(); |
| continue; | continue; |
| } | } |
| cout << " timeout but no free thread, looping" << endl; |
PEGASUS_STD(cout) << " timeout but no free thread, looping" << PEGASUS_STD(endl); |
| | |
| } | } |
| catch(IPCException & ) | catch(IPCException & ) |
| { | { |
| cout << " IPC Exception " << endl; |
PEGASUS_STD(cout) << " IPC Exception " << PEGASUS_STD(endl); |
| abort(); | abort(); |
| } | } |
| | |
Return to
Thread.cpp
CVS log
Up to [Pegasus] / pegasus / src / Pegasus / Common