#endif
typedef struct {
- int pid;
+ pid_t pid;
std::string appid;
} ma_client_s;
virtual ~CClientManager() {}
int set_application_manager(IApplicationManager* manager);
- int create_client(int pid, std::string appid);
- int destroy_client_by_pid(int pid);
+ int create_client(pid_t pid, std::string appid);
+ int destroy_client_by_pid(pid_t pid);
int destroy_client_by_appid(std::string appid);
int get_client_num();
- int find_client_pid_by_index(unsigned int index);
+ pid_t find_client_pid_by_index(unsigned int index);
- int find_client_pid_by_appid(std::string appid);
- std::string find_client_appid_by_pid(int pid);
+ pid_t find_client_pid_by_appid(std::string appid);
+ std::string find_client_appid_by_pid(pid_t pid);
bool check_client_validity_by_appid(std::string appid);
private:
ma_client_s* find_client_by_appid(std::string appid);
- ma_client_s* find_client_by_pid(int pid);
+ ma_client_s* find_client_by_pid(pid_t pid);
ma_client_s* get_client_by_index(unsigned int index);
int destroy_client(ma_client_s* client);
int open_connection();
int close_connection();
- int send_hello(int pid);
+ int send_hello(pid_t pid);
int send_error_message(int reason, const char* err_msg);
- int send_streaming_audio_data(int pid, int event, void* data, unsigned int data_size);
- int change_active_state(int pid, int state);
- int send_preprocessing_information(int pid, const char* app_id);
- int send_streaming_section_changed(int pid, int section);
- int send_preprocessing_result(int pid, bool result);
- int send_wakeup_engine_command(int pid, const char* command);
- int change_service_state(int pid, int state);
- int change_voice_key_status(int pid, int status);
+ int send_streaming_audio_data(pid_t pid, int event, void* data, unsigned int data_size);
+ int change_active_state(pid_t pid, int state);
+ int send_preprocessing_information(pid_t pid, const char* app_id);
+ int send_streaming_section_changed(pid_t pid, int section);
+ int send_preprocessing_result(pid_t pid, bool result);
+ int send_wakeup_engine_command(pid_t pid, const char* command);
+ int change_service_state(pid_t pid, int state);
+ int change_voice_key_status(pid_t pid, int status);
int masc_ui_dbus_send_hello(void);
- int masc_ui_dbus_send_asr_result(int pid, int event, const char* asr_result);
- int masc_ui_dbus_send_result(int pid, const char* display_text, const char* utterance_text, const char* result_json);
+ int masc_ui_dbus_send_asr_result(pid_t pid, int event, const char* asr_result);
+ int masc_ui_dbus_send_result(pid_t pid, const char* display_text, const char* utterance_text, const char* result_json);
int masc_ui_dbus_change_assistant(const char* app_id);
int masc_ui_dbus_send_error_message(int reason, const char* err_msg);
- int masc_ui_dbus_send_recognition_result(int pid, int result);
+ int masc_ui_dbus_send_recognition_result(pid_t pid, int result);
int masc_ui_dbus_enable_common_ui(int enable);
DBusConnection* get_connection_listener() { return mConnectionListener; }
class IServiceIpcObserver {
public:
- virtual int on_initialize(int pid) = 0;
- virtual int on_deinitialize(int pid) = 0;
- virtual int on_get_audio_format(int pid, int& rate, int& channel, int& audio_type) = 0;
- virtual int on_get_audio_source_type(int pid, std::string& type) = 0;
- virtual int on_send_asr_result(int pid, int event, std::string asr_result) = 0;
- virtual int on_send_result(int pid,
+ virtual int on_initialize(pid_t pid) = 0;
+ virtual int on_deinitialize(pid_t pid) = 0;
+ virtual int on_get_audio_format(pid_t pid, int& rate, int& channel, int& audio_type) = 0;
+ virtual int on_get_audio_source_type(pid_t pid, std::string& type) = 0;
+ virtual int on_send_asr_result(pid_t pid, int event, std::string asr_result) = 0;
+ virtual int on_send_result(pid_t pid,
std::string display_text, std::string utterance_text, std::string result_json) = 0;
- virtual int on_send_recognition_result(int pid, int result) = 0;
- virtual int on_start_streaming_audio_data(int pid, int type) = 0;
- virtual int on_stop_streaming_audio_data(int pid, int type) = 0;
- virtual int on_update_voice_feedback_state(int pid, int state) = 0;
- virtual int on_send_assistant_specific_command(int pid, std::string command) = 0;
- virtual int on_set_background_volume(int pid, double ratio) = 0;
- virtual int on_set_preprocessing_allow_mode(int pid, int mode, std::string app_id) = 0;
- virtual int on_send_preprocessing_result(int pid, int result) = 0;
- virtual int on_set_wake_word_audio_require_flag(int pid, int require) = 0;
- virtual int on_set_assistant_language(int pid, std::string language) = 0;
- virtual int on_add_wake_word(int pid, std::string wake_word, std::string language) = 0;
- virtual int on_remove_wake_word(int pid, std::string wake_word, std::string language) = 0;
+ virtual int on_send_recognition_result(pid_t pid, int result) = 0;
+ virtual int on_start_streaming_audio_data(pid_t pid, int type) = 0;
+ virtual int on_stop_streaming_audio_data(pid_t pid, int type) = 0;
+ virtual int on_update_voice_feedback_state(pid_t pid, int state) = 0;
+ virtual int on_send_assistant_specific_command(pid_t pid, std::string command) = 0;
+ virtual int on_set_background_volume(pid_t pid, double ratio) = 0;
+ virtual int on_set_preprocessing_allow_mode(pid_t pid, int mode, std::string app_id) = 0;
+ virtual int on_send_preprocessing_result(pid_t pid, int result) = 0;
+ virtual int on_set_wake_word_audio_require_flag(pid_t pid, int require) = 0;
+ virtual int on_set_assistant_language(pid_t pid, std::string language) = 0;
+ virtual int on_add_wake_word(pid_t pid, std::string wake_word, std::string language) = 0;
+ virtual int on_remove_wake_word(pid_t pid, std::string wake_word, std::string language) = 0;
- virtual int on_ui_initialize(int pid) = 0;
- virtual int on_ui_deinitialize(int pid) = 0;
+ virtual int on_ui_initialize(pid_t pid) = 0;
+ virtual int on_ui_deinitialize(pid_t pid) = 0;
virtual int on_ui_change_assistant(std::string app_id) = 0;
};
{}
virtual ~CServiceMain() {}
- int mas_client_get_audio_format(int pid, int* rate, int* channel, int* audio_type);
- int mas_client_get_audio_source_type(int pid, char** type);
- int mas_client_send_preprocessing_information(int pid);
- int mas_client_send_voice_key_status_change(int pid, ma_voice_key_status_e status);
- int mas_client_request_speech_data(int pid);
- int mas_client_send_asr_result(int pid, int event, const char* asr_result);
- int mas_client_send_result(int pid, const char* display_text,
+ int mas_client_get_audio_format(pid_t pid, int* rate, int* channel, int* audio_type);
+ int mas_client_get_audio_source_type(pid_t pid, char** type);
+ int mas_client_send_preprocessing_information(pid_t pid);
+ int mas_client_send_voice_key_status_change(pid_t pid, ma_voice_key_status_e status);
+ int mas_client_request_speech_data(pid_t pid);
+ int mas_client_send_asr_result(pid_t pid, int event, const char* asr_result);
+ int mas_client_send_result(pid_t pid, const char* display_text,
const char* utterance_text, const char* result_json);
- int mas_client_send_recognition_result(int pid, int result);
- int mas_client_start_streaming_audio_data(int pid, int type);
- int mas_client_stop_streaming_audio_data(int pid, int type);
- int mas_client_update_voice_feedback_state(int pid, int state);
- int mas_client_set_assistant_specific_command(int pid, const char *command);
- int mas_client_set_background_volume(int pid, double ratio);
- int mas_client_set_preprocessing_allow_mode(int pid, ma_preprocessing_allow_mode_e mode, const char* appid);
- int mas_client_send_preprocessing_result(int pid, bool result);
- int mas_client_set_wake_word_audio_require_flag(int pid, bool require);
- int mas_client_set_assistant_language(int pid, const char* language);
- int mas_client_add_wake_word(int pid, const char* wake_word, const char* language);
- int mas_client_remove_wake_word(int pid, const char* wake_word, const char* language);
- int mas_ui_client_initialize(int pid);
- int mas_ui_client_deinitialize(int pid);
+ int mas_client_send_recognition_result(pid_t pid, int result);
+ int mas_client_start_streaming_audio_data(pid_t pid, int type);
+ int mas_client_stop_streaming_audio_data(pid_t pid, int type);
+ int mas_client_update_voice_feedback_state(pid_t pid, int state);
+ int mas_client_set_assistant_specific_command(pid_t pid, const char *command);
+ int mas_client_set_background_volume(pid_t pid, double ratio);
+ int mas_client_set_preprocessing_allow_mode(pid_t pid, ma_preprocessing_allow_mode_e mode, const char* appid);
+ int mas_client_send_preprocessing_result(pid_t pid, bool result);
+ int mas_client_set_wake_word_audio_require_flag(pid_t pid, bool require);
+ int mas_client_set_assistant_language(pid_t pid, const char* language);
+ int mas_client_add_wake_word(pid_t pid, const char* wake_word, const char* language);
+ int mas_client_remove_wake_word(pid_t pid, const char* wake_word, const char* language);
+ int mas_ui_client_initialize(pid_t pid);
+ int mas_ui_client_deinitialize(pid_t pid);
int mas_ui_client_change_assistant(const char* appid);
- int mas_get_current_client_pid();
- int mas_get_current_preprocessing_client_pid();
+ pid_t mas_get_current_client_pid();
+ pid_t mas_get_current_preprocessing_client_pid();
pid_t mas_get_current_audio_processing_pid();
int mas_get_client_pid_by_wakeup_word(const char *wakeup_word);
int mas_get_client_pid_by_appid(const char *appid);
- std::string mas_get_client_appid_by_pid(int pid);
+ std::string mas_get_client_appid_by_pid(pid_t pid);
bool mas_get_client_custom_ui_option_by_appid(const char *appid);
const char* mas_get_client_appid_by_wakeup_word(const char *wakeup_word);
int mas_set_current_client_by_wakeup_word(const char *wakeup_word);
int mas_process_preprocessing_state_event(PREPROCESSING_STATE_EVENT event);
int mas_update_voice_key_support_mode();
- virtual int on_initialize(int pid) override;
- virtual int on_deinitialize(int pid) override;
- virtual int on_get_audio_format(int pid, int& rate, int& channel, int& audio_type) override;
- virtual int on_get_audio_source_type(int pid, std::string& type) override;
- virtual int on_send_asr_result(int pid, int event, std::string asr_result) override;
- virtual int on_send_result(int pid, std::string display_text,
+ virtual int on_initialize(pid_t pid) override;
+ virtual int on_deinitialize(pid_t pid) override;
+ virtual int on_get_audio_format(pid_t pid, int& rate, int& channel, int& audio_type) override;
+ virtual int on_get_audio_source_type(pid_t pid, std::string& type) override;
+ virtual int on_send_asr_result(pid_t pid, int event, std::string asr_result) override;
+ virtual int on_send_result(pid_t pid, std::string display_text,
std::string utterance_text, std::string result_json) override;
- virtual int on_send_recognition_result(int pid, int result) override;
- virtual int on_start_streaming_audio_data(int pid, int type) override;
- virtual int on_stop_streaming_audio_data(int pid, int type) override;
- virtual int on_update_voice_feedback_state(int pid, int state) override;
- virtual int on_send_assistant_specific_command(int pid, std::string command) override;
- virtual int on_set_background_volume(int pid, double ratio) override;
- virtual int on_set_preprocessing_allow_mode(int pid, int mode, std::string app_id) override;
- virtual int on_send_preprocessing_result(int pid, int result) override;
- virtual int on_set_wake_word_audio_require_flag(int pid, int require) override;
- virtual int on_set_assistant_language(int pid, std::string language) override;
- virtual int on_add_wake_word(int pid, std::string wake_word, std::string language) override;
- virtual int on_remove_wake_word(int pid, std::string wake_word, std::string language) override;
-
- virtual int on_ui_initialize(int pid) override;
- virtual int on_ui_deinitialize(int pid) override;
+ virtual int on_send_recognition_result(pid_t pid, int result) override;
+ virtual int on_start_streaming_audio_data(pid_t pid, int type) override;
+ virtual int on_stop_streaming_audio_data(pid_t pid, int type) override;
+ virtual int on_update_voice_feedback_state(pid_t pid, int state) override;
+ virtual int on_send_assistant_specific_command(pid_t pid, std::string command) override;
+ virtual int on_set_background_volume(pid_t pid, double ratio) override;
+ virtual int on_set_preprocessing_allow_mode(pid_t pid, int mode, std::string app_id) override;
+ virtual int on_send_preprocessing_result(pid_t pid, int result) override;
+ virtual int on_set_wake_word_audio_require_flag(pid_t pid, int require) override;
+ virtual int on_set_assistant_language(pid_t pid, std::string language) override;
+ virtual int on_add_wake_word(pid_t pid, std::string wake_word, std::string language) override;
+ virtual int on_remove_wake_word(pid_t pid, std::string wake_word, std::string language) override;
+
+ virtual int on_ui_initialize(pid_t pid) override;
+ virtual int on_ui_deinitialize(pid_t pid) override;
virtual int on_ui_change_assistant(std::string app_id) override;
bool app_create(void *data);
{
boost::optional<pid_t> ret;
- int pid = aul_app_get_pid(appid.c_str());
+ pid_t pid = aul_app_get_pid(appid.c_str());
if (pid >= 0) {
ret = pid;
}
return 0;
}
-int CClientManager::create_client(int pid, std::string appid)
+int CClientManager::create_client(pid_t pid, std::string appid)
{
ma_client_s* data = NULL;
return 0;
}
-int CClientManager::destroy_client_by_pid(int pid)
+int CClientManager::destroy_client_by_pid(pid_t pid)
{
ma_client_s* client = find_client_by_pid(pid);
return destroy_client(client);
return NULL;
}
-ma_client_s* CClientManager::find_client_by_pid(int pid)
+ma_client_s* CClientManager::find_client_by_pid(pid_t pid)
{
ma_client_s *data = NULL;
return static_cast<ma_client_s*>(g_slist_nth_data(mClientList, index));
}
-int CClientManager::find_client_pid_by_index(unsigned int index)
+pid_t CClientManager::find_client_pid_by_index(unsigned int index)
{
- int pid = -1;
+ pid_t pid = -1;
ma_client_s* client = get_client_by_index(index);
if (client) {
pid = client->pid;
return pid;
}
-int CClientManager::find_client_pid_by_appid(std::string appid)
+pid_t CClientManager::find_client_pid_by_appid(std::string appid)
{
- int pid = -1;
+ pid_t pid = -1;
if (nullptr == mApplicationManager) {
MAS_LOGE("ApplicationManager is NULL, can't check if app is running or not");
return pid;
}
-std::string CClientManager::find_client_appid_by_pid(int pid)
+std::string CClientManager::find_client_appid_by_pid(pid_t pid)
{
std::string appid;
bool CClientManager::check_client_validity_by_appid(std::string appid)
{
- int pid = find_client_pid_by_appid(appid);
+ pid_t pid = find_client_pid_by_appid(appid);
if (0 < pid) return true;
return false;
}
return 0;
}
-int CServiceIpcDbus::send_hello(int pid)
+int CServiceIpcDbus::send_hello(pid_t pid)
{
if (0 != __dbus_check()) {
return -1; //MAS_ERROR_OPERATION_FAILED;
"MESSAGE_PORT_ERROR_UNKNOWN");
}
-int CServiceIpcDbus::send_streaming_audio_data(int pid, int event, void* data, unsigned int data_size)
+int CServiceIpcDbus::send_streaming_audio_data(pid_t pid, int event, void* data, unsigned int data_size)
{
if (nullptr == mClientManager) {
MAS_LOGE("mClientManager variable is NULL");
return 0;
}
-int CServiceIpcDbus::change_active_state(int pid, int state)
+int CServiceIpcDbus::change_active_state(pid_t pid, int state)
{
if (0 != __dbus_check()) {
return -1; //MAS_ERROR_OPERATION_FAILED;
return 0;
}
-int CServiceIpcDbus::send_preprocessing_information(int pid, const char* app_id)
+int CServiceIpcDbus::send_preprocessing_information(pid_t pid, const char* app_id)
{
if (0 != __dbus_check()) {
return -1; //MAS_ERROR_OPERATION_FAILED;
return 0;
}
-int CServiceIpcDbus::send_streaming_section_changed(int pid, int section)
+int CServiceIpcDbus::send_streaming_section_changed(pid_t pid, int section)
{
if (nullptr == mClientManager) {
MAS_LOGE("mClientManager variable is NULL");
return 0;
}
-int CServiceIpcDbus::send_preprocessing_result(int pid, bool result)
+int CServiceIpcDbus::send_preprocessing_result(pid_t pid, bool result)
{
if (0 != __dbus_check()) {
return -1; //MAS_ERROR_OPERATION_FAILED;
return 0;
}
-int CServiceIpcDbus::send_wakeup_engine_command(int pid, const char* command)
+int CServiceIpcDbus::send_wakeup_engine_command(pid_t pid, const char* command)
{
if (0 != __dbus_check()) {
return -1; //MAS_ERROR_OPERATION_FAILED;
return 0;
}
-int CServiceIpcDbus::change_service_state(int pid, int state)
+int CServiceIpcDbus::change_service_state(pid_t pid, int state)
{
if (0 != __dbus_check()) {
return -1; //MAS_ERROR_OPERATION_FAILED;
return 0;
}
-int CServiceIpcDbus::change_voice_key_status(int pid, int status)
+int CServiceIpcDbus::change_voice_key_status(pid_t pid, int status)
{
if (0 != __dbus_check()) {
return -1; //MAS_ERROR_OPERATION_FAILED;
return result;
}
-int CServiceIpcDbus::masc_ui_dbus_send_asr_result(int pid, int event, const char* asr_result)
+int CServiceIpcDbus::masc_ui_dbus_send_asr_result(pid_t pid, int event, const char* asr_result)
{
if (0 != __dbus_check()) {
return -1; //MAS_ERROR_OPERATION_FAILED;
return 0;
}
-int CServiceIpcDbus::masc_ui_dbus_send_result(int pid, const char* display_text, const char* utterance_text, const char* result_json)
+int CServiceIpcDbus::masc_ui_dbus_send_result(pid_t pid, const char* display_text, const char* utterance_text, const char* result_json)
{
if (0 != __dbus_check()) {
return -1; //MA_ERROR_OPERATION_FAILED;
return 0;
}
-int CServiceIpcDbus::masc_ui_dbus_send_recognition_result(int pid, int result)
+int CServiceIpcDbus::masc_ui_dbus_send_recognition_result(pid_t pid, int result)
{
if (0 != __dbus_check()) {
return -1; //MAS_ERROR_OPERATION_FAILED;
DBusError err;
dbus_error_init(&err);
- int pid = -1;
+ pid_t pid = -1;
int ret = 0;
dbus_message_get_args(msg, &err,
DBusError err;
dbus_error_init(&err);
- int pid = -1;
+ pid_t pid = -1;
int ret = 0;
dbus_message_get_args(msg, &err,
DBusError err;
dbus_error_init(&err);
- int pid = -1;
+ pid_t pid = -1;
int rate, channel, audio_type;
int ret;
DBusError err;
dbus_error_init(&err);
- int pid = -1;
+ pid_t pid = -1;
std::string type;
int ret;
DBusError err;
dbus_error_init(&err);
- int pid, event;
+ pid_t pid, event;
char *asr_result;
int ret = 0;
DBusError err;
dbus_error_init(&err);
- int pid;
+ pid_t pid;
char* display_text;
char* utterance_text;
char* result_json;
DBusError err;
dbus_error_init(&err);
- int pid;
+ pid_t pid;
int result;
int ret = 0;
DBusError err;
dbus_error_init(&err);
- int pid;
+ pid_t pid;
int type;
int ret = 0;
DBusError err;
dbus_error_init(&err);
- int pid;
+ pid_t pid;
int type;
int ret = 0;
DBusError err;
dbus_error_init(&err);
- int pid;
+ pid_t pid;
int state;
int ret = 0;
DBusError err;
dbus_error_init(&err);
- int pid;
+ pid_t pid;
int ret = 0;
char* command;
DBusError err;
dbus_error_init(&err);
- int pid;
+ pid_t pid;
int ret = 0;
double ratio;
DBusError err;
dbus_error_init(&err);
- int pid;
+ pid_t pid;
int ret = 0;
int mode;
char* app_id;
DBusError err;
dbus_error_init(&err);
- int pid;
+ pid_t pid;
int ret = 0;
int result;
DBusError err;
dbus_error_init(&err);
- int pid;
+ pid_t pid;
int ret = 0;
int require;
DBusError err;
dbus_error_init(&err);
- int pid;
+ pid_t pid;
int ret = 0;
char* language;
DBusError err;
dbus_error_init(&err);
- int pid;
+ pid_t pid;
int ret = 0;
char* wake_word;
char* language;
DBusError err;
dbus_error_init(&err);
- int pid;
+ pid_t pid;
int ret = 0;
char* wake_word;
char* language;
DBusError err;
dbus_error_init(&err);
- int pid = -1;
+ pid_t pid = -1;
int ret = 0;
dbus_message_get_args(msg, &err,
DBusError err;
dbus_error_init(&err);
- int pid = -1;
+ pid_t pid = -1;
int ret = 0;
dbus_message_get_args(msg, &err,
return ret;
}
-int CServiceMain::mas_client_get_audio_format(int pid, int* rate, int* channel, int* audio_type)
+int CServiceMain::mas_client_get_audio_format(pid_t pid, int* rate, int* channel, int* audio_type)
{
MAS_LOGD("[Enter] pid(%d)", pid);
}
#define MAX_LOCAL_VARIABLE_STRING_LEN 256
-int CServiceMain::mas_client_get_audio_source_type(int pid, char** type)
+int CServiceMain::mas_client_get_audio_source_type(pid_t pid, char** type)
{
MAS_LOGD("[Enter] pid(%d)", pid);
return ret;
}
-int CServiceMain::mas_client_send_preprocessing_information(int pid)
+int CServiceMain::mas_client_send_preprocessing_information(pid_t pid)
{
int ret = -1;
MAS_LOGD("[Enter] pid(%d)", pid);
return ret;
}
-int CServiceMain::mas_client_send_voice_key_status_change(int pid, ma_voice_key_status_e status)
+int CServiceMain::mas_client_send_voice_key_status_change(pid_t pid, ma_voice_key_status_e status)
{
int ret = -1;
MAS_LOGD("[Enter] pid(%d)", pid);
return ret;
}
-int CServiceMain::mas_client_send_asr_result(int pid, int event, const char* asr_result)
+int CServiceMain::mas_client_send_asr_result(pid_t pid, int event, const char* asr_result)
{
MAS_LOGD("[Enter] pid(%d), event(%d), asr_result(%s)", pid, event, asr_result);
int ret = mServiceIpc.masc_ui_dbus_send_asr_result(pid, event, asr_result);
return ret;
}
-int CServiceMain::mas_client_send_result(int pid, const char* display_text,
+int CServiceMain::mas_client_send_result(pid_t pid, const char* display_text,
const char* utterance_text, const char* result_json)
{
MAS_LOGD("[Enter] pid(%d), display_text(%s), utterance_text(%s), result_json(%s)", pid, display_text, utterance_text, result_json);
return ret;
}
-int CServiceMain::mas_client_send_recognition_result(int pid, int result)
+int CServiceMain::mas_client_send_recognition_result(pid_t pid, int result)
{
MAS_LOGD("[Enter] pid(%d), result(%d)", pid, result);
int ret = mServiceIpc.masc_ui_dbus_send_recognition_result(pid, result);
return ret;
}
-int CServiceMain::mas_client_start_streaming_audio_data(int pid, int type)
+int CServiceMain::mas_client_start_streaming_audio_data(pid_t pid, int type)
{
int ret = -1;
switch(type) {
return ret;
}
-int CServiceMain::mas_client_stop_streaming_audio_data(int pid, int type)
+int CServiceMain::mas_client_stop_streaming_audio_data(pid_t pid, int type)
{
int ret = -1;
switch(type) {
return ret;
}
-int CServiceMain::mas_client_update_voice_feedback_state(int pid, int state)
+int CServiceMain::mas_client_update_voice_feedback_state(pid_t pid, int state)
{
std::string pid_appid;
boost::optional<std::string> appid_by_pid = mApplicationManager.get_appid_by_pid(pid);
return 0;
}
-int CServiceMain::mas_client_set_assistant_specific_command(int pid, const char *command)
+int CServiceMain::mas_client_set_assistant_specific_command(pid_t pid, const char *command)
{
std::string pid_appid;
boost::optional<std::string> appid_by_pid = mApplicationManager.get_appid_by_pid(pid);
return 0;
}
-int CServiceMain::mas_client_set_background_volume(int pid, double ratio)
+int CServiceMain::mas_client_set_background_volume(pid_t pid, double ratio)
{
std::string pid_appid;
boost::optional<std::string> appid_by_pid = mApplicationManager.get_appid_by_pid(pid);
return 0;
}
-int CServiceMain::mas_client_set_preprocessing_allow_mode(int pid, ma_preprocessing_allow_mode_e mode, const char* appid)
+int CServiceMain::mas_client_set_preprocessing_allow_mode(pid_t pid, ma_preprocessing_allow_mode_e mode, const char* appid)
{
std::string pid_appid;
boost::optional<std::string> appid_by_pid = mApplicationManager.get_appid_by_pid(pid);
return 0;
}
-int CServiceMain::mas_client_send_preprocessing_result(int pid, bool result)
+int CServiceMain::mas_client_send_preprocessing_result(pid_t pid, bool result)
{
std::string pid_appid;
boost::optional<std::string> appid_by_pid = mApplicationManager.get_appid_by_pid(pid);
}
if (current_maclient_appid) {
- int pid_by_appid = mClientManager.find_client_pid_by_appid(
+ pid_t pid_by_appid = mClientManager.find_client_pid_by_appid(
std::string{current_maclient_appid});
mServiceIpc.send_preprocessing_result(pid_by_appid, result);
}
return 0;
}
-int CServiceMain::mas_client_set_wake_word_audio_require_flag(int pid, bool require)
+int CServiceMain::mas_client_set_wake_word_audio_require_flag(pid_t pid, bool require)
{
std::string pid_appid;
boost::optional<std::string> appid_by_pid = mApplicationManager.get_appid_by_pid(pid);
return 0;
}
-int CServiceMain::mas_client_set_assistant_language(int pid, const char* language)
+int CServiceMain::mas_client_set_assistant_language(pid_t pid, const char* language)
{
std::string pid_appid;
boost::optional<std::string> appid_by_pid = mApplicationManager.get_appid_by_pid(pid);
return 0;
}
-int CServiceMain::mas_client_add_wake_word(int pid, const char* wake_word, const char* language)
+int CServiceMain::mas_client_add_wake_word(pid_t pid, const char* wake_word, const char* language)
{
std::string pid_appid;
boost::optional<std::string> appid_by_pid = mApplicationManager.get_appid_by_pid(pid);
return 0;
}
-int CServiceMain::mas_client_remove_wake_word(int pid, const char* wake_word, const char* language)
+int CServiceMain::mas_client_remove_wake_word(pid_t pid, const char* wake_word, const char* language)
{
std::string pid_appid;
boost::optional<std::string> appid_by_pid = mApplicationManager.get_appid_by_pid(pid);
return 0;
}
-int CServiceMain::mas_ui_client_initialize(int pid)
+int CServiceMain::mas_ui_client_initialize(pid_t pid)
{
MAS_LOGD("[Enter] pid(%d)", pid);
return 0;
}
-int CServiceMain::mas_ui_client_deinitialize(int pid)
+int CServiceMain::mas_ui_client_deinitialize(pid_t pid)
{
MAS_LOGD("[Enter] pid(%d)", pid);
mServiceIpc.masc_ui_dbus_enable_common_ui(!use_custom_ui);
mas_set_current_client_by_appid(appid);
- int pid = mas_get_client_pid_by_appid(appid);
+ pid_t pid = mas_get_client_pid_by_appid(appid);
if (pid != -1) {
mas_bring_client_to_foreground(appid);
mas_client_send_preprocessing_information(pid);
return ret;
}
-int CServiceMain::mas_get_current_preprocessing_client_pid()
+pid_t CServiceMain::mas_get_current_preprocessing_client_pid()
{
- int ret = -1;
+ pid_t ret = -1;
if (mCurrentPreprocessingClientInfo >= 0 && mCurrentPreprocessingClientInfo < MAX_MACLIENT_INFO_NUM) {
const char *appid = mClientInfo[mCurrentPreprocessingClientInfo].appid;
if (appid) {
return ret;
}
-int CServiceMain::mas_get_client_pid_by_appid(const char *appid)
+pid_t CServiceMain::mas_get_client_pid_by_appid(const char *appid)
{
- int ret = -1;
+ pid_t ret = -1;
if (appid) {
ret = mClientManager.find_client_pid_by_appid(std::string{appid});
if (mCurrentClientInfo != prev_selection) {
if (prev_selection >= 0 && prev_selection < MAX_MACLIENT_INFO_NUM) {
- int pid = mas_get_client_pid_by_appid(mClientInfo[prev_selection].appid);
+ pid_t pid = mas_get_client_pid_by_appid(mClientInfo[prev_selection].appid);
mServiceIpc.change_active_state(pid, MA_ACTIVE_STATE_INACTIVE);
}
}
if (mCurrentClientInfo != prev_selection) {
if (prev_selection >= 0 && prev_selection < MAX_MACLIENT_INFO_NUM) {
- int pid = mas_get_client_pid_by_appid(mClientInfo[prev_selection].appid);
+ pid_t pid = mas_get_client_pid_by_appid(mClientInfo[prev_selection].appid);
mServiceIpc.change_active_state(pid, MA_ACTIVE_STATE_INACTIVE);
}
}
int i;
for (i = 0; i < count; i++) {
- int pid = mClientManager.find_client_pid_by_index(i);
+ pid_t pid = mClientManager.find_client_pid_by_index(i);
if (-1 != pid) {
int ret = mServiceIpc.change_service_state(pid, state);
return;
}
-int CServiceMain::on_initialize(int pid) {
+int CServiceMain::on_initialize(pid_t pid) {
MAS_LOGD("[Enter] pid(%d)", pid);
std::string pid_appid;
return 0;
}
-int CServiceMain::on_deinitialize(int pid) {
+int CServiceMain::on_deinitialize(pid_t pid) {
MAS_LOGD("[Enter] pid(%d)", pid);
mClientManager.destroy_client_by_pid(pid);
return 0;
}
-int CServiceMain::on_get_audio_format(int pid, int& rate, int& channel, int& audio_type) {
+int CServiceMain::on_get_audio_format(pid_t pid, int& rate, int& channel, int& audio_type) {
int main_rate, main_channel, main_audio_type;
int ret = mas_client_get_audio_format(pid,
&main_rate, &main_channel, &main_audio_type);
return ret;
}
-int CServiceMain::on_get_audio_source_type(int pid, std::string& type) {
+int CServiceMain::on_get_audio_source_type(pid_t pid, std::string& type) {
char *main_type = nullptr;
int ret = mas_client_get_audio_source_type(pid, &main_type);
if (0 == ret && main_type) {
return ret;
}
-int CServiceMain::on_send_asr_result(int pid, int event, std::string asr_result) {
+int CServiceMain::on_send_asr_result(pid_t pid, int event, std::string asr_result) {
return mas_client_send_asr_result(pid, event, asr_result.c_str());
}
-int CServiceMain::on_send_result(int pid, std::string display_text,
+int CServiceMain::on_send_result(pid_t pid, std::string display_text,
std::string utterance_text, std::string result_json) {
return mas_client_send_result(pid,
display_text.c_str(), utterance_text.c_str(), result_json.c_str());
}
-int CServiceMain::on_send_recognition_result(int pid, int result) {
+int CServiceMain::on_send_recognition_result(pid_t pid, int result) {
return mas_client_send_recognition_result(pid, result);
}
-int CServiceMain::on_start_streaming_audio_data(int pid, int type) {
+int CServiceMain::on_start_streaming_audio_data(pid_t pid, int type) {
return mas_client_start_streaming_audio_data(pid, type);
}
-int CServiceMain::on_stop_streaming_audio_data(int pid, int type) {
+int CServiceMain::on_stop_streaming_audio_data(pid_t pid, int type) {
return mas_client_stop_streaming_audio_data(pid, type);
}
-int CServiceMain::on_update_voice_feedback_state(int pid, int state) {
+int CServiceMain::on_update_voice_feedback_state(pid_t pid, int state) {
return mas_client_update_voice_feedback_state(pid, state);
}
-int CServiceMain::on_send_assistant_specific_command(int pid, std::string command) {
+int CServiceMain::on_send_assistant_specific_command(pid_t pid, std::string command) {
return mas_client_set_assistant_specific_command(pid, command.c_str());
}
-int CServiceMain::on_set_background_volume(int pid, double ratio) {
+int CServiceMain::on_set_background_volume(pid_t pid, double ratio) {
return mas_client_set_background_volume(pid, ratio);
}
-int CServiceMain::on_set_preprocessing_allow_mode(int pid, int mode, std::string app_id) {
+int CServiceMain::on_set_preprocessing_allow_mode(pid_t pid, int mode, std::string app_id) {
return mas_client_set_preprocessing_allow_mode(pid,
static_cast<ma_preprocessing_allow_mode_e>(mode), app_id.c_str());
}
-int CServiceMain::on_send_preprocessing_result(int pid, int result) {
+int CServiceMain::on_send_preprocessing_result(pid_t pid, int result) {
return mas_client_send_preprocessing_result(pid, result);
}
-int CServiceMain::on_set_wake_word_audio_require_flag(int pid, int require) {
+int CServiceMain::on_set_wake_word_audio_require_flag(pid_t pid, int require) {
return mas_client_set_wake_word_audio_require_flag(pid, require);
}
-int CServiceMain::on_set_assistant_language(int pid, std::string language) {
+int CServiceMain::on_set_assistant_language(pid_t pid, std::string language) {
return mas_client_set_assistant_language(pid, language.c_str());
}
-int CServiceMain::on_add_wake_word(int pid, std::string wake_word, std::string language) {
+int CServiceMain::on_add_wake_word(pid_t pid, std::string wake_word, std::string language) {
return mas_client_add_wake_word(pid, wake_word.c_str(), language.c_str());
}
-int CServiceMain::on_remove_wake_word(int pid, std::string wake_word, std::string language) {
+int CServiceMain::on_remove_wake_word(pid_t pid, std::string wake_word, std::string language) {
return mas_client_remove_wake_word(pid, wake_word.c_str(), language.c_str());
}
-int CServiceMain::on_ui_initialize(int pid)
+int CServiceMain::on_ui_initialize(pid_t pid)
{
return mas_ui_client_initialize(pid);
}
-int CServiceMain::on_ui_deinitialize(int pid)
+int CServiceMain::on_ui_deinitialize(pid_t pid)
{
return mas_ui_client_deinitialize(pid);
}
char* appid = static_cast<char*>(param->data);
MAS_LOGD("[ENTER] appid(%s)", appid);
- int pid = -1;
+ pid_t pid = -1;
if (!appid) return ECORE_CALLBACK_CANCEL;
CServicePlugin* plugin = param->plugin;
}
}
-static bool __validate_streaming_event_order(int pid, mas_speech_streaming_event_e *event)
+static bool __validate_streaming_event_order(pid_t pid, mas_speech_streaming_event_e *event)
{
bool ret = false;
CServiceIpcDbus *service_ipc = plugin->get_service_ipc();
CServiceMain* service_main = plugin->get_service_main();
if (service_ipc && service_main) {
- int pid = service_main->mas_get_current_client_pid();
+ pid_t pid = service_main->mas_get_current_client_pid();
int ret = service_ipc->send_streaming_section_changed(pid, (int)section);
if (0 != ret) {
MAS_LOGE("[ERROR] Fail to send streaming section changed information, ret(%d)", ret);
CServiceIpcDbus *service_ipc = plugin->get_service_ipc();
CServiceMain* service_main = plugin->get_service_main();
if (service_ipc && service_main) {
- int pid = service_main->mas_get_client_pid_by_appid(assistant_name);
+ pid_t pid = service_main->mas_get_client_pid_by_appid(assistant_name);
if (-1 != pid) {
int ret = service_ipc->send_wakeup_engine_command(pid, command);
if (0 != ret) {
CServiceIpcDbus *service_ipc = plugin->get_service_ipc();
CServiceMain* service_main = plugin->get_service_main();
if (service_ipc && service_main) {
- int pid = service_main->mas_get_current_client_pid();
+ pid_t pid = service_main->mas_get_current_client_pid();
int ret = service_ipc->change_voice_key_status(pid, status);
if (0 != ret) {
MAS_LOGE("[ERROR] Fail to send voice key status changed information, ret(%d)", ret);
TEST_F(StorageWithNoClient, HasOneClientAfterCreate) {
const std::string arbitrary_client_appid{"Client1"};
- const int arbitrary_client_pid{1};
+ const pid_t arbitrary_client_pid{1};
client_manager.create_client(arbitrary_client_pid, arbitrary_client_appid);
TEST_F(StorageWithNoClient, ValidityReturnsTrueForCreatedClient) {
const std::string arbitrary_client_appid{"Client1"};
- const int arbitrary_client_pid{1};
+ const pid_t arbitrary_client_pid{1};
client_manager.create_client(arbitrary_client_pid, arbitrary_client_appid);
TEST_F(StorageWithNoClient, ValidityReturnsFalseForNotCreatedClient) {
const std::string arbitrary_client_appid{"Client1"};
- const int arbitrary_client_pid{1};
+ const pid_t arbitrary_client_pid{1};
const std::string noexist_client_appid{"Client987654321"};
void TearDown() override {
}
const std::string preloaded_client_appid_1{"Client1"};
- const int preloaded_client_pid_1{1};
+ const pid_t preloaded_client_pid_1{1};
CClientManager client_manager;
CDummyApplicationManager application_manager;
};
TEST_F(StorageWithOneClient, ReturnsExistingPIDByIndex) {
const std::string arbitrary_client_appid{"Client2"};
- const int arbitrary_client_pid{2};
+ const pid_t arbitrary_client_pid{2};
client_manager.create_client(arbitrary_client_pid, arbitrary_client_appid);
- int pid = client_manager.find_client_pid_by_index(0);
+ pid_t pid = client_manager.find_client_pid_by_index(0);
ASSERT_EQ(pid, preloaded_client_pid_1);
}
TEST_F(StorageWithOneClient, ReturnsCreatedPIDByIndex) {
const std::string arbitrary_client_appid{"Client2"};
- const int arbitrary_client_pid{2};
+ const pid_t arbitrary_client_pid{2};
client_manager.create_client(arbitrary_client_pid, arbitrary_client_appid);
- int pid = client_manager.find_client_pid_by_index(1);
+ pid_t pid = client_manager.find_client_pid_by_index(1);
ASSERT_EQ(pid, arbitrary_client_pid);
}
TEST_F(StorageWithOneClient, PreservesExistingItemNotRequestedForRemoval) {
const std::string arbitrary_client_appid{"Client2"};
- const int arbitrary_client_pid{2};
+ const pid_t arbitrary_client_pid{2};
client_manager.create_client(arbitrary_client_pid, arbitrary_client_appid);
client_manager.destroy_client_by_pid(arbitrary_client_pid);
- int pid = client_manager.find_client_pid_by_index(0);
+ pid_t pid = client_manager.find_client_pid_by_index(0);
ASSERT_EQ(pid, preloaded_client_pid_1);
}
TEST_F(StorageWithOneClient, PreservesCreatedItemNotRequestedForRemoval) {
const std::string arbitrary_client_appid{"Client2"};
- const int arbitrary_client_pid{2};
+ const pid_t arbitrary_client_pid{2};
client_manager.create_client(arbitrary_client_pid, arbitrary_client_appid);
client_manager.destroy_client_by_pid(preloaded_client_pid_1);
- int pid = client_manager.find_client_pid_by_index(0);
+ pid_t pid = client_manager.find_client_pid_by_index(0);
ASSERT_EQ(pid, arbitrary_client_pid);
}
TEST_F(StorageWithOneClient, ReturnsCorrectExistingPIDByAppID) {
const std::string arbitrary_client_appid{"Client2"};
- const int arbitrary_client_pid{2};
+ const pid_t arbitrary_client_pid{2};
client_manager.create_client(arbitrary_client_pid, arbitrary_client_appid);
- int pid = client_manager.find_client_pid_by_appid(preloaded_client_appid_1);
+ pid_t pid = client_manager.find_client_pid_by_appid(preloaded_client_appid_1);
ASSERT_EQ(pid, preloaded_client_pid_1);
}
TEST_F(StorageWithOneClient, ReturnsCorrectCreatedPIDByAppID) {
const std::string arbitrary_client_appid{"Client2"};
- const int arbitrary_client_pid{2};
+ const pid_t arbitrary_client_pid{2};
client_manager.create_client(arbitrary_client_pid, arbitrary_client_appid);
- int pid = client_manager.find_client_pid_by_appid(arbitrary_client_appid);
+ pid_t pid = client_manager.find_client_pid_by_appid(arbitrary_client_appid);
ASSERT_EQ(pid, arbitrary_client_pid);
}
TEST_F(StorageWithOneClient, ReturnsCorrectExistingAppIDByPID) {
const std::string arbitrary_client_appid{"Client2"};
- const int arbitrary_client_pid{2};
+ const pid_t arbitrary_client_pid{2};
client_manager.create_client(arbitrary_client_pid, arbitrary_client_appid);