int ms_ipc_create_server_socket(ms_msg_port_type_e port, int *sock_fd);
int ms_ipc_send_msg_to_server_tcp(int sockfd, ms_msg_port_type_e port, ms_comm_msg_s *send_msg, struct sockaddr_un *serv_addr);
int ms_ipc_send_msg_to_client_tcp(int sockfd, ms_comm_msg_s *send_msg, struct sockaddr_un *client_addr);
-int ms_ipc_receive_message_tcp(int client_sock, ms_comm_msg_s *recv_msg);
int ms_ipc_accept_client_tcp(int serv_sock, int* client_sock);
#ifdef __cplusplus
return MS_MEDIA_ERR_NONE;
}
-
-int ms_ipc_receive_message_tcp(int client_sock, ms_comm_msg_s *recv_msg)
-{
- int recv_msg_size = 0;
-
- if ((recv_msg_size = read(client_sock, recv_msg, sizeof(ms_comm_msg_s))) < 0) {
- MSAPI_DBG_STRERROR("recv failed");
- return MS_MEDIA_ERR_IPC;
- }
-
- MSAPI_DBG_SLOG("receive msg from P[%d] T[%d] M[%.*s]", recv_msg->pid, recv_msg->msg_type, MAX_MSG_SIZE, recv_msg->msg);
-
- if (strlen(recv_msg->msg) == 0 || strlen(recv_msg->msg) >= MAX_MSG_SIZE) {
- MSAPI_DBG_ERR("IPC message is wrong. message size is over MAX_MSG_SIZE");
- return MS_MEDIA_ERR_IPC;
- }
-
- return MS_MEDIA_ERR_NONE;
-}
-
ret = ms_cynara_receive_untrusted_message(client_sock, &recv_msg, &creds);
if (ret != MS_MEDIA_ERR_NONE) {
- MS_DBG_ERR("ms_ipc_receive_message_tcp failed [%d]", ret);
+ MS_DBG_ERR("ms_cynara_receive_untrusted_message failed [%d]", ret);
goto ERROR;
}