DominionEnterprises\Cronus\ProcessRegistry::add()

Complexity

Conditions	17
Paths	197

Size

Total Lines	84
Code Lines	47

Duplication

Lines	7
Ratio	8.33 %

Importance

Changes

0

<?php
    public function add(

Function's nesting level (4) exceeds 2; consider refactoring the function

Unknown type hint "string" found for $id

Unknown type hint "int" found for $minsBeforeExpire

Unknown type hint "int" found for $maxGlobalProcesses

Unknown type hint "int" found for $maxHostProcesses

        string $id,
        int $minsBeforeExpire = PHP_INT_MAX,
        int $maxGlobalProcesses = 1,
        int $maxHostProcesses = 1
    ) : bool {
        $thisHostName = self::_getEncodedHostname();
        $thisPid = getmypid();

        //loop in case the update fails its optimistic concurrency check
        for ($i = 0; $i < 5; ++$i) {
            $this->collection->findOneAndUpdate(
                ['_id' => $id],
                ['$setOnInsert' => ['hosts' => [], 'version' => new ObjectID()]],
                ['upsert' => true]
            );
            $existing = $this->collection->findOne(
                ['_id' => $id],
                ['typeMap' => ['root' => 'array', 'document' => 'array', 'array' => 'array']]
            );

            $replacement = $existing;
            $replacement['version'] = new ObjectID();

            //clean $replacement based on their pids and expire times
            foreach ($existing['hosts'] as $hostname => $pids) {
                foreach ($pids as $pid => $expires) {
                    //our machine and not running
                    //the task expired
                    //our machine and pid is recycled (should rarely happen)
                    if (($hostname === $thisHostName && !file_exists("/proc/{$pid}"))
                        || time() > $expires
                        || ($hostname === $thisHostName && $pid === $thisPid)
                    ) {
                        unset($replacement['hosts'][$hostname][$pid]);
                    }
                }

                if (empty($replacement['hosts'][$hostname])) {
                    unset($replacement['hosts'][$hostname]);
                }
            }

            $totalPidCount = 0;
            foreach ($replacement['hosts'] as $hostname => $pids) {
                $totalPidCount += count($pids);
            }

            $thisHostPids = array_key_exists($thisHostName, $replacement['hosts']) ? $replacement['hosts'][$thisHostName] : [];

            if ($totalPidCount >= $maxGlobalProcesses || count($thisHostPids) >= $maxHostProcesses) {
                return false;
            }

            // add our process
            $expireSecs = time() + $minsBeforeExpire * 60;
            if (!is_int($expireSecs)) {

This code seems to be duplicated across your project.

                if ($minsBeforeExpire > 0) {
                    $expireSecs = self::MONGO_INT32_MAX;
                } else {
                    $expireSecs = 0;
                }
            }

            $thisHostPids[$thisPid] = $expireSecs;
            $replacement['hosts'][$thisHostName] = $thisHostPids;

            $status = $this->collection->replaceOne(
                ['_id' => $existing['_id'], 'version' => $existing['version']],
                $replacement,
                ['writeConcern' => new \MongoDB\Driver\WriteConcern(1, 100, true)]
            );
            if ($status->getMatchedCount() === 1) {
                return true;
            }

            //@codeCoverageIgnoreStart
            //hard to test the optimistic concurrency check
        }

        //too much concurrency at the moment, return false to signify not added.
        return false;
        //@codeCoverageIgnoreEnd
    }