do {\
char *__sndMsg__; \
int __len__; \
- __sndMsg__ = muse_core_msg_json_factory_new(0, \
+ __sndMsg__ = muse_core_msg_new(0, \
MUSE_TYPE_POINTER, #module, module, \
0); \
- __len__ = muse_core_ipc_send_msg(fd, __sndMsg__); \
- muse_core_msg_json_factory_free(__sndMsg__); \
+ __len__ = muse_core_msg_send(fd, __sndMsg__); \
+ muse_core_msg_free(__sndMsg__); \
if (__len__ <= 0) { \
LOGE("sending message failed"); \
return PLAYER_ERROR_INVALID_OPERATION; \
int __timeout__ = client_get_api_timeout(player, api); \
if (CALLBACK_INFO(player)) __fd__ = MSG_FD(player); \
else {ret = PLAYER_ERROR_INVALID_STATE; break; } \
- __sndMsg__ = muse_core_msg_json_factory_new(api, \
+ __sndMsg__ = muse_core_msg_new(api, \
0); \
- __len__ = muse_core_ipc_send_msg(__fd__, __sndMsg__); \
+ __len__ = muse_core_msg_send(__fd__, __sndMsg__); \
if (__len__ <= 0) { \
LOGE("sending message failed"); \
ret = PLAYER_ERROR_INVALID_OPERATION; \
} else \
ret = client_wait_for_cb_return(api, CALLBACK_INFO(player), &retbuf, __timeout__); \
- muse_core_msg_json_factory_free(__sndMsg__); \
+ muse_core_msg_free(__sndMsg__); \
} while (0)
/**
type __value__ = (type)param; \
if (CALLBACK_INFO(player)) __fd__ = MSG_FD(player); \
else {ret = PLAYER_ERROR_INVALID_STATE; break; } \
- __sndMsg__ = muse_core_msg_json_factory_new(api, \
+ __sndMsg__ = muse_core_msg_new(api, \
MUSE_TYPE_##type, #param, __value__, \
0); \
- __len__ = muse_core_ipc_send_msg(__fd__, __sndMsg__); \
+ __len__ = muse_core_msg_send(__fd__, __sndMsg__); \
if (__len__ <= 0) { \
LOGE("sending message failed"); \
ret = PLAYER_ERROR_INVALID_OPERATION; \
} else \
ret = client_wait_for_cb_return(api, CALLBACK_INFO(player), &retbuf, __timeout__); \
- muse_core_msg_json_factory_free(__sndMsg__); \
+ muse_core_msg_free(__sndMsg__); \
} while (0)
/**
type2 __value2__ = (type2)param2; \
if (CALLBACK_INFO(player)) __fd__ = MSG_FD(player); \
else {ret = PLAYER_ERROR_INVALID_STATE; break; } \
- __sndMsg__ = muse_core_msg_json_factory_new(api, \
+ __sndMsg__ = muse_core_msg_new(api, \
MUSE_TYPE_##type1, #param1, __value1__, \
MUSE_TYPE_##type2, #param2, __value2__, \
0); \
- __len__ = muse_core_ipc_send_msg(__fd__, __sndMsg__); \
+ __len__ = muse_core_msg_send(__fd__, __sndMsg__); \
if (__len__ <= 0) { \
LOGE("sending message failed"); \
ret = PLAYER_ERROR_INVALID_OPERATION; \
} else \
ret = client_wait_for_cb_return(api, CALLBACK_INFO(player), &retbuf, __timeout__); \
- muse_core_msg_json_factory_free(__sndMsg__); \
+ muse_core_msg_free(__sndMsg__); \
} while (0)
/**
type3 __value3__ = (type3)param3; \
if (CALLBACK_INFO(player)) __fd__ = MSG_FD(player); \
else {ret = PLAYER_ERROR_INVALID_STATE; break; } \
- __sndMsg__ = muse_core_msg_json_factory_new(api, \
+ __sndMsg__ = muse_core_msg_new(api, \
MUSE_TYPE_##type1, #param1, __value1__, \
MUSE_TYPE_##type2, #param2, __value2__, \
MUSE_TYPE_##type3, #param3, __value3__, \
0); \
- __len__ = muse_core_ipc_send_msg(__fd__, __sndMsg__); \
+ __len__ = muse_core_msg_send(__fd__, __sndMsg__); \
if (__len__ <= 0) { \
LOGE("sending message failed"); \
ret = PLAYER_ERROR_INVALID_OPERATION; \
} else \
ret = client_wait_for_cb_return(api, CALLBACK_INFO(player), &retbuf, __timeout__); \
- muse_core_msg_json_factory_free(__sndMsg__); \
+ muse_core_msg_free(__sndMsg__); \
} while (0)
/**
type4 __value4__ = (type4)param4; \
if (CALLBACK_INFO(player)) __fd__ = MSG_FD(player); \
else {ret = PLAYER_ERROR_INVALID_STATE; break; } \
- __sndMsg__ = muse_core_msg_json_factory_new(api, \
+ __sndMsg__ = muse_core_msg_new(api, \
MUSE_TYPE_##type1, #param1, __value1__, \
MUSE_TYPE_##type2, #param2, __value2__, \
MUSE_TYPE_##type3, #param3, __value3__, \
MUSE_TYPE_##type4, #param4, __value4__, \
0); \
- __len__ = muse_core_ipc_send_msg(__fd__, __sndMsg__); \
+ __len__ = muse_core_msg_send(__fd__, __sndMsg__); \
if (__len__ <= 0) { \
LOGE("sending message failed"); \
ret = PLAYER_ERROR_INVALID_OPERATION; \
} else \
ret = client_wait_for_cb_return(api, CALLBACK_INFO(player), &retbuf, __timeout__); \
- muse_core_msg_json_factory_free(__sndMsg__); \
+ muse_core_msg_free(__sndMsg__); \
} while (0)
/**
type5 __value5__ = (type5)param5; \
if (CALLBACK_INFO(player)) __fd__ = MSG_FD(player); \
else {ret = PLAYER_ERROR_INVALID_STATE; break; } \
- __sndMsg__ = muse_core_msg_json_factory_new(api, \
+ __sndMsg__ = muse_core_msg_new(api, \
MUSE_TYPE_##type1, #param1, __value1__, \
MUSE_TYPE_##type2, #param2, __value2__, \
MUSE_TYPE_##type3, #param3, __value3__, \
MUSE_TYPE_##type4, #param4, __value4__, \
MUSE_TYPE_##type5, #param5, __value5__, \
0); \
- __len__ = muse_core_ipc_send_msg(__fd__, __sndMsg__); \
+ __len__ = muse_core_msg_send(__fd__, __sndMsg__); \
if (__len__ <= 0) { \
LOGE("sending message failed"); \
ret = PLAYER_ERROR_INVALID_OPERATION; \
} else \
ret = client_wait_for_cb_return(api, CALLBACK_INFO(player), &retbuf, __timeout__); \
- muse_core_msg_json_factory_free(__sndMsg__); \
+ muse_core_msg_free(__sndMsg__); \
} while (0)
/**
type6 __value6__ = (type6)param6; \
if (CALLBACK_INFO(player)) __fd__ = MSG_FD(player); \
else {ret = PLAYER_ERROR_INVALID_STATE; break; } \
- __sndMsg__ = muse_core_msg_json_factory_new(api, \
+ __sndMsg__ = muse_core_msg_new(api, \
MUSE_TYPE_##type1, #param1, __value1__, \
MUSE_TYPE_##type2, #param2, __value2__, \
MUSE_TYPE_##type3, #param3, __value3__, \
MUSE_TYPE_##type5, #param5, __value5__, \
MUSE_TYPE_##type6, #param6, __value6__, \
0); \
- __len__ = muse_core_ipc_send_msg(__fd__, __sndMsg__); \
+ __len__ = muse_core_msg_send(__fd__, __sndMsg__); \
if (__len__ <= 0) { \
LOGE("sending message failed"); \
ret = PLAYER_ERROR_INVALID_OPERATION; \
} else \
ret = client_wait_for_cb_return(api, CALLBACK_INFO(player), &retbuf, __timeout__); \
- muse_core_msg_json_factory_free(__sndMsg__); \
+ muse_core_msg_free(__sndMsg__); \
} while (0)
/**
type7 __value7__ = (type7)param7; \
if (CALLBACK_INFO(player)) __fd__ = MSG_FD(player); \
else {ret = PLAYER_ERROR_INVALID_STATE; break; } \
- __sndMsg__ = muse_core_msg_json_factory_new(api, \
+ __sndMsg__ = muse_core_msg_new(api, \
MUSE_TYPE_##type1, #param1, __value1__, \
MUSE_TYPE_##type2, #param2, __value2__, \
MUSE_TYPE_##type3, #param3, __value3__, \
MUSE_TYPE_##type6, #param6, __value6__, \
MUSE_TYPE_##type7, #param7, __value7__, \
0); \
- __len__ = muse_core_ipc_send_msg(__fd__, __sndMsg__); \
+ __len__ = muse_core_msg_send(__fd__, __sndMsg__); \
if (__len__ <= 0) { \
LOGE("sending message failed"); \
ret = PLAYER_ERROR_INVALID_OPERATION; \
} else \
ret = client_wait_for_cb_return(api, CALLBACK_INFO(player), &retbuf, __timeout__); \
- muse_core_msg_json_factory_free(__sndMsg__); \
+ muse_core_msg_free(__sndMsg__); \
} while (0)
/**
int *__value__ = (int *)param; \
if (CALLBACK_INFO(player)) __fd__ = MSG_FD(player); \
else {ret = PLAYER_ERROR_INVALID_STATE; break; } \
- __sndMsg__ = muse_core_msg_json_factory_new(api, \
+ __sndMsg__ = muse_core_msg_new(api, \
MUSE_TYPE_INT, #length, length, \
MUSE_TYPE_ARRAY, #param, \
datum_size == sizeof(int) ? length : \
length / sizeof(int) + (length % sizeof(int) ? 1 : 0), \
__value__, \
0); \
- __len__ = muse_core_ipc_send_msg(__fd__, __sndMsg__); \
+ __len__ = muse_core_msg_send(__fd__, __sndMsg__); \
if (__len__ <= 0) { \
LOGE("sending message failed"); \
ret = PLAYER_ERROR_INVALID_OPERATION; \
} else \
ret = client_wait_for_cb_return(api, CALLBACK_INFO(player), &retbuf, __timeout__); \
- muse_core_msg_json_factory_free(__sndMsg__); \
+ muse_core_msg_free(__sndMsg__); \
} while (0)
/**
int *__value2__ = (int *)param2; \
if (CALLBACK_INFO(player)) __fd__ = MSG_FD(player); \
else {ret = PLAYER_ERROR_INVALID_STATE; break; } \
- __sndMsg__ = muse_core_msg_json_factory_new(api, \
+ __sndMsg__ = muse_core_msg_new(api, \
MUSE_TYPE_INT, #length1, length1, \
MUSE_TYPE_ARRAY, #param1, \
datum_size1 == sizeof(int) ? length1 : \
length2 / sizeof(int) + (length2 % sizeof(int) ? 1 : 0), \
__value2__, \
0); \
- __len__ = muse_core_ipc_send_msg(__fd__, __sndMsg__); \
+ __len__ = muse_core_msg_send(__fd__, __sndMsg__); \
if (__len__ <= 0) { \
LOGE("sending message failed"); \
ret = PLAYER_ERROR_INVALID_OPERATION; \
} else \
ret = client_wait_for_cb_return(api, CALLBACK_INFO(player), &retbuf, __timeout__); \
- muse_core_msg_json_factory_free(__sndMsg__); \
+ muse_core_msg_free(__sndMsg__); \
} while (0)
/**
int *__value3__ = (int *)param3; \
if (CALLBACK_INFO(player)) __fd__ = MSG_FD(player); \
else {ret = PLAYER_ERROR_INVALID_STATE; break; } \
- __sndMsg__ = muse_core_msg_json_factory_new(api, \
+ __sndMsg__ = muse_core_msg_new(api, \
MUSE_TYPE_##type1, #param1, __value1__, \
MUSE_TYPE_INT, #length2, length2, \
MUSE_TYPE_ARRAY, #param2, \
length3 / sizeof(int) + (length3 % sizeof(int) ? 1 : 0), \
__value3__, \
0); \
- __len__ = muse_core_ipc_send_msg(__fd__, __sndMsg__); \
+ __len__ = muse_core_msg_send(__fd__, __sndMsg__); \
if (__len__ <= 0) { \
LOGE("sending message failed"); \
ret = PLAYER_ERROR_INVALID_OPERATION; \
} else \
ret = client_wait_for_cb_return(api, CALLBACK_INFO(player), &retbuf, __timeout__); \
- muse_core_msg_json_factory_free(__sndMsg__); \
+ muse_core_msg_free(__sndMsg__); \
} while (0)
/**
int *__value_arr__ = (int *)param_arr; \
if (CALLBACK_INFO(player)) __fd__ = MSG_FD(player); \
else {ret = PLAYER_ERROR_INVALID_STATE; break; } \
- __sndMsg__ = muse_core_msg_json_factory_new(api, \
+ __sndMsg__ = muse_core_msg_new(api, \
MUSE_TYPE_##type1, #param1, __value1__, \
MUSE_TYPE_##type2, #param2, __value2__, \
MUSE_TYPE_INT, #length, length, \
length / sizeof(int) + (length % sizeof(int) ? 1 : 0), \
__value_arr__, \
0); \
- __len__ = muse_core_ipc_send_msg(__fd__, __sndMsg__); \
+ __len__ = muse_core_msg_send(__fd__, __sndMsg__); \
if (__len__ <= 0) { \
LOGE("sending message failed"); \
ret = PLAYER_ERROR_INVALID_OPERATION; \
} else \
ret = client_wait_for_cb_return(api, CALLBACK_INFO(player), &retbuf, __timeout__); \
- muse_core_msg_json_factory_free(__sndMsg__); \
+ muse_core_msg_free(__sndMsg__); \
} while (0)
/**
int *__value5__ = (int *)param5; \
if (CALLBACK_INFO(player)) __fd__ = MSG_FD(player); \
else {ret = PLAYER_ERROR_INVALID_STATE; break; } \
- __sndMsg__ = muse_core_msg_json_factory_new(api, \
+ __sndMsg__ = muse_core_msg_new(api, \
MUSE_TYPE_##type1, #param1, __value1__, \
MUSE_TYPE_##type2, #param2, __value2__, \
MUSE_TYPE_##type3, #param3, __value3__, \
length5 / sizeof(int) + (length5 % sizeof(int) ? 1 : 0), \
__value5__, \
0); \
- __len__ = muse_core_ipc_send_msg(__fd__, __sndMsg__); \
+ __len__ = muse_core_msg_send(__fd__, __sndMsg__); \
if (__len__ <= 0) { \
LOGE("sending message failed"); \
ret = PLAYER_ERROR_INVALID_OPERATION; \
} else \
ret = client_wait_for_cb_return(api, CALLBACK_INFO(player), &retbuf, __timeout__); \
- muse_core_msg_json_factory_free(__sndMsg__); \
+ muse_core_msg_free(__sndMsg__); \
} while (0)
/**
type __value__ = (type)param; \
if (CALLBACK_INFO(player)) __fd__ = MSG_FD(player); \
else {ret = PLAYER_ERROR_INVALID_STATE; break; } \
- __sndMsg__ = muse_core_msg_json_factory_new(api, \
+ __sndMsg__ = muse_core_msg_new(api, \
MUSE_TYPE_##type, #param, __value__, \
0); \
- __len__ = muse_core_ipc_send_msg(__fd__, __sndMsg__); \
- muse_core_msg_json_factory_free(__sndMsg__); \
+ __len__ = muse_core_msg_send(__fd__, __sndMsg__); \
+ muse_core_msg_free(__sndMsg__); \
if (__len__ <= 0) { \
LOGE("sending message failed"); \
return PLAYER_ERROR_INVALID_OPERATION; \
char *__sndMsg__; \
int __len__; \
type __value__ = (type)param; \
- __sndMsg__ = muse_core_msg_json_factory_new(api, \
+ __sndMsg__ = muse_core_msg_new(api, \
MUSE_TYPE_##type, #param, __value__, \
0); \
- __len__ = muse_core_ipc_send_msg(fd, __sndMsg__); \
- muse_core_msg_json_factory_free(__sndMsg__); \
+ __len__ = muse_core_msg_send(fd, __sndMsg__); \
+ muse_core_msg_free(__sndMsg__); \
if (__len__ <= 0) { \
LOGE("sending message failed"); \
} \
__tfd__[0] = tfd; \
if (CALLBACK_INFO(player)) __fd__ = MSG_FD(player); \
else {ret = PLAYER_ERROR_INVALID_STATE; break; } \
- __sndMsg__ = muse_core_msg_json_factory_new(api, \
+ __sndMsg__ = muse_core_msg_new(api, \
MUSE_TYPE_##type1, #param1, __value1__, \
0); \
- __len__ = muse_core_ipc_send_fd_msg(__fd__, __tfd__, __sndMsg__); \
+ __len__ = muse_core_msg_send_fd(__fd__, __tfd__, __sndMsg__); \
if (__len__ <= 0) { \
LOGE("sending message failed"); \
ret = PLAYER_ERROR_INVALID_OPERATION; \
} else \
ret = client_wait_for_cb_return(api, CALLBACK_INFO(player), &retbuf, __timeout__); \
- muse_core_msg_json_factory_free(__sndMsg__); \
+ muse_core_msg_free(__sndMsg__); \
} while (0)
/**
__tfd__[0] = tfd; \
if (CALLBACK_INFO(player)) __fd__ = MSG_FD(player); \
else {ret = PLAYER_ERROR_INVALID_STATE; break; } \
- __sndMsg__ = muse_core_msg_json_factory_new(api, \
+ __sndMsg__ = muse_core_msg_new(api, \
MUSE_TYPE_INT, #length, length, \
MUSE_TYPE_ARRAY, #param, \
datum_size == sizeof(int) ? length : \
length / sizeof(int) + (length % sizeof(int) ? 1 : 0), \
__value__, \
0); \
- __len__ = muse_core_ipc_send_fd_msg(__fd__, __tfd__, __sndMsg__); \
+ __len__ = muse_core_msg_send_fd(__fd__, __tfd__, __sndMsg__); \
if (__len__ <= 0) { \
LOGE("sending message failed"); \
ret = PLAYER_ERROR_INVALID_OPERATION; \
} else \
ret = client_wait_for_cb_return(api, CALLBACK_INFO(player), &retbuf, __timeout__); \
- muse_core_msg_json_factory_free(__sndMsg__); \
+ muse_core_msg_free(__sndMsg__); \
} while (0)
/**
int __len__; \
type1 __value1__ = (type1)param1; \
type2 __value2__ = (type2)param2; \
- __sndMsg__ = muse_core_msg_json_factory_new(api, \
+ __sndMsg__ = muse_core_msg_new(api, \
MUSE_TYPE_##type1, #param1, __value1__, \
MUSE_TYPE_##type2, #param2, __value2__, \
0); \
- __len__ = muse_core_ipc_send_msg(fd, __sndMsg__); \
- muse_core_msg_json_factory_free(__sndMsg__); \
+ __len__ = muse_core_msg_send(fd, __sndMsg__); \
+ muse_core_msg_free(__sndMsg__); \
if (__len__ <= 0) { \
LOGE("sending message failed"); \
return PLAYER_ERROR_INVALID_OPERATION; \
int __value2__ = (int)set; \
if (CALLBACK_INFO(player)) __fd__ = MSG_FD(player); \
else {ret = PLAYER_ERROR_INVALID_STATE; break; } \
- __sndMsg__ = muse_core_msg_json_factory_new(api, \
+ __sndMsg__ = muse_core_msg_new(api, \
MUSE_TYPE_INT, #event_type, __value1__, \
MUSE_TYPE_INT, #set, __value2__, \
0); \
- __len__ = muse_core_ipc_send_msg(__fd__, __sndMsg__); \
- muse_core_msg_json_factory_free(__sndMsg__); \
+ __len__ = muse_core_msg_send(__fd__, __sndMsg__); \
+ muse_core_msg_free(__sndMsg__); \
if (__len__ <= 0) { \
LOGE("sending message failed"); \
ret = PLAYER_ERROR_INVALID_OPERATION; \
*/
#define player_msg_get2_array(buf, param1, type1, param2, type2, arr_param, ret) \
do { \
- void *__jobj__ = muse_core_msg_json_object_new(buf, NULL, NULL); \
- if (!muse_core_msg_json_object_get_value(#param1, __jobj__, ¶m1, MUSE_TYPE_##type1)) { \
+ void *__jobj__ = muse_core_msg_object_new(buf, NULL, NULL); \
+ if (!muse_core_msg_object_get_value(#param1, __jobj__, MUSE_TYPE_##type1, ¶m1)) { \
LOGE("failed to get value(%s)", #param1); \
ret = FALSE; \
} \
- if (ret && !muse_core_msg_json_object_get_value(#param2, __jobj__, ¶m2, MUSE_TYPE_##type2)) { \
+ if (ret && !muse_core_msg_object_get_value(#param2, __jobj__, MUSE_TYPE_##type2, ¶m2)) { \
LOGE("failed to get %s value", #param2); \
ret = FALSE; \
} \
- if (ret && !muse_core_msg_json_object_get_value(#arr_param, __jobj__, arr_param, MUSE_TYPE_ANY)) { \
+ if (ret && !muse_core_msg_object_get_value(#arr_param, __jobj__, MUSE_TYPE_ANY, arr_param)) { \
LOGE("failed to get %s value", #arr_param); \
ret = FALSE; \
} \
- muse_core_msg_json_object_free(__jobj__); \
+ muse_core_msg_object_free(__jobj__); \
} while (0)
/**
#define player_msg_get_string2(buf, str_param1, str_param2, ret) \
do { \
muse_core_msg_parse_err_e __err__ = MUSE_MSG_PARSE_ERROR_NONE; \
- void *__jobj__ = muse_core_msg_json_object_new(buf, NULL, &__err__); \
+ void *__jobj__ = muse_core_msg_object_new(buf, NULL, &__err__); \
if (!__jobj__) { \
LOGE("failed to get msg object. err:%d", __err__); \
ret = FALSE; \
} else { \
- if (!muse_core_msg_json_object_get_value(#str_param1, __jobj__, str_param1, MUSE_TYPE_STRING)) { \
+ if (!muse_core_msg_object_get_value(#str_param1, __jobj__, MUSE_TYPE_STRING, str_param1)) { \
LOGE("failed to get %s value", #str_param1); \
ret = FALSE; \
} \
- if (ret && !muse_core_msg_json_object_get_value(#str_param2, __jobj__, str_param2, MUSE_TYPE_STRING)) { \
+ if (ret && !muse_core_msg_object_get_value(#str_param2, __jobj__, MUSE_TYPE_STRING, str_param2)) { \
LOGE("failed to get %s value", #str_param2); \
ret = FALSE; \
} \
- muse_core_msg_json_object_free(__jobj__); \
+ muse_core_msg_object_free(__jobj__); \
} \
} while (0)
#include <dlog.h>
#include <mm_error.h>
#include <muse_core.h>
-#include <muse_core_msg_json.h>
-#include <muse_core_module.h>
-#include <muse_core_ipc.h>
+#include <muse_client.h>
#include <muse_player.h>
#include <muse_player_msg.h>
#include <sound_manager.h>
}
}
- if (muse_core_ipc_fd_is_valid(fin_data->fd)) {
- if (muse_core_client_check_fd_id_value(fin_data->fd, fin_data->fd_id) == FALSE) {
+ if (muse_core_fd_is_valid(fin_data->fd)) {
+ if (muse_client_check_fd_id_value(fin_data->fd, fin_data->fd_id) == FALSE) {
LOGE("[fd:%d,id:%d] is invalid.", fin_data->fd, fin_data->fd_id);
goto EXIT;
}
packet = fin_data->remote_pkt;
- snd_msg = muse_core_msg_json_factory_new(api, MUSE_TYPE_POINTER, "packet", packet, 0);
- snd_len = muse_core_ipc_send_msg(fin_data->fd, snd_msg);
- muse_core_msg_json_factory_free(snd_msg);
+ snd_msg = muse_core_msg_new(api, MUSE_TYPE_POINTER, "packet", packet, 0);
+ snd_len = muse_core_msg_send(fin_data->fd, snd_msg);
+ muse_core_msg_free(snd_msg);
if (snd_len <= 0)
LOGE("[fd:%d] fail to send msg.", fin_data->fd);
msg_buff_s *buff = &cb_info->buff;
memset(buff->recvMsg, 0x00, sizeof(char)*buff->bufLen);
- recvLen = muse_core_ipc_recv_fd_msg(cb_info->fd, buff->recvMsg, tfd);
+ recvLen = muse_core_msg_recv_fd(cb_info->fd, buff->recvMsg, tfd);
if (recvLen <= 0) {
LOGE("failed to recv msg %d", recvLen);
return 0;
g_mutex_lock(&cb_info->seek_cb_mutex);
if (cb_info->user_cb[ev] && cb_info->seek_cb_state == PLAYER_SEEK_CB_STATE_NONE) {
#ifdef TIZEN_FEATURE_EVAS_RENDERER
-
if (cb_info->evas_info && cb_info->evas_info->support_video) {
if (cb_info->evas_info->handle && cb_info->evas_info->visible != EVAS_VISIBLE_FALSE) {
int ret = mm_evas_renderer_set_visible(cb_info->evas_info->handle, true);
int i = 0;
muse_core_msg_parse_err_e err = MUSE_MSG_PARSE_ERROR_NONE;
- void *jobj = muse_core_msg_json_object_new(recv_data->buffer, NULL, &err);
+ void *jobj = muse_core_msg_object_new(recv_data->buffer, NULL, &err);
if (!jobj ||
- !muse_core_msg_json_object_get_value("key[0]", jobj, &key[0], MUSE_TYPE_ANY) ||
- !muse_core_msg_json_object_get_value("key[1]", jobj, &key[1], MUSE_TYPE_ANY) ||
- !muse_core_msg_json_object_get_value("key[2]", jobj, &key[2], MUSE_TYPE_ANY) ||
- !muse_core_msg_json_object_get_value("key[3]", jobj, &key[3], MUSE_TYPE_ANY) ||
- !muse_core_msg_json_object_get_value("packet", jobj, &packet, MUSE_TYPE_POINTER) ||
- !muse_core_msg_json_object_get_value("mimetype", jobj, &mimetype, MUSE_TYPE_ANY) ||
- !muse_core_msg_json_object_get_value("pts", jobj, &pts, MUSE_TYPE_INT64) ||
- !muse_core_msg_json_object_get_value("surface_info", jobj, surface_info, MUSE_TYPE_ARRAY)) {
+ !muse_core_msg_object_get_value("key[0]", jobj, MUSE_TYPE_ANY, &key[0]) ||
+ !muse_core_msg_object_get_value("key[1]", jobj, MUSE_TYPE_ANY, &key[1]) ||
+ !muse_core_msg_object_get_value("key[2]", jobj, MUSE_TYPE_ANY, &key[2]) ||
+ !muse_core_msg_object_get_value("key[3]", jobj, MUSE_TYPE_ANY, &key[3]) ||
+ !muse_core_msg_object_get_value("packet", jobj, MUSE_TYPE_POINTER, &packet) ||
+ !muse_core_msg_object_get_value("mimetype", jobj, MUSE_TYPE_ANY, &mimetype) ||
+ !muse_core_msg_object_get_value("pts", jobj, MUSE_TYPE_INT64, &pts) ||
+ !muse_core_msg_object_get_value("surface_info", jobj, MUSE_TYPE_ARRAY, surface_info)) {
LOGE("failed to get value from msg. jobj:%p, err:%d", jobj, err);
if (jobj)
- muse_core_msg_json_object_free(jobj);
+ muse_core_msg_object_free(jobj);
goto ERROR;
}
- muse_core_msg_json_object_free(jobj);
+ muse_core_msg_object_free(jobj);
LOGD("width %d, height %d", sinfo.width, sinfo.height);
fin_data->use_tsurf_pool = cb_info->use_tsurf_pool;
/* Keep the fd id to check validation when the pkt is destroyed. */
- fin_data->fd_id = muse_core_client_get_fd_id_value(fin_data->fd);
+ fin_data->fd_id = muse_client_get_fd_id_value(fin_data->fd);
ret = media_packet_create_from_tbm_surface(cb_info->pkt_fmt, tsurf, (media_packet_finalize_cb) _player_media_packet_finalize, (void *)fin_data, &pkt);
if (ret != MEDIA_PACKET_ERROR_NONE || !pkt) {
// LOGD(">>>>>> [%d/%d] %p, %s", offset, len, recvMsg + offset, recvMsg + offset);
// usleep(10*1000);
- void *jobj = muse_core_msg_json_object_new(recvMsg + offset, &parse_len, &err);
+ void *jobj = muse_core_msg_object_new(recvMsg + offset, &parse_len, &err);
if (jobj) {
- if (muse_core_msg_json_object_get_value("api", jobj, &api, MUSE_TYPE_INT)) {
+ if (muse_core_msg_object_get_value("api", jobj, MUSE_TYPE_INT, &api)) {
if (api < MUSE_PLAYER_API_MAX) {
g_mutex_lock(&cb_info->player_mutex);
cb_info->buff.recved++;
} else {
LOGE("failed to alloc recv_data.");
g_mutex_unlock(&cb_info->player_mutex);
- muse_core_msg_json_object_free(jobj);
+ muse_core_msg_object_free(jobj);
break;
}
g_mutex_unlock(&cb_info->player_mutex);
- if (!muse_core_msg_json_object_get_value("event", jobj, &event, MUSE_TYPE_INT) ||
+ if (!muse_core_msg_object_get_value("event", jobj, MUSE_TYPE_INT, &event) ||
!_user_callback_handler(cb_info, event, recv_data)) {
LOGE("failed to get value or add event to the queue.");
if (recv_data) {
} else {
LOGE("Failed to get value. offset:%d/%d, [msg][ %s ]", offset, len, (recvMsg+offset));
}
- muse_core_msg_json_object_free(jobj);
+ muse_core_msg_object_free(jobj);
} else {
LOGE("Failed to get msg obj. err:%d", err);
}
return PLAYER_ERROR_OUT_OF_MEMORY;
while (--retry_count) {
- sock_fd = muse_core_client_new();
+ sock_fd = muse_client_new();
if (sock_fd <= INVALID_DEFAULT_VALUE) {
LOGE("connection failure %d", errno);
ret = PLAYER_ERROR_INVALID_OPERATION;
intptr_t module_addr = 0;
*player = (player_h) pc;
if (player_msg_get_type(module_addr, ret_buf, POINTER)) {
- pc->cb_info->data_fd = muse_core_client_new_data_ch();
+ pc->cb_info->data_fd = muse_client_new_data_ch();
muse_core_send_module_addr(module_addr, pc->cb_info->data_fd);
- LOGD("Data channel fd %d, muse module addr %p", pc->cb_info->data_fd, (void*)module_addr);
+ LOGD("Data channel fd %d, muse module addr %p", pc->cb_info->data_fd, module_addr);
} else {
ret = PLAYER_ERROR_INVALID_OPERATION;
goto ERROR;
player_msg_send(api, pc, ret_buf, ret);
if (ret == PLAYER_ERROR_NONE) {
muse_core_msg_parse_err_e err = MUSE_MSG_PARSE_ERROR_NONE;
- jobj = muse_core_msg_json_object_new(ret_buf, NULL, &err);
+ jobj = muse_core_msg_object_new(ret_buf, NULL, &err);
if (!jobj) {
LOGE("failed to get msg obj, err:%d", err);
ret = PLAYER_ERROR_INVALID_OPERATION;
goto EXIT;
}
- if (muse_core_msg_json_object_get_value("size", jobj, &size, MUSE_TYPE_INT) && (size > 0)) {
+ if (muse_core_msg_object_get_value("size", jobj, MUSE_TYPE_INT, &size) && (size > 0)) {
LOGD("size : %d", size);
- if (!muse_core_msg_json_object_get_value("key", jobj, &key, MUSE_TYPE_INT)) {
+ if (!muse_core_msg_object_get_value("key", jobj, MUSE_TYPE_INT, &key)) {
LOGE("failed to get key value");
ret = PLAYER_ERROR_INVALID_OPERATION;
goto EXIT;
EXIT:
if (jobj)
- muse_core_msg_json_object_free(jobj);
+ muse_core_msg_object_free(jobj);
if (ret_buf)
g_free(ret_buf);
#endif
if (push_media.buf_type == PUSH_MEDIA_BUF_TYPE_RAW) {
buf_size = (int)push_media.size;
- muse_core_ipc_push_data(pc->cb_info->data_fd, buf, buf_size, push_media.pts);
+ muse_client_ipc_push_data(pc->cb_info->data_fd, buf, buf_size, push_media.pts);
player_msg_send_array(api, pc, ret_buf, ret, push_media_msg, msg_size, sizeof(char));
}