{ $rseqid = 0; $fname = ''; $mtype = 0; $input->readMessageBegin(inout $fname, inout $mtype, inout $rseqid); $methodname = 'process_'.$fname; if (!method_exists($this, $methodname)) { $handler_ctx = $this->eventHandler_->getHandlerContext($fname); $this->eventHandler_->preRead($handler_ctx, $fname, array()); $input->skip(TType::STRUCT); $input->readMessageEnd(); $this->eventHandler_->postRead($handler_ctx, $fname, array()); $x = new TApplicationException( 'Function '.$fname.' not implemented.', TApplicationException::UNKNOWN_METHOD, ); $this->eventHandler_->handlerError($handler_ctx, $fname, $x); $output->writeMessageBegin($fname, TMessageType::EXCEPTION, $rseqid); $x->write($output); $output->writeMessageEnd(); $output->getTransport()->flush(); return true; } /* UNSAFE_EXPR[2011]: This is safe */ await $this->$methodname($rseqid, $input, $output); return true; } final public function process(TProtocol $input, TProtocol $output): bool { return HH\Asio\join($this->processAsync($input, $output)); } }