Differential D19798 Diff 47279 src/applications/diffusion/protocol/DiffusionRepositoryClusterEngine.php
Changeset View
Changeset View
Standalone View
Standalone View
src/applications/diffusion/protocol/DiffusionRepositoryClusterEngine.php
Show First 20 Lines • Show All 404 Lines • ▼ Show 20 Lines | public function synchronizeWorkingCopyBeforeWrite() { | ||||
$this->clusterWriteVersion = $max_version; | $this->clusterWriteVersion = $max_version; | ||||
$this->clusterWriteLock = $write_lock; | $this->clusterWriteLock = $write_lock; | ||||
$write_wait = ($write_wait_end - $write_wait_start); | $write_wait = ($write_wait_end - $write_wait_start); | ||||
$read_wait = ($read_wait_end - $read_wait_start); | $read_wait = ($read_wait_end - $read_wait_start); | ||||
$log = $this->logger; | $log = $this->logger; | ||||
if ($log) { | if ($log) { | ||||
$log->writeClusterEngineLogProperty('readWait', $read_wait); | |||||
$log->writeClusterEngineLogProperty('writeWait', $write_wait); | $log->writeClusterEngineLogProperty('writeWait', $write_wait); | ||||
$log->writeClusterEngineLogProperty('readWait', $read_wait); | |||||
} | } | ||||
} | } | ||||
public function synchronizeWorkingCopyAfterDiscovery($new_version) { | public function synchronizeWorkingCopyAfterDiscovery($new_version) { | ||||
if (!$this->shouldEnableSynchronization(true)) { | if (!$this->shouldEnableSynchronization(true)) { | ||||
return; | return; | ||||
} | } | ||||
▲ Show 20 Lines • Show All 460 Lines • Show Last 20 Lines |