|
version 1.21, 2002/06/19 22:06:33
|
version 1.22, 2002/06/20 14:55:38
|
|
|
|
| int i = 0; | int i = 0; |
| AtomicInt needed(0); | AtomicInt needed(0); |
| | |
| for( ; i < 1; i++) |
for( ; i < 2; i++) |
| { | { |
| q = map[i]; | q = map[i]; |
| if(q->count() > 0 ) | if(q->count() > 0 ) |
|
|
|
| } | } |
| else | else |
| { | { |
| check_time(&dt, get_deadlock_detect(&deadlock_timeout)); |
too_long = check_time(&dt, get_deadlock_detect(&deadlock_timeout)); |
| } | } |
| | |
| if( true == too_long) | if( true == too_long) |
|
|
|
| | |
| Boolean ThreadPool::check_time(struct timeval *start, struct timeval *interval) | Boolean ThreadPool::check_time(struct timeval *start, struct timeval *interval) |
| { | { |
| |
// never time out if the interval is zero |
| |
if(interval && interval->tv_sec == 0 && interval->tv_usec == 0) |
| |
return false; |
| |
|
| struct timeval now, finish, remaining; | struct timeval now, finish, remaining; |
| Uint32 usec; | Uint32 usec; |
| gettimeofday(&now, NULL); | gettimeofday(&now, NULL); |
Return to
Thread.cpp
CVS log
Up to [Pegasus] / pegasus / src / Pegasus / Common