Commitce3b7f7

committed

Added ping

1 parentd582215 commitce3b7f7Copy full SHA for ce3b7f7

File tree

+33

-0

lines changed

+33

-0

lines changed

Lines changed: 23 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -33,6 +33,11 @@ class CommandInvoker`
`33`	`33`	`*/`
`34`	`34`	`protected$messageChannel;`
`35`	`35`
	`36`	`+/**`
	`37`	`+ * @var Channel`
	`38`	`+ */`
	`39`	`+private$pingChannel;`
	`40`	`+`
`36`	`41`	`/**`
`37`	`42`	`* CommandInvoker constructor.`
`38`	`43`	`* @param Connection $connection`
`@@ -41,6 +46,7 @@ public function __construct(Connection $connection)`
`41`	`46`	`{`
`42`	`47`	`$this->connection =$connection;`
`43`	`48`	`$this->resultChannel =newChannel();`
	`49`	`+$this->pingChannel =newChannel();`
`44`	`50`	`$this->messageChannel =newChannel(100);`
`45`	`51`	`Coroutine::create(function ()use ($connection) {`
`46`	`52`	`$this->receive($connection);`
`@@ -63,6 +69,11 @@ public function receive(Connection $connection)`
`63`	`69`	`}`
`64`	`70`	`$line =substr($line,0, -(strlen(static::CRLF)));`
`65`	`71`
	`72`	`+if ($line =='pong') {`
	`73`	`+$this->pingChannel->push($line);`
	`74`	`+continue;`
	`75`	`+ }`
	`76`	`+`
`66`	`77`	`if ($line =='+OK') {`
`67`	`78`	`$this->resultChannel->push($line);`
`68`	`79`	`continue;`
`@@ -153,6 +164,18 @@ public function interrupt()`
`153`	`164`	`returntrue;`
`154`	`165`	`}`
`155`	`166`
	`167`	`+/**`
	`168`	`+ * Ping`
	`169`	`+ * @param int $timeout`
	`170`	`+ * @return string`
	`171`	`+ * @throws \Swoole\Exception`
	`172`	`+ */`
	`173`	`+publicfunctionping(int$timeout =1)`
	`174`	`+ {`
	`175`	`+$this->connection->send(Resp::build('ping'));`
	`176`	`+return$this->pingChannel->pop($timeout);`
	`177`	`+ }`
	`178`	`+`
`156`	`179`	`/**`
`157`	`180`	`* Print error`
`158`	`181`	`* @param \Throwable $ex`

Lines changed: 10 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -143,4 +143,14 @@ public function close()`
`143`	`143`	`$this->commandInvoker->interrupt();`
`144`	`144`	`}`
`145`	`145`
	`146`	`+/**`
	`147`	`+ * Ping`
	`148`	`+ * @param int $timeout`
	`149`	`+ * @throws \Swoole\Exception`
	`150`	`+ */`
	`151`	`+publicfunctionping(int$timeout =1)`
	`152`	`+ {`
	`153`	`+return$this->commandInvoker->ping($timeout);`
	`154`	`+ }`
	`155`	`+`
`146`	`156`	`}`

Comments

(0)