diff --git a/include/nnstreamer-edge-event.h b/include/nnstreamer-edge-event.h index e885615..c8c2a9a 100644 --- a/include/nnstreamer-edge-event.h +++ b/include/nnstreamer-edge-event.h @@ -30,6 +30,7 @@ typedef enum { NNS_EDGE_EVENT_NEW_DATA_RECEIVED, NNS_EDGE_EVENT_CALLBACK_RELEASED, NNS_EDGE_EVENT_CONNECTION_CLOSED, + NNS_EDGE_EVENT_CONNECTED, NNS_EDGE_EVENT_CUSTOM = 0x01000000 } nns_edge_event_e; diff --git a/src/libnnstreamer-edge/nnstreamer-edge-internal.c b/src/libnnstreamer-edge/nnstreamer-edge-internal.c index ac7c9db..d3b7f7f 100644 --- a/src/libnnstreamer-edge/nnstreamer-edge-internal.c +++ b/src/libnnstreamer-edge/nnstreamer-edge-internal.c @@ -1153,6 +1153,12 @@ _nns_edge_accept_socket (nns_edge_handle_s * eh) conn_data->sink_conn = conn; } + ret = nns_edge_event_invoke_callback (eh->event_cb, eh->user_data, + NNS_EDGE_EVENT_CONNECTED, NULL, 0, NULL); + if (ret != NNS_EDGE_ERROR_NONE) { + nns_edge_loge ("Failed to send an event for new connection."); + goto error; + } done = true; error: