本文整理汇总了PHP中thrift_protocol_read_binary函数的典型用法代码示例。如果您正苦于以下问题:PHP thrift_protocol_read_binary函数的具体用法?PHP thrift_protocol_read_binary怎么用?PHP thrift_protocol_read_binary使用的例子?那么恭喜您, 这里精选的函数代码示例或许可以为您提供帮助。
在下文中一共展示了thrift_protocol_read_binary函数的20个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的PHP代码示例。
示例1: recv_healthPoke
public function recv_healthPoke()
{
$bin_accel = $this->input_ instanceof TBinaryProtocolAccelerated && function_exists('thrift_protocol_read_binary');
if ($bin_accel) {
$result = thrift_protocol_read_binary($this->input_, '\\RedRoma\\Aroma\\Endpoint\\ApplicationEndpoint_healthPoke_result', $this->input_->isStrictRead());
} else {
$rseqid = 0;
$fname = null;
$mtype = 0;
$this->input_->readMessageBegin($fname, $mtype, $rseqid);
if ($mtype == TMessageType::EXCEPTION) {
$x = new TApplicationException();
$x->read($this->input_);
$this->input_->readMessageEnd();
throw $x;
}
$result = new \RedRoma\Aroma\Endpoint\ApplicationEndpoint_healthPoke_result();
$result->read($this->input_);
$this->input_->readMessageEnd();
}
if ($result->success !== null) {
return $result->success;
}
if ($result->ex1 !== null) {
throw $result->ex1;
}
throw new \Exception("healthPoke failed: unknown result");
}
开发者ID:RedRoma,项目名称:aroma-thrift,代码行数:28,代码来源:ApplicationEndpoint.php
示例2: recv_UpdateState
public function recv_UpdateState()
{
$bin_accel = $this->input_ instanceof TBinaryProtocolAccelerated && function_exists('thrift_protocol_read_binary');
if ($bin_accel) {
$result = thrift_protocol_read_binary($this->input_, '\\Impala\\StateStoreSubscriber_UpdateState_result', $this->input_->isStrictRead());
} else {
$rseqid = 0;
$fname = null;
$mtype = 0;
$this->input_->readMessageBegin($fname, $mtype, $rseqid);
if ($mtype == TMessageType::EXCEPTION) {
$x = new TApplicationException();
$x->read($this->input_);
$this->input_->readMessageEnd();
throw $x;
}
$result = new \Impala\StateStoreSubscriber_UpdateState_result();
$result->read($this->input_);
$this->input_->readMessageEnd();
}
if ($result->success !== null) {
return $result->success;
}
throw new \Exception("UpdateState failed: unknown result");
}
开发者ID:pozypakya,项目名称:php-impala,代码行数:25,代码来源:StateStoreSubscriber.php
示例3: recv_Report
public function recv_Report()
{
$bin_accel = $this->input_ instanceof TBinaryProtocolAccelerated && function_exists('thrift_protocol_read_binary');
if ($bin_accel) {
$result = thrift_protocol_read_binary($this->input_, '\\CroutonThrift\\ReportingService_Report_result', $this->input_->isStrictRead());
} else {
$rseqid = 0;
$fname = null;
$mtype = 0;
$this->input_->readMessageBegin($fname, $mtype, $rseqid);
if ($mtype == TMessageType::EXCEPTION) {
$x = new TApplicationException();
$x->read($this->input_);
$this->input_->readMessageEnd();
throw $x;
}
$result = new \CroutonThrift\ReportingService_Report_result();
$result->read($this->input_);
$this->input_->readMessageEnd();
}
if ($result->success !== null) {
return $result->success;
}
throw new \Exception("Report failed: unknown result");
}
开发者ID:lightstep,项目名称:lightstep-tracer-php,代码行数:25,代码来源:ReportingService.php
示例4: recv_Log
public function recv_Log()
{
$bin_accel = $this->input_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED && function_exists('thrift_protocol_read_binary');
if ($bin_accel) {
$result = thrift_protocol_read_binary($this->input_, 'scribe_Log_result', $this->input_->isStrictRead());
} else {
$rseqid = 0;
$fname = null;
$mtype = 0;
$this->input_->readMessageBegin($fname, $mtype, $rseqid);
if ($mtype == TMessageType::EXCEPTION) {
$x = new TApplicationException();
$x->read($this->input_);
$this->input_->readMessageEnd();
throw $x;
}
$result = new scribe_Log_result();
$result->read($this->input_);
$this->input_->readMessageEnd();
}
if ($result->success !== null) {
return $result->success;
}
throw new Exception("Log failed: unknown result");
}
开发者ID:utcuong3010,项目名称:vng,代码行数:25,代码来源:scribe.php
示例5: test
function test()
{
$p = new DummyProtocol();
$v1 = new TestStruct();
$v1->aString = str_repeat('x', 1000000);
thrift_protocol_write_binary($p, 'foomethod', 1, $v1, 20, true);
$p->getTransport()->buff = str_replace(pack('N', 1000000), pack('N', (1 << 32) - 2), $p->getTransport()->buff);
thrift_protocol_read_binary($p, 'TestStruct', true);
}
开发者ID:badlamer,项目名称:hhvm,代码行数:9,代码来源:thrift.php
示例6: deserialize
public static function deserialize($str, $object, $disable_hphp_extension = false)
{
$transport = new TMemoryBuffer();
$protocol = new TBinaryProtocolAccelerated($transport);
if (\hacklib_cast_as_boolean(function_exists('thrift_protocol_read_binary')) && !\hacklib_cast_as_boolean($disable_hphp_extension)) {
$protocol->writeMessageBegin('', TMessageType::REPLY, 0);
$transport->write($str);
$object = thrift_protocol_read_binary($protocol, get_class($object), $protocol->isStrictRead());
} else {
$transport->write($str);
$object->read($protocol);
}
return $object;
}
开发者ID:pandasasa,项目名称:fbthrift,代码行数:14,代码来源:TBinarySerializer.php
示例7: deserialize
public static function deserialize($string_object, $class_name)
{
$transport = new TMemoryBuffer();
$protocol = new TBinaryProtocolAccelerated($transport);
if (function_exists('thrift_protocol_read_binary')) {
$protocol->writeMessageBegin('', TMessageType::REPLY, 0);
$transport->write($string_object);
return thrift_protocol_read_binary($protocol, $class_name, $protocol->isStrictRead());
} else {
$transport->write($string_object);
$object = new $class_name();
$object->read($protocol);
return $object;
}
}
开发者ID:bibhutibhusan89,项目名称:Impala,代码行数:15,代码来源:TBinarySerializer.php
示例8: test
function test()
{
$p = new DummyProtocol();
$v1 = new TestStruct();
$v1->aBool = false;
$v1->anInt = -1234;
$v1->aDouble = -1.2345;
$v1->anInt64 = -1;
$v1->anByte = -12;
$v1->anI16 = -123;
$v1->aFloat = 1.25;
$v1->bFloat = 3.141592653589793;
thrift_protocol_write_binary($p, 'foomethod', 1, $v1, 20, true);
var_dump(thrift_protocol_read_binary($p, 'TestStruct', true));
}
开发者ID:badlamer,项目名称:hhvm,代码行数:15,代码来源:1557.php
示例9: deserialize
public static function deserialize($string_object, $class_name)
{
$transport = new TMemoryBuffer();
$protocol = new TBinaryProtocolAccelerated($transport);
if (function_exists('thrift_protocol_read_binary')) {
// NOTE (t.heintz) TBinaryProtocolAccelerated internally wraps our TMemoryBuffer in a
// TBufferedTransport, so we have to retrieve it again or risk losing data when writing
// less than 512 bytes to the transport (see the comment there as well).
// @see THRIFT-1579
$protocol->writeMessageBegin('', TMessageType::REPLY, 0);
$protocolTransport = $protocol->getTransport();
$protocolTransport->write($string_object);
$protocolTransport->flush();
return thrift_protocol_read_binary($protocol, $class_name, $protocol->isStrictRead());
} else {
$transport->write($string_object);
$object = new $class_name();
$object->read($protocol);
return $object;
}
}
开发者ID:junerain,项目名称:thrift,代码行数:21,代码来源:TBinarySerializer.php
示例10: recv_close
public function recv_close()
{
$bin_accel = $this->input_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED && function_exists('thrift_protocol_read_binary');
if ($bin_accel) {
$result = thrift_protocol_read_binary($this->input_, '\\ICANS\\Component\\IcansLoggingComponent\\Flume\\ThriftFlumeEventServer_close_result', $this->input_->isStrictRead());
} else {
$rseqid = 0;
$fname = null;
$mtype = 0;
$this->input_->readMessageBegin($fname, $mtype, $rseqid);
if ($mtype == TMessageType::EXCEPTION) {
$x = new TApplicationException();
$x->read($this->input_);
$this->input_->readMessageEnd();
throw $x;
}
$result = new \ICANS\Component\IcansLoggingComponent\Flume\ThriftFlumeEventServer_close_result();
$result->read($this->input_);
$this->input_->readMessageEnd();
}
return;
}
开发者ID:xietongling,项目名称:IcansLoggingComponent,代码行数:22,代码来源:ThriftFlumeEventServerClient.php
示例11: recv_ShutdownServer
public function recv_ShutdownServer()
{
$bin_accel = $this->input_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED && function_exists('thrift_protocol_read_binary');
if ($bin_accel) {
$result = thrift_protocol_read_binary($this->input_, '\\ImpalaPlanService_ShutdownServer_result', $this->input_->isStrictRead());
} else {
$rseqid = 0;
$fname = null;
$mtype = 0;
$this->input_->readMessageBegin($fname, $mtype, $rseqid);
if ($mtype == TMessageType::EXCEPTION) {
$x = new TApplicationException();
$x->read($this->input_);
$this->input_->readMessageEnd();
throw $x;
}
$result = new \ImpalaPlanService_ShutdownServer_result();
$result->read($this->input_);
$this->input_->readMessageEnd();
}
return;
}
开发者ID:pozypakya,项目名称:php_impala_phar,代码行数:22,代码来源:ImpalaPlanService.php
示例12: recv_hql_query2
public function recv_hql_query2()
{
$bin_accel = $this->input_ instanceof TBinaryProtocolAccelerated && function_exists('thrift_protocol_read_binary');
if ($bin_accel) {
$result = thrift_protocol_read_binary($this->input_, '\\Hypertable_ThriftGen2\\HqlService_hql_query2_result', $this->input_->isStrictRead());
} else {
$rseqid = 0;
$fname = null;
$mtype = 0;
$this->input_->readMessageBegin($fname, $mtype, $rseqid);
if ($mtype == TMessageType::EXCEPTION) {
$x = new TApplicationException();
$x->read($this->input_);
$this->input_->readMessageEnd();
throw $x;
}
$result = new \Hypertable_ThriftGen2\HqlService_hql_query2_result();
$result->read($this->input_);
$this->input_->readMessageEnd();
}
if ($result->success !== null) {
return $result->success;
}
if ($result->e !== null) {
throw $result->e;
}
throw new \Exception("hql_query2 failed: unknown result");
}
开发者ID:covertcodeop,项目名称:hypertable,代码行数:28,代码来源:HqlService.php
示例13: recv_clean
public function recv_clean()
{
$bin_accel = $this->input_ instanceof TBinaryProtocolAccelerated && function_exists('thrift_protocol_read_binary');
if ($bin_accel) {
$result = thrift_protocol_read_binary($this->input_, '\\ThriftHive_clean_result', $this->input_->isStrictRead());
} else {
$rseqid = 0;
$fname = null;
$mtype = 0;
$this->input_->readMessageBegin($fname, $mtype, $rseqid);
if ($mtype == TMessageType::EXCEPTION) {
$x = new TApplicationException();
$x->read($this->input_);
$this->input_->readMessageEnd();
throw $x;
}
$result = new \ThriftHive_clean_result();
$result->read($this->input_);
$this->input_->readMessageEnd();
}
return;
}
开发者ID:priyanshu-sekhar,项目名称:hive,代码行数:22,代码来源:ThriftHive.php
示例14: recv_getCardRechargeList
public function recv_getCardRechargeList()
{
$bin_accel = $this->input_ instanceof TBinaryProtocolAccelerated && function_exists('thrift_protocol_read_binary');
if ($bin_accel) {
$result = thrift_protocol_read_binary($this->input_, '\\Thrift\\Server\\CardCenterService_getCardRechargeList_result', $this->input_->isStrictRead());
} else {
$rseqid = 0;
$fname = null;
$mtype = 0;
$this->input_->readMessageBegin($fname, $mtype, $rseqid);
if ($mtype == TMessageType::EXCEPTION) {
$x = new TApplicationException();
$x->read($this->input_);
$this->input_->readMessageEnd();
throw $x;
}
$result = new \Thrift\Server\CardCenterService_getCardRechargeList_result();
$result->read($this->input_);
$this->input_->readMessageEnd();
}
if ($result->success !== null) {
return $result->success;
}
if ($result->dataNotFound !== null) {
throw $result->dataNotFound;
}
throw new \Exception("getCardRechargeList failed: unknown result");
}
开发者ID:xiaoyueer98,项目名称:app.heimi.com,代码行数:28,代码来源:CardCenterServiceClient.php
示例15: recv_getAllUserSSHPubKeys
public function recv_getAllUserSSHPubKeys()
{
$bin_accel = $this->input_ instanceof TBinaryProtocolAccelerated && function_exists('thrift_protocol_read_binary');
if ($bin_accel) {
$result = thrift_protocol_read_binary($this->input_, '\\Airavata\\API\\Credentials\\CredentialManagementService_getAllUserSSHPubKeys_result', $this->input_->isStrictRead());
} else {
$rseqid = 0;
$fname = null;
$mtype = 0;
$this->input_->readMessageBegin($fname, $mtype, $rseqid);
if ($mtype == TMessageType::EXCEPTION) {
$x = new TApplicationException();
$x->read($this->input_);
$this->input_->readMessageEnd();
throw $x;
}
$result = new \Airavata\API\Credentials\CredentialManagementService_getAllUserSSHPubKeys_result();
$result->read($this->input_);
$this->input_->readMessageEnd();
}
if ($result->success !== null) {
return $result->success;
}
throw new \Exception("getAllUserSSHPubKeys failed: unknown result");
}
开发者ID:kidaak,项目名称:airavata-sandbox,代码行数:25,代码来源:CredentialManagementService.php
示例16: recv_pac
public function recv_pac()
{
$bin_accel = $this->input_ instanceof TBinaryProtocolAccelerated && function_exists('thrift_protocol_read_binary');
if ($bin_accel) {
$result = thrift_protocol_read_binary($this->input_, '\\net\\toruneko\\wakfu\\interfaces\\WakfuService_pac_result', $this->input_->isStrictRead());
} else {
$rseqid = 0;
$fname = null;
$mtype = 0;
$this->input_->readMessageBegin($fname, $mtype, $rseqid);
if ($mtype == TMessageType::EXCEPTION) {
$x = new TApplicationException();
$x->read($this->input_);
$this->input_->readMessageEnd();
throw $x;
}
$result = new \net\toruneko\wakfu\interfaces\WakfuService_pac_result();
$result->read($this->input_);
$this->input_->readMessageEnd();
}
if ($result->success !== null) {
return $result->success;
}
throw new \Exception("pac failed: unknown result");
}
开发者ID:syxoasis,项目名称:wakfu-server,代码行数:25,代码来源:WakfuService.php
示例17: recv_GetBehaviorReport
public function recv_GetBehaviorReport()
{
$bin_accel = $this->input_ instanceof TBinaryProtocolAccelerated && function_exists('thrift_protocol_read_binary');
if ($bin_accel) {
$result = thrift_protocol_read_binary($this->input_, '\\com\\boxalino\\dataintelligence\\api\\thrift\\BoxalinoDataIntelligence_GetBehaviorReport_result', $this->input_->isStrictRead());
} else {
$rseqid = 0;
$fname = null;
$mtype = 0;
$this->input_->readMessageBegin($fname, $mtype, $rseqid);
if ($mtype == TMessageType::EXCEPTION) {
$x = new TApplicationException();
$x->read($this->input_);
$this->input_->readMessageEnd();
throw $x;
}
$result = new \com\boxalino\dataintelligence\api\thrift\BoxalinoDataIntelligence_GetBehaviorReport_result();
$result->read($this->input_);
$this->input_->readMessageEnd();
}
if ($result->success !== null) {
return $result->success;
}
if ($result->e !== null) {
throw $result->e;
}
throw new \Exception("GetBehaviorReport failed: unknown result");
}
开发者ID:boxalino,项目名称:dataintelligence-client-php,代码行数:28,代码来源:BoxalinoDataIntelligence.php
示例18: recv_updateChoice
public function recv_updateChoice()
{
$bin_accel = $this->input_ instanceof TBinaryProtocolAccelerated && function_exists('thrift_protocol_read_binary');
if ($bin_accel) {
$result = thrift_protocol_read_binary($this->input_, '\\com\\boxalino\\p13n\\api\\thrift\\P13nService_updateChoice_result', $this->input_->isStrictRead());
} else {
$rseqid = 0;
$fname = null;
$mtype = 0;
$this->input_->readMessageBegin($fname, $mtype, $rseqid);
if ($mtype == TMessageType::EXCEPTION) {
$x = new TApplicationException();
$x->read($this->input_);
$this->input_->readMessageEnd();
throw $x;
}
$result = new \com\boxalino\p13n\api\thrift\P13nService_updateChoice_result();
$result->read($this->input_);
$this->input_->readMessageEnd();
}
if ($result->success !== null) {
return $result->success;
}
if ($result->p13nServiceException !== null) {
throw $result->p13nServiceException;
}
throw new \Exception("updateChoice failed: unknown result");
}
开发者ID:boxalino,项目名称:plugin-shopware,代码行数:28,代码来源:P13nService.php
示例19: recv_getUserInfoByEmail
public function recv_getUserInfoByEmail()
{
$bin_accel = $this->input_ instanceof TBinaryProtocolAccelerated && function_exists('thrift_protocol_read_binary');
if ($bin_accel) {
$result = thrift_protocol_read_binary($this->input_, '\\Demo\\Account_getUserInfoByEmail_result', $this->input_->isStrictRead());
} else {
$rseqid = 0;
$fname = null;
$mtype = 0;
$this->input_->readMessageBegin($fname, $mtype, $rseqid);
if ($mtype == TMessageType::EXCEPTION) {
$x = new TApplicationException();
$x->read($this->input_);
$this->input_->readMessageEnd();
throw $x;
}
$result = new \Demo\Account_getUserInfoByEmail_result();
$result->read($this->input_);
$this->input_->readMessageEnd();
}
if ($result->success !== null) {
return $result->success;
}
if ($result->ouch !== null) {
throw $result->ouch;
}
throw new \Exception("getUserInfoByEmail failed: unknown result");
}
开发者ID:nilyang,项目名称:thrift-laravel,代码行数:28,代码来源:Account.php
示例20: recv_findRelated
public function recv_findRelated()
{
$bin_accel = $this->input_ instanceof TBinaryProtocolAccelerated && function_exists('thrift_protocol_read_binary');
if ($bin_accel) {
$result = thrift_protocol_read_binary($this->input_, '\\EDAM\\NoteStore\\NoteStore_findRelated_result', $this->input_->isStrictRead());
} else {
$rseqid = 0;
$fname = null;
$mtype = 0;
$this->input_->readMessageBegin($fname, $mtype, $rseqid);
if ($mtype == TMessageType::EXCEPTION) {
$x = new TApplicationException();
$x->read($this->input_);
$this->input_->readMessageEnd();
throw $x;
}
$result = new \EDAM\NoteStore\NoteStore_findRelated_result();
$result->read($this->input_);
$this->input_->readMessageEnd();
}
if ($result->success !== null) {
return $result->success;
}
if ($result->userException !== null) {
throw $result->userException;
}
if ($result->systemException !== null) {
throw $result->systemException;
}
if ($result->notFoundException !== null) {
throw $result->notFoundException;
}
throw new \Exception("findRelated failed: unknown result");
}
开发者ID:smallsnailbigdream,项目名称:evernote-cloud-sdk-php,代码行数:34,代码来源:NoteStore.php
注:本文中的thrift_protocol_read_binary函数示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论