本文整理汇总了PHP中phpiredis_reader_feed函数的典型用法代码示例。如果您正苦于以下问题:PHP phpiredis_reader_feed函数的具体用法?PHP phpiredis_reader_feed怎么用?PHP phpiredis_reader_feed使用的例子?那么恭喜您, 这里精选的函数代码示例或许可以为您提供帮助。
在下文中一共展示了phpiredis_reader_feed函数的5个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的PHP代码示例。
示例1: parseResponseBuffer
/**
* {@inheritdoc}
*/
public function parseResponseBuffer($buffer)
{
phpiredis_reader_feed($reader = $this->reader, $buffer);
while (phpiredis_reader_get_state($reader) === PHPIREDIS_READER_STATE_COMPLETE) {
$this->state->process(phpiredis_reader_get_reply($reader));
}
}
开发者ID:xzander,项目名称:predis-async,代码行数:10,代码来源:PhpiredisStreamConnection.php
示例2: feedReader
/**
* Feeds phpredis' reader resource with the data read from the network.
*
* @param resource $resource Reader resource.
* @param string $buffer Buffer with the reply read from the network.
* @return int
*/
protected function feedReader($resource, $buffer)
{
phpiredis_reader_feed($this->_reader, $buffer);
return strlen($buffer);
}
开发者ID:GunioRobot,项目名称:predis,代码行数:12,代码来源:WebdisConnection.php
示例3: read
/**
* {@inheritdoc}
*/
public function read()
{
$socket = $this->getResource();
$reader = $this->reader;
while (PHPIREDIS_READER_STATE_INCOMPLETE === ($state = phpiredis_reader_get_state($reader))) {
if (@socket_recv($socket, $buffer, 4096, 0) === false || $buffer === '' || $buffer === null) {
$this->emitSocketError();
}
phpiredis_reader_feed($reader, $buffer);
}
if ($state === PHPIREDIS_READER_STATE_COMPLETE) {
return phpiredis_reader_get_reply($reader);
} else {
$this->onProtocolError(phpiredis_reader_get_error($reader));
return;
}
}
开发者ID:sohel4r,项目名称:wordpress_4_1_1,代码行数:20,代码来源:predis.php
示例4: read
/**
* {@inheritdoc}
*/
public function read()
{
$socket = $this->getResource();
$reader = $this->reader;
while (PHPIREDIS_READER_STATE_INCOMPLETE === ($state = phpiredis_reader_get_state($reader))) {
$buffer = stream_socket_recvfrom($socket, 4096);
if ($buffer === false || $buffer === '') {
$this->onConnectionError('Error while reading bytes from the server');
}
phpiredis_reader_feed($reader, $buffer);
}
if ($state === PHPIREDIS_READER_STATE_COMPLETE) {
return phpiredis_reader_get_reply($reader);
} else {
$this->onProtocolError(phpiredis_reader_get_error($reader));
}
}
开发者ID:rodrigopbel,项目名称:ong,代码行数:20,代码来源:PhpiredisStreamConnection.php
示例5: read
/**
* {@inheritdoc}
*/
public function read()
{
$buffer = stream_socket_recvfrom($this->getResource(), 4096);
if ($buffer === false || $buffer === '') {
return $this->onError(new ConnectionException($this, 'Error while reading bytes from the server'));
}
phpiredis_reader_feed($reader = $this->reader, $buffer);
while (phpiredis_reader_get_state($reader) === PHPIREDIS_READER_STATE_COMPLETE) {
$this->state->process(phpiredis_reader_get_reply($reader));
}
}
开发者ID:tystr,项目名称:predis-async,代码行数:14,代码来源:PhpiredisStreamConnection.php
注:本文中的phpiredis_reader_feed函数示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论