kakserpom /
phpdaemon
| @@ 397-407 (lines=11) @@ | ||
| 394 | public function findChannelId() |
|
| 395 | { |
|
| 396 | // first check in range [next, max] ... |
|
| 397 | for ( |
|
| 398 | $channelId = $this->nextChannelId; |
|
| 399 | $channelId <= $this->maximumChannelCount; |
|
| 400 | ++$channelId |
|
| 401 | ) { |
|
| 402 | if (!isset($this->channels[$channelId])) { |
|
| 403 | $this->nextChannelId = $channelId + 1; |
|
| 404 | ||
| 405 | return $channelId; |
|
| 406 | } |
|
| 407 | } |
|
| 408 | ||
| 409 | // then check in range [min, next) ... |
|
| 410 | for ( |
|
| @@ 410-420 (lines=11) @@ | ||
| 407 | } |
|
| 408 | ||
| 409 | // then check in range [min, next) ... |
|
| 410 | for ( |
|
| 411 | $channelId = 1; |
|
| 412 | $channelId < $this->nextChannelId; |
|
| 413 | ++$channelId |
|
| 414 | ) { |
|
| 415 | if (!isset($this->channels[$channelId])) { |
|
| 416 | $this->nextChannelId = $channelId + 1; |
|
| 417 | ||
| 418 | return $channelId; |
|
| 419 | } |
|
| 420 | } |
|
| 421 | ||
| 422 | throw new AMQPConnectionException('No available channels'); |
|
| 423 | } |
|
