test/hyperf
1
0
Fork 0
mirror of https://gitee.com/hyperf/hyperf.git synced 2024-11-30 02:37:58 +08:00
Code Issues Actions 16 Packages Projects Releases Wiki Activity

Update ConfigFetcherProcess.php

Browse Source
This commit is contained in:
李铭昕 2019-07-27 09:50:45 +08:00
parent 5a6d943afc
commit e7b080f006
1 changed files with 3 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
src/config-etcd/src/Process/ConfigFetcherProcess.php
View File

@ -69,15 +69,10 @@ class ConfigFetcherProcess extends AbstractProcess
while (true) {
$config = $this->client->pull();
if ($config !== $this->cacheConfig) {
if ($this->cacheConfig !== null) {
$diff = array_diff($this->cacheConfig ?? [], $config);
} else {
$diff = $config;
}
$this->cacheConfig = $config;
$workerCount = $this->server->setting['worker_num'] + $this->server->setting['task_worker_num'] - 1;
for ($workerId = 0; $workerId <= $workerCount; ++$workerId) {
$this->server->sendMessage(new PipeMessage($this->format($diff)), $workerId);
$this->server->sendMessage(new PipeMessage($this->format($config)), $workerId);
}
}
@ -88,10 +83,10 @@ class ConfigFetcherProcess extends AbstractProcess
/**
* Format kv configurations.
*/
protected function format(array $diff): array
protected function format(array $config): array
{
$result = [];
foreach ($diff as $value) {
foreach ($config as $value) {
$result[] = new KV($value);
}