static gboolean __mc_service_process(gpointer data)
{
int length_of_queue = 0;
- int send_msg = MEDIA_CONTROLLER_ERROR_NONE;
+ int msg = MEDIA_CONTROLLER_ERROR_NONE;
mc_service_t *_service_data = (mc_service_t*)data;
mc_retvm_if(!_service_data, FALSE, "invalid data");
if (!MC_STRING_VALID(request_msg->msg) || request_msg->msg_size == 0) {
mc_error("Invalid message [msg:%s size:%zu]", request_msg->msg, request_msg->msg_size);
- send_msg = MEDIA_CONTROLLER_ERROR_INVALID_OPERATION;
+ msg = MEDIA_CONTROLLER_ERROR_INVALID_OPERATION;
goto ERROR;
}
if (!__mc_service_is_valid_connection(_service_data->connected_apps, request_msg)) {
mc_error("Wrong message");
- send_msg = MEDIA_CONTROLLER_ERROR_INVALID_OPERATION;
+ msg = MEDIA_CONTROLLER_ERROR_INVALID_OPERATION;
goto ERROR;
}
switch (request_msg->msg_type) {
case MC_MSG_DB_UPDATE:
- send_msg = mc_db_request(request_msg->uid, request_msg->msg, request_msg->msg_size);
+ msg = mc_db_request(request_msg->uid, request_msg->msg, request_msg->msg_size);
break;
case MC_MSG_CLIENT_SET:
- send_msg = __mc_service_add_cmd_to_send(&(_service_data->connected_apps), request_msg);
+ msg = __mc_service_add_cmd_to_send(&(_service_data->connected_apps), request_msg);
break;
case MC_MSG_CLIENT_GET:
- send_msg = __mc_service_remove_cmd_to_send(&(_service_data->connected_apps), request_msg);
+ msg = __mc_service_remove_cmd_to_send(&(_service_data->connected_apps), request_msg);
break;
case MC_MSG_SERVER_CONNECTION:
- send_msg = __mc_service_add_connection(&(_service_data->connected_apps), request_msg);
- if (send_msg == MEDIA_CONTROLLER_ERROR_NONE)
- send_msg = mc_db_add_application(request_msg->uid, request_msg->msg, request_msg->priv_type);
+ msg = __mc_service_add_connection(&(_service_data->connected_apps), request_msg);
+ if (msg == MEDIA_CONTROLLER_ERROR_NONE)
+ msg = mc_db_add_application(request_msg->uid, request_msg->msg, request_msg->priv_type);
break;
case MC_MSG_SERVER_DISCONNECTION:
__mc_service_remove_connection(&(_service_data->connected_apps), request_msg);
- send_msg = mc_db_remove_application(request_msg->uid, request_msg->msg, request_msg->priv_type);
+ msg = mc_db_remove_application(request_msg->uid, request_msg->msg, request_msg->priv_type);
break;
default:
mc_error("Invalid message type!");
- send_msg = MEDIA_CONTROLLER_ERROR_INVALID_OPERATION;
+ msg = MEDIA_CONTROLLER_ERROR_INVALID_OPERATION;
break;
}
ERROR:
- if (write(req->client_sock, &send_msg, sizeof(send_msg)) != sizeof(send_msg))
+ if (write(req->client_sock, &msg, sizeof(msg)) != sizeof(msg))
mc_stderror("send failed");
else
mc_debug("Sent successfully");
{
int sock = -1;
int client_sock = -1;
- int ret = MEDIA_CONTROLLER_ERROR_NONE;
- int send_msg = MEDIA_CONTROLLER_ERROR_NONE;
+ int msg = MEDIA_CONTROLLER_ERROR_NONE;
mc_service_request *req = NULL;
mc_service_t *_service_data = (mc_service_t*)data;
GQueue *request_queue = _service_data->request->queue;
}
/* get client socket fd */
- ret = mc_ipc_accept_client_tcp(sock, &(client_sock));
- if (ret != MEDIA_CONTROLLER_ERROR_NONE)
+ msg = mc_ipc_accept_client_tcp(sock, &(client_sock));
+ if (msg != MEDIA_CONTROLLER_ERROR_NONE)
return TRUE;
mc_peer_creds creds;
req->req_msg = g_new0(mc_comm_msg_s, 1);
req->client_sock = client_sock;
- ret = mc_cynara_receive_untrusted_message(req->client_sock, req->req_msg, &creds);
- if (ret != MEDIA_CONTROLLER_ERROR_NONE) {
- mc_error("mc_ipc_receive_message_tcp failed [%d]", ret);
- send_msg = ret;
+ msg = mc_cynara_receive_untrusted_message(req->client_sock, req->req_msg, &creds);
+ if (msg != MEDIA_CONTROLLER_ERROR_NONE) {
+ mc_error("mc_ipc_receive_message_tcp failed [%d]", msg);
goto ERROR;
}
if (req->req_msg->priv_type == MC_PRIV_TYPE_SERVER) {
- ret = mc_cynara_check(&creds, MC_SERVER_PRIVILEGE);
+ msg = mc_cynara_check(&creds, MC_SERVER_PRIVILEGE);
} else if (req->req_msg->priv_type == MC_PRIV_TYPE_CLIENT) {
- ret = mc_cynara_check(&creds, MC_CLIENT_PRIVILEGE);
+ msg = mc_cynara_check(&creds, MC_CLIENT_PRIVILEGE);
} else {
mc_error("invalid priv_type[%d]", req->req_msg->priv_type);
- send_msg = MEDIA_CONTROLLER_ERROR_INVALID_OPERATION;
+ msg = MEDIA_CONTROLLER_ERROR_INVALID_OPERATION;
goto ERROR;
}
- if (ret != MEDIA_CONTROLLER_ERROR_NONE) {
- mc_error("permission is denied![%d]", ret);
- send_msg = MEDIA_CONTROLLER_ERROR_PERMISSION_DENIED;
+ if (msg != MEDIA_CONTROLLER_ERROR_NONE) {
+ mc_error("permission is denied![%d]", msg);
+ msg = MEDIA_CONTROLLER_ERROR_PERMISSION_DENIED;
goto ERROR;
}
if (req->req_msg->msg_type < 0 || req->req_msg->msg_type >= MC_MSG_MAX) {
mc_error("invalid msg_type[%d]", req->req_msg->msg_type);
- send_msg = MEDIA_CONTROLLER_ERROR_INVALID_OPERATION;
+ msg = MEDIA_CONTROLLER_ERROR_INVALID_OPERATION;
goto ERROR;
}
if (g_queue_get_length(request_queue) >= MAX_MC_REQUEST) {
mc_error("request_queue is limited until %d", MAX_MC_REQUEST);
- send_msg = MEDIA_CONTROLLER_ERROR_INVALID_OPERATION;
+ msg = MEDIA_CONTROLLER_ERROR_INVALID_OPERATION;
goto ERROR;
}
return TRUE;
ERROR:
- if (write(client_sock, &send_msg, sizeof(send_msg)) != sizeof(send_msg))
+ if (write(client_sock, &msg, sizeof(msg)) != sizeof(msg))
mc_stderror("send failed");
else
mc_debug("Sent successfully");