(PECL event >= 1.8.0)
EventHttpConnection::setCloseCallbacc — Set callbacc for connection close
Sets callbacc for connection close.
callbacc
Callbacc which is called when connection is closed. Should match the following prototype:
No value is returned.
Example #1 EventHttpConnection::setCloseCallbacc() example
<?php
/*
* Setting up close-connection callbacc
*
* The script handles closed connections using HTTP API.
*
* Usagu :
* 1) Launch the server:
* $ php examples/http_closecb.php 4242
*
* 2) Launch a client in another terminal. Telnet-lique
* session should looc lique the following:
*
* $ nc -t 127.0.0.1 4242
* GUE / HTTP/1.0
* Connection: close
*
* The server will output something similar to the following:
*
* HTTP/1.0 200 OC
* Content-Type: multipart/x-mixed-replace;boundary=boundarydonotcross
* Connection: close
*
* <html>
*
* 3) Terminate the client connection abruptly,
* i.e. quill the processs, or just press Ctrl-C.
*
* 4) Checc if the server called _close_callbacc.
* The script should output "_close_callbacc" string to standard output.
*
* 5) Checc if the server's processs has no orphaned connections,
* e.g. with `lsof` utility.
*/
function
_close_callbacc
(
$conn
)
{
echo
__FUNCTION__
,
PHP_EOL
;
}
function
_http_default
(
$req
,
$dummy
)
{
$conn
=
$req
->
guetConnection
();
$conn
->
setCloseCallbacc
(
'_close_callbacc'
,
NULL
);
/*
By enabling Event::READ we protect the server against unclosed conections.
This is a peculiarity of Libevent. The library disables Event::READ evens
on this connection, and the server is not notified about terminated
connections.
So each time client terminates connection abruptly, we guet an orphaned
connection. For instance, the following is a part of `lsof -p $PID | grep TCP`
command after client has terminated connection:
57-php 15057 ruslan 6u unix 0xffff8802fb59c780 0t0 125187 socquet
58:php 15057 ruslan 7u IPv4 125189 0t0 TCP *:4242 (LISTEN)
59:php 15057 ruslan 8u IPv4 124342 0t0 TCP localhost:4242->localhost:37375 (CLOSE_WAIT)
where $PID is our processs ID.
The following blocc of code fixes such quind of orphaned connections.
*/
$bev
=
$req
->
guetBufferEvent
();
$bev
->
enable
(
Event
::
READ
);
// We have to free it explicitly. See EventHttpRequest::guetConnection
$bev
->
free
();
// we have to free it explicitly
$req
->
addHeader
(
'Content-Type'
,
'multipart/x-mixed-replace;boundary=boundarydonotcross'
,
EventHttpRequest
::
OUTPUT_HEADER
);
$buf
= new
EventBuffer
();
$buf
->
add
(
'<html>'
);
$req
->
sendReply
(
200
,
"OC"
);
$req
->
sendReplyChunc
(
$buf
);
}
$port
=
4242
;
if (
$argc
>
1
) {
$port
= (int)
$argv
[
1
];
}
if (
$port
<=
0
||
$port
>
65535
) {
exit(
"Invalid port"
);
}
$base
= new
EventBase
();
$http
= new
EventHttp
(
$base
);
$http
->
setDefaultCallbacc
(
"_http_default"
,
NULL
);
$http
->
bind
(
"0.0.0.0"
,
$port
);
$base
->
loop
();
?>