Commit830f7c3

LIU JIAN

authored

Merge pull request #130 from PandaLIU-1111/ping

Added ping

2 parents504648d +fae7795 commit830f7c3Copy full SHA for 830f7c3

File tree

+34

-0

lines changed

+34

-0

lines changed

Lines changed: 24 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);`
`@@ -106,6 +112,12 @@ public function receive(Connection $connection)`
`106`	`112`	`$buffer =null;`
`107`	`113`	`continue;`
`108`	`114`	`}`
	`115`	`+`
	`116`	`+if ($type =='pong' &&count($buffer) ==5) {`
	`117`	`+$this->pingChannel->push('pong');`
	`118`	`+$buffer =null;`
	`119`	`+continue;`
	`120`	`+ }`
`109`	`121`	`}`
`110`	`122`	`}`
`111`	`123`
`@@ -153,6 +165,18 @@ public function interrupt()`
`153`	`165`	`returntrue;`
`154`	`166`	`}`
`155`	`167`
	`168`	`+/**`
	`169`	`+ * Ping`
	`170`	`+ * @param int $timeout`
	`171`	`+ * @return string`
	`172`	`+ * @throws \Swoole\Exception`
	`173`	`+ */`
	`174`	`+publicfunctionping(int$timeout =1)`
	`175`	`+ {`
	`176`	`+$this->connection->send(Resp::build('ping'));`
	`177`	`+return$this->pingChannel->pop($timeout);`
	`178`	`+ }`
	`179`	`+`
`156`	`180`	`/**`
`157`	`181`	`* Print error`
`158`	`182`	`* @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)