&g_adaptor_event_thread_pid);
}
-void __browser_adaptor_disconnect_mutex_unlock(void)
-{
- errorcode = BP_ERROR_IO_ERROR;
- BP_PRINT_ERROR(-1, errorcode);
- __browser_adaptor_disconnect();
- pthread_mutex_unlock(&g_adaptor_mutex);
-}
static int __browser_adaptor_connect(int callback)
{
if (g_adaptorinfo == NULL) {
if (bp_ipc_send_custom_type(sock, &conds,
sizeof(bp_db_base_conds_fmt)) < 0 ||
bp_adaptor_ipc_send_int(sock, size) < 0) {
- __browser_adaptor_disconnect_mutex_unlock();
+ /* LCOV_EXCL_START */
+ errorcode = BP_ERROR_IO_ERROR;
+ BP_PRINT_ERROR(-1, errorcode);
+ __browser_adaptor_disconnect();
+ pthread_mutex_unlock(&g_adaptor_mutex);
return -1;
+ /* LCOV_EXCL_STOP */
}
// wait id from provider.
errorcode = bp_ipc_read_errorcode(sock);
unsigned int oflags = offset;
if (bp_ipc_send_custom_type(sock, &oflags,
sizeof(bp_history_offset)) < 0) {
- __browser_adaptor_disconnect_mutex_unlock();
+ /* LCOV_EXCL_START */
+ errorcode = BP_ERROR_IO_ERROR;
+ BP_PRINT_ERROR(id, errorcode);
+ __browser_adaptor_disconnect();
+ pthread_mutex_unlock(&g_adaptor_mutex);
return -1;
+ /* LCOV_EXCL_STOP */
}
// 2. wait id from provider.
errorcode = bp_ipc_read_errorcode(sock);
if (bp_ipc_send_custom_type(sock, &oflags,
sizeof(bp_history_offset)) < 0 ||
bp_adaptor_ipc_send_int(sock, date_type) < 0) {
- __browser_adaptor_disconnect_mutex_unlock();
+ /* LCOV_EXCL_START */
+ errorcode = BP_ERROR_IO_ERROR;
+ BP_PRINT_ERROR(-1, errorcode);
+ __browser_adaptor_disconnect();
+ pthread_mutex_unlock(&g_adaptor_mutex);
return -1;
+ /* LCOV_EXCL_STOP */
}
// wait id from provider.
errorcode = bp_ipc_read_errorcode(sock);
sizeof(bp_history_rows_cond_fmt)) < 0 ||
bp_ipc_send_custom_type(sock, &oflags,
sizeof(bp_history_offset)) < 0) {
- __browser_adaptor_disconnect_mutex_unlock();
+ /* LCOV_EXCL_START */
+ errorcode = BP_ERROR_IO_ERROR;
+ BP_PRINT_ERROR(-1, errorcode);
+ __browser_adaptor_disconnect();
+ pthread_mutex_unlock(&g_adaptor_mutex);
return -1;
+ /* LCOV_EXCL_STOP */
}
if (oflags > 0) {
if (bp_adaptor_ipc_send_int(sock, is_like) < 0 ||
bp_ipc_send_string(sock, keyword) < 0) {
- __browser_adaptor_disconnect_mutex_unlock();
+ /* LCOV_EXCL_START */
+ errorcode = BP_ERROR_IO_ERROR;
+ __browser_adaptor_disconnect();
+ pthread_mutex_unlock(&g_adaptor_mutex);
return -1;
+ /* LCOV_EXCL_STOP */
+
}
}
// wait id from provider.
if (bp_ipc_send_custom_type(sock, &t_limits,
sizeof(bp_history_rows_fmt)) < 0 ||
bp_adaptor_ipc_send_int(sock, times_count) < 0) {
- __browser_adaptor_disconnect_mutex_unlock();
+ /* LCOV_EXCL_START */
+ errorcode = BP_ERROR_IO_ERROR;
+ BP_PRINT_ERROR(-1, errorcode);
+ __browser_adaptor_disconnect();
+ pthread_mutex_unlock(&g_adaptor_mutex);
return -1;
+ /* LCOV_EXCL_STOP */
}
if (times_count > 0) {
int i = 0;
(bp_history_timestamp_fmt *)(times + i);
if (bp_ipc_send_custom_type(sock, timestamps,
sizeof(bp_history_timestamp_fmt)) < 0) {
- __browser_adaptor_disconnect_mutex_unlock();
+ /* LCOV_EXCL_START */
+ errorcode = BP_ERROR_IO_ERROR;
+ BP_PRINT_ERROR(-1, errorcode);
+ __browser_adaptor_disconnect();
+ pthread_mutex_unlock(&g_adaptor_mutex);
return -1;
+ /* LCOV_EXCL_STOP */
}
}
}
oflags = 0; //LCOV_EXCL_LINE
if (bp_ipc_send_custom_type(sock, &oflags,
sizeof(unsigned int)) < 0) {
- __browser_adaptor_disconnect_mutex_unlock();
+ /* LCOV_EXCL_START */
+ errorcode = BP_ERROR_IO_ERROR;
+ BP_PRINT_ERROR(-1, errorcode);
+ __browser_adaptor_disconnect();
+ pthread_mutex_unlock(&g_adaptor_mutex);
return -1;
+ /* LCOV_EXCL_STOP */
}
if (oflags > 0) {
if (bp_adaptor_ipc_send_int(sock, is_like) < 0 ||
bp_ipc_send_string(sock, keyword) < 0) {
- __browser_adaptor_disconnect_mutex_unlock();
+ /* LCOV_EXCL_START */
+ errorcode = BP_ERROR_IO_ERROR;
+ BP_PRINT_ERROR(-1, errorcode);
+ __browser_adaptor_disconnect();
+ pthread_mutex_unlock(&g_adaptor_mutex);
return -1;
+ /* LCOV_EXCL_STOP */
}
}
// wait id from provider.