if (!sensor_client_info::get_instance().has_client_id()) {
first_connection = true;
- if(!cmd_channel->cmd_get_id(client_id)) {
+ if (!cmd_channel->cmd_get_id(client_id)) {
_E("Sending cmd_get_id() failed for %s", get_sensor_name(sensor_id));
sensor_client_info::get_instance().close_command_channel(sensor_id);
sensor_client_info::get_instance().delete_handle(handle);
sensor_client_info::get_instance().set_sensor_params(handle, SENSOR_STATE_STOPPED, SENSOR_OPTION_DEFAULT);
if (!sensor_registered) {
- if(!cmd_channel->cmd_hello(sensor_id)) {
+ if (!cmd_channel->cmd_hello(sensor_id)) {
_E("Sending cmd_hello(%s, %d) failed for %s", get_sensor_name(sensor_id), client_id, get_client_name());
sensor_client_info::get_instance().close_command_channel(sensor_id);
sensor_client_info::get_instance().delete_handle(handle);
sensor_client_info::get_instance().set_client_id(CLIENT_ID_INVALID);
if (!sensor_client_info::get_instance().is_sensor_registered(sensor_id)) {
- if(!cmd_channel->cmd_byebye()) {
+ if (!cmd_channel->cmd_byebye()) {
_E("Sending cmd_byebye(%d, %s) failed for %s", client_id, get_sensor_name(sensor_id), get_client_name());
return false;
}
auto it_event = event_vec.begin();
while (it_event != event_vec.end()) {
- if(!cmd_register_event(*it_event))
+ if (!cmd_register_event(*it_event))
return false;
++it_event;
auto it_event = event_vec.begin();
while (it_event != event_vec.end()) {
- if(!cmd_unregister_event(*it_event))
+ if (!cmd_unregister_event(*it_event))
return false;
++it_event;
len = m_event_socket.recv(buffer, buffer_len);
if (!len) {
- if(!m_poller->poll(event))
+ if (!m_poller->poll(event))
return -1;
len = m_event_socket.recv(buffer, buffer_len);
int quat_to_matrix(const float *quat, float *R)
{
- if(quat == NULL || R == NULL)
+ if (quat == NULL || R == NULL)
return -EINVAL;
float q0 = quat[3];
return false;
}
- if(!it_record->second.get_registered_events(sensor_id, event_vec))
+ if (!it_record->second.get_registered_events(sensor_id, event_vec))
return false;
return true;
return false;
}
- if(!it_record->second.register_event(sensor_id, event_type))
+ if (!it_record->second.register_event(sensor_id, event_type))
return false;
return true;
return false;
}
- if(!it_record->second.unregister_event(sensor_id, event_type))
+ if (!it_record->second.unregister_event(sensor_id, event_type))
return false;
return true;
return false;
}
- if(!it_record->second.set_option(sensor_id, option))
+ if (!it_record->second.set_option(sensor_id, option))
return false;
return true;
return false;
}
- if(!it_record->second.set_start(sensor_id, start))
+ if (!it_record->second.set_start(sensor_id, start))
return false;
return true;
return false;
}
- if(!it_record->second.remove_sensor_usage(sensor_id))
+ if (!it_record->second.remove_sensor_usage(sensor_id))
return false;
- if(!it_record->second.has_sensor_usage())
+ if (!it_record->second.has_sensor_usage())
remove_client_record(client_id);
return true;
return false;
}
- if(!it_record->second.has_sensor_usage(sensor_id))
+ if (!it_record->second.has_sensor_usage(sensor_id))
return false;
return true;
return false;
}
- if(!it_record->second.has_sensor_usage())
+ if (!it_record->second.has_sensor_usage())
return false;
return true;
auto it_record = m_clients.begin();
while (it_record != m_clients.end()) {
- if(it_record->second.is_listening_event(sensor_id, event_type))
+ if (it_record->second.is_listening_event(sensor_id, event_type))
id_vec.push_back(it_record->first);
++it_record;
client_socket.set_transfer_mode();
- if(!get_client_info_manager().set_event_socket(client_id, client_socket)) {
+ if (!get_client_info_manager().set_event_socket(client_id, client_socket)) {
_E("Failed to store event socket[%d] for %s", client_socket.get_socket_fd(),
client_info_manager.get_client_info(client_id));
return;
}
cur = xmlDocGetRootElement(doc);
- if(cur == NULL) {
+ if (cur == NULL) {
_E("There is no root element in %s\n", config_path.c_str());
xmlFreeDoc(doc);
return false;
}
- if(xmlStrcmp(cur->name, (const xmlChar *)ROOT_ELEMENT)) {
+ if (xmlStrcmp(cur->name, (const xmlChar *)ROOT_ELEMENT)) {
_E("Wrong type document: there is no [%s] root element in %s\n", ROOT_ELEMENT, config_path.c_str());
xmlFreeDoc(doc);
return false;
bool worker_thread::transition_function(trans_func_index index)
{
if (m_trans_func[index] != NULL) {
- if(!m_trans_func[index](m_context)) {
+ if (!m_trans_func[index](m_context)) {
_E("Transition[%d] function returning false", index);
return false;
}
return false;
}
- if(setsockopt(m_sock_fd, SOL_SOCKET, SO_RCVTIMEO, &tv, sizeof(tv)) < 0) {
+ if (setsockopt(m_sock_fd, SOL_SOCKET, SO_RCVTIMEO, &tv, sizeof(tv)) < 0) {
_ERRNO(errno, _E, "Set SO_RCVTIMEO failed for %s, m_sock_fd : %d", get_client_name(), m_sock_fd);
close();
return false;
#if defined(_DEBUG)
# define warn_if(expr, fmt, arg...) do { \
- if(expr) { \
+ if (expr) { \
_D("(%s) -> " fmt, #expr, ##arg); \
} \
} while (0)
# define ret_if(expr) do { \
- if(expr) { \
+ if (expr) { \
_D("(%s) -> %s() return", #expr, __FUNCTION__); \
return; \
} \
} while (0)
# define retv_if(expr, val) do { \
- if(expr) { \
+ if (expr) { \
_D("(%s) -> %s() return", #expr, __FUNCTION__); \
return (val); \
} \
} while (0)
# define retm_if(expr, fmt, arg...) do { \
- if(expr) { \
+ if (expr) { \
_E(fmt, ##arg); \
_D("(%s) -> %s() return", #expr, __FUNCTION__); \
return; \
} \
} while (0)
# define retvm_if(expr, val, fmt, arg...) do { \
- if(expr) { \
+ if (expr) { \
_E(fmt, ##arg); \
_D("(%s) -> %s() return", #expr, __FUNCTION__); \
return (val); \
#else
# define warn_if(expr, fmt, arg...) do { \
- if(expr) { \
+ if (expr) { \
_E(fmt, ##arg); \
} \
} while (0)
# define ret_if(expr) do { \
- if(expr) { \
+ if (expr) { \
return; \
} \
} while (0)
# define retv_if(expr, val) do { \
- if(expr) { \
+ if (expr) { \
return (val); \
} \
} while (0)
# define retm_if(expr, fmt, arg...) do { \
- if(expr) { \
+ if (expr) { \
_E(fmt, ##arg); \
return; \
} \
} while (0)
# define retvm_if(expr, val, fmt, arg...) do { \
- if(expr) { \
+ if (expr) { \
_E(fmt, ##arg); \
return (val); \
} \