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