forked/ustreamer
1
0
Fork 0
mirror of https://github.com/pikvm/ustreamer.git synced 2026-05-26 23:36:16 +00:00
Code Issues Packages Projects Releases Wiki Activity

report about stream clients

Browse Source
This commit is contained in:
Devaev Maxim
2018-09-30 06:27:58 +03:00
parent ec2a704ca0
commit e9ec65cfde
2 changed files with 21 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
src/http.c
View File

@@ -219,6 +219,8 @@ static void _http_callback_stream(struct evhttp_request *request, void *v_server
struct evhttp_connection *conn; struct evhttp_connection *conn;
struct bufferevent *buf_event; struct bufferevent *buf_event;
struct stream_client_t *client; struct stream_client_t *client;
char *client_addr;
unsigned short client_port;
PROCESS_HEAD_REQUEST; PROCESS_HEAD_REQUEST;
@@ -239,6 +241,13 @@ static void _http_callback_stream(struct evhttp_request *request, void *v_server
client->prev = last; client->prev = last;
last->next = client; last->next = client;
} }
++server->run->stream_clients_count;
evhttp_connection_get_peer(conn, &client_addr, &client_port);
LOG_INFO(
"HTTP: Registered the new stream client: [%s]:%u; clients now: %u",
client_addr, client_port, server->run->stream_clients_count
);
buf_event = evhttp_connection_get_bufferevent(conn); buf_event = evhttp_connection_get_bufferevent(conn);
bufferevent_setcb(buf_event, NULL, NULL, _http_callback_stream_error, (void *)client); bufferevent_setcb(buf_event, NULL, NULL, _http_callback_stream_error, (void *)client);
@@ -301,8 +310,19 @@ static void _http_callback_stream_write(struct bufferevent *buf_event, void *v_c
static void _http_callback_stream_error(UNUSED struct bufferevent *buf_event, UNUSED short what, void *v_client) { static void _http_callback_stream_error(UNUSED struct bufferevent *buf_event, UNUSED short what, void *v_client) {
struct stream_client_t *client = (struct stream_client_t *)v_client; struct stream_client_t *client = (struct stream_client_t *)v_client;
struct evhttp_connection *conn; struct evhttp_connection *conn;
char *client_addr = "???";
unsigned short client_port = 0;
--client->server->run->stream_clients_count;
conn = evhttp_request_get_connection(client->request); conn = evhttp_request_get_connection(client->request);
if (conn != NULL) {
evhttp_connection_get_peer(conn, &client_addr, &client_port);
}
LOG_INFO(
"HTTP: Disconnected the stream client: [%s]:%u; clients now: %u",
client_addr, client_port, client->server->run->stream_clients_count
);
if (conn != NULL) { if (conn != NULL) {
evhttp_connection_free(conn); evhttp_connection_free(conn);
} }

1
src/http.h
View File

@@ -54,6 +54,7 @@ struct http_server_runtime_t {
struct stream_t *stream; struct stream_t *stream;
struct exposed_t *exposed; struct exposed_t *exposed;
struct stream_client_t *stream_clients; struct stream_client_t *stream_clients;
unsigned stream_clients_count;
unsigned drop_same_frames_blank; unsigned drop_same_frames_blank;
}; };