diff --git a/modules/channel/chain/dap_stream_ch_chain.c b/modules/channel/chain/dap_stream_ch_chain.c index 6799edd03d9e15cbf26a66a8c66c02e5b3c7ba65..71cf0683024ac12deba2e730a7bf1fa48951e2eb 100644 --- a/modules/channel/chain/dap_stream_ch_chain.c +++ b/modules/channel/chain/dap_stream_ch_chain.c @@ -773,19 +773,17 @@ static bool s_gdb_in_pkt_proc_callback(dap_proc_thread_t *a_thread, void *a_arg) (dap_chain_datum_t** restrict) &l_store_obj_value, 1, l_store_obj[i].group); } - else { - // save data to global_db - if(!dap_chain_global_db_obj_save(l_obj, 1)) { - struct sync_request *l_sync_req_err = DAP_DUP(l_sync_request); - dap_proc_thread_worker_exec_callback(a_thread, l_sync_request->worker->id, - s_gdb_in_pkt_error_worker_callback, l_sync_req_err); - } else { - if (s_debug_more) - log_it(L_DEBUG, "Added new GLOBAL_DB synchronization record"); - } - } } - + // save data to global_db + if(!dap_chain_global_db_obj_save(l_obj, 1)) { + struct sync_request *l_sync_req_err = DAP_DUP(l_sync_request); + dap_proc_thread_worker_exec_callback(a_thread, l_sync_request->worker->id, + s_gdb_in_pkt_error_worker_callback, l_sync_req_err); + } + else { + if (s_debug_more) + log_it(L_DEBUG, "Added new GLOBAL_DB synchronization record"); + } } if(l_store_obj) { dap_store_obj_free(l_store_obj, l_data_obj_count);