|
@@ 193-205 (lines=13) @@
|
| 190 |
|
GlobalState::incr('streams.read.ticks'); |
| 191 |
|
GlobalState::incr('streams.total.ticks'); |
| 192 |
|
}); |
| 193 |
|
$loop->on('removeReadStream', function ($stream) { |
| 194 |
|
$key = (int) $stream; |
| 195 |
|
|
| 196 |
|
if (isset($this->streamsRead[$key])) { |
| 197 |
|
unset($this->streamsRead[$key]); |
| 198 |
|
} |
| 199 |
|
if (isset($this->streamsDuplex[$key]) && !isset($this->streamsWrite[$key])) { |
| 200 |
|
unset($this->streamsDuplex[$key]); |
| 201 |
|
} |
| 202 |
|
|
| 203 |
|
GlobalState::set('streams.read.current', count($this->streamsRead)); |
| 204 |
|
GlobalState::set('streams.total.current', count($this->streamsDuplex)); |
| 205 |
|
}); |
| 206 |
|
|
| 207 |
|
$loop->on('addWriteStream', function ($stream) { |
| 208 |
|
$key = (int) $stream; |
|
@@ 225-237 (lines=13) @@
|
| 222 |
|
GlobalState::incr('streams.write.ticks'); |
| 223 |
|
GlobalState::incr('streams.total.ticks'); |
| 224 |
|
}); |
| 225 |
|
$loop->on('removeWriteStream', function ($stream) { |
| 226 |
|
$key = (int) $stream; |
| 227 |
|
|
| 228 |
|
if (isset($this->streamsWrite[$key])) { |
| 229 |
|
unset($this->streamsWrite[$key]); |
| 230 |
|
} |
| 231 |
|
if (isset($this->streamsDuplex[$key]) && !isset($this->streamsRead[$key])) { |
| 232 |
|
unset($this->streamsDuplex[$key]); |
| 233 |
|
} |
| 234 |
|
|
| 235 |
|
GlobalState::set('streams.write.current', count($this->streamsWrite)); |
| 236 |
|
GlobalState::set('streams.total.current', count($this->streamsDuplex)); |
| 237 |
|
}); |
| 238 |
|
|
| 239 |
|
$loop->on('removeStream', function ($stream) { |
| 240 |
|
$key = (int) $stream; |