| 75 | return P; |
| 76 | } |
| 77 | void INetQueue::Release() |
| 78 | { |
| 79 | cs.Enter(); |
| 80 | VERIFY(!ready.empty()); |
| 81 | //--------------------------------------------- |
| 82 | u32 tmp_time = GetTickCount() - 60000; |
| 83 | u32 size = unused.size(); |
| 84 | if ((LastTimeCreate < tmp_time) && (size > 32)) |
| 85 | { |
| 86 | xr_delete(ready.front()); |
| 87 | } |
| 88 | else |
| 89 | unused.push_back(ready.front()); |
| 90 | //--------------------------------------------- |
| 91 | ready.pop_front(); |
| 92 | cs.Leave(); |
| 93 | } |
| 94 | |
| 95 | IPureClient::IPureClient(CTimer* timer) |
| 96 | { |