|
@@ -52,19 +52,26 @@ class CentraHelper
|
|
|
{
|
|
|
$this->socket = $sockfd;
|
|
|
//$this->socket = stream_socket_server ($this->remote_addr(), $errno, $errstr);
|
|
|
+ echo "stream_set_blocking \n";
|
|
|
if(stream_set_blocking($this->socket, 0) == false) {
|
|
|
echo "stream_set_blocking error \n";
|
|
|
}
|
|
|
$this->ev_base = event_base_new();
|
|
|
$this->ev = event_new();
|
|
|
+
|
|
|
+ echo "event_set\n";
|
|
|
if(event_set($this->ev, $this->socket, EV_READ | EV_PERSIST, 'ev_accept', $this->ev_base) == false) {
|
|
|
echo "event_set error EV_READ | EV_PERSIST\n";
|
|
|
}
|
|
|
+
|
|
|
+ echo "event_base_set\n";
|
|
|
if(event_base_set($this->ev, $this->ev_base) == false) {
|
|
|
echo "event_set error EV_READ | EV_PERSIST\n";
|
|
|
}
|
|
|
+
|
|
|
+ echo "event_add\n";
|
|
|
if(event_add($this->ev) == false) {
|
|
|
- echo "event_set error EV_READ | EV_PERSIST\n";
|
|
|
+ echo "event_add error EV_READ | EV_PERSIST\n";
|
|
|
}
|
|
|
$ret = event_base_loop($this->ev_base);
|
|
|
|