执行调用

@param \Yurun\Swoole\SharedMemory\Message\Operation $operation
@return mixed
497160
protected function doCall($operation)
    {
        $this->client->send($operation);
        $result = $this->client->recv();
        if(false === $result)
        {
            return false;
        }
        if(null === $result->throwable)
        {
            return $result->result;
        }
        else
        {
            throw $result->throwable;
        }
    }
1260228
public function run($operation, array $arguments=[])
    {
        $job = $this->createJob($this->attributes, $operation, $arguments);
        return $this->pushToChannel($job);
    }
13313
protected function releaseLock($operation)
    {
        $exists = is_resource($this->lockHandle);

        $success = $exists && flock($this->lockHandle, $operation);

        $exists && fclose($this->lockHandle);
        $this->lockHandle = null;

        return $success;
    }
876182
function getOperationData($operation){
		if ($this->endpointType == 'wsdl' && is_null($this->wsdl)) {
			$this->loadWSDL();
			if ($this->getError())
				return false;
		}
		if(isset($this->operations[$operation])){
			return $this->operations[$operation];
		}
		$this->debug("No data for operation: $operation");
	}
606678
public function GetOperationCount($Operation) {
      if ($Operation == 'edits')
         $Operation = array('edit', 'delete');
      else
         $Operation = explode(',', $Operation);
      
      sort($Operation);
      array_map('ucfirst', $Operation);
      $CacheKey = 'Moderation.LogCount.'.implode('.', $Operation);
      $Count = Gdn::Cache()->Get($CacheKey);
      if ($Count === Gdn_Cache::CACHEOP_FAILURE) {
         $Count = $this->GetCountWhere(array('Operation' => $Operation));
         Gdn::Cache()->Store($CacheKey, $Count, array(
            Gdn_Cache::FEATURE_EXPIRY  => 300 // 5 minutes
         ));
      }
      return $Count;
   }
1070002
public function run($taskId, $operation, array $arguments)
    {

        try {

            $lambda = new Lambda($operation, $this->ioc);

            if ($lambda->isInstanceMethod()) {
                $this->connectHooks($taskId, $lambda->getCallInstance());
            }

            $this->taskRepository->write($taskId, ['state' => Queue::RUNNING]);

            $result = $this->performTask($lambda, $arguments);

            $this->taskRepository->write($taskId, ['state' => Queue::FINISHED]);

            return $result;

        } catch (\Exception $e) {

            $this->taskRepository->writeMessage($taskId, $this->exceptionMessage($e), Chatty::FATAL);
            $this->taskRepository->write($taskId, ['state' => Queue::FAILED]);

        }

    }
1203190
private function log(string $operation, array $data, string $fields = '*', $where = '', bool $before = true, bool $after = true): bool
    {

        //检查是否需要记录数据库日志
        $operationLog = self::logEnabled();
        if (!$operationLog) {
            //不需要记录,直接执行
            return $this->execute2();
        }

        //如果需要保存之前数据
        if ($before) {
            //保存旧的statement对象
            $old = clone $this->statement;

            //查询修改前数据
            $data['before'] = $this->select2($fields, $where);

            //恢复statement对象
            $this->statement = clone $old;
        }

        //执行原始操作
        $result = $this->execute2();

        //如果需要记录操作后数据
        if ($after) {
            //查询修改后数据
            $data['after'] = $this->select2($fields, $where);
        }

        //记录日志
        call_user_func($operationLog, $this->tableName, $operation, $data);

        return $result;
    }
1084132
public function find(string $operation, string $locale)
    {
        $model = $this->notifications->first(function ($value) use($operation, $locale) {
            return $value->code === $locale && ($value->title === $operation || $value->name === $operation);
        });

        return $model ? $model->content : false;
    }
272255
public static function parseOperationName(Operation $operation)
    {
        $verb = self::deriveAction($operation->httpMethod, $operation->uri);

        $wordifiedPath = self::wordifyPath($operation->uri);

        if ($operation->version == 'stream') {
            $wordifiedPath = $wordifiedPath.'Stream';
        }

        if (preg_match("/^\/{urlname}.*/", $operation->uri) == 1) {
            $wordifiedPath = 'Group'.$wordifiedPath;
        }

        return ucfirst($verb.$wordifiedPath);
    }
492258
public function withinTransaction(callable $operation)
    {
        if ($this->isInTransaction()) {
            return $operation();
        }

        $this->beginTransaction();
        try {
            $result = $operation();
            $this->commitTransaction();

            return $result;
        } catch (\Exception $e) {
            $this->rollbackTransaction();
            throw $e;
        }
    }
10110
protected function buildOperation($operation)
    {
        $body      = $this->document->getElementsByTagNameNS(self::SOAP_ENVELOPE, 'Body')->item(0);
        $operation = $this->document->createElementNS(self::ETP_NAME_SPACE, 'etp:' . $operation);

        return $body->appendChild($operation);
    }
523153
private function execCommand($operation, array $params)
    {
        // Create the command.
        $command = $this->client->getCommand(
            $this->info['command'][$operation],
            $params + $this->state->getId()
        );

        // Execute the before callback.
        if (is_callable($this->config["before_{$operation}"])) {
            $this->config["before_{$operation}"]($command);
        }

        // Execute the command asynchronously and return the promise.
        return $this->client->executeAsync($command);
    }
608666
public function process($src, OperationInterface $operation)
    {
        $res = [];
        foreach ($src as $row) {
            $testedValue = mp\getValue($row, $operation->getField());
            $argument = $operation->getValue();
            $operator = $operation->getOperator();
            if ($this->checkValue($testedValue, $operator, $argument)) {
                $res[] = $row;
            }
        }
        return $res;
    }
1237512
public static function runController($controllerName, $op, $namespaces) {
        $class = $namespaces . $controllerName;
        //实例化controller
        $controller = new $class();

        //验证方法是否存在
        if (method_exists($controller, $op) == FALSE) {
            error_404();
        }

        //验证通过，执行方法
        $controller->$op();

        //记录路由日志
        $msg = 'method：' . filter_input(INPUT_SERVER, 'REQUEST_METHOD') . '，url：' . filter_input(INPUT_SERVER, 'REQUEST_URI') . '，Http Status：' . filter_input(INPUT_SERVER, 'REDIRECT_STATUS');
        Log::info($msg);
        exit;
    }
99994
protected function translate($operation, array $params = [])
    {

        $locale     = is_null($this->locale) ? app()->getLocale() : $this->locale;
        $translator = app('translator');
        if (($name       = $this->notificationContents->find($operation, $locale)) !== false) {
            return $translator->transWith($name, $params);
        }
        return $translator->trans("antares/logger::operations.{$operation}", $params, 'messages', $locale, false);
    }
1044801
protected Object process(String operation, Object data){
        Closure<Object,Object> cl = operations.get(operation);
        if(cl!=null){
            return cl.call(data);
        }
        return true;
    }
99669
public function ExecuteRequest($operation, $params = array())
	{
		$params = array_replace($this->GetWSInitialRequest($operation), $params); 

		$results = parent::ExecuteRequest($operation, $params);

		$this->_CheckErrors($operation, $results);

		return $results->{$operation.'Result'};
	}