Skip to content
Snippets Groups Projects
Commit 759d14c0 authored by Dmitry Gerasimov's avatar Dmitry Gerasimov
Browse files

[*] Fixed

parent 5355a1e2
No related branches found
No related tags found
1 merge request!897hotfix-6925
Pipeline #18155 failed with stage
in 12 seconds
...@@ -23,6 +23,8 @@ along with any CellFrame SDK based project. If not, see <http://www.gnu.org/lic ...@@ -23,6 +23,8 @@ along with any CellFrame SDK based project. If not, see <http://www.gnu.org/lic
*/ */
#include <sys/time.h> #include <sys/time.h>
#include <time.h>
#include "dap_global_db.h"
#include "dap_timerfd.h" #include "dap_timerfd.h"
#include "dap_hash.h" #include "dap_hash.h"
#include "rand/dap_rand.h" #include "rand/dap_rand.h"
...@@ -395,7 +397,7 @@ void s_stream_ch_packet_in(dap_stream_ch_t* a_ch , void* a_arg) ...@@ -395,7 +397,7 @@ void s_stream_ch_packet_in(dap_stream_ch_t* a_ch , void* a_arg)
l_request->err_code = 0; l_request->err_code = 0;
strncpy(l_request->ip_send, a_ch->stream->esocket->hostaddr, INET_ADDRSTRLEN); strncpy(l_request->ip_send, a_ch->stream->esocket->hostaddr, INET_ADDRSTRLEN);
struct timespec l_recvtime2; struct timespec l_recvtime2;
clck_gettime(CLOCK_REALTIME, &l_recvtime2); clock_gettime(CLOCK_REALTIME, &l_recvtime2);
l_request->recv_time2 = l_recvtime2; l_request->recv_time2 = l_recvtime2;
dap_stream_ch_pkt_write_unsafe(a_ch, DAP_STREAM_CH_CHAIN_NET_SRV_PKT_TYPE_CHECK_RESPONSE, l_request, dap_stream_ch_pkt_write_unsafe(a_ch, DAP_STREAM_CH_CHAIN_NET_SRV_PKT_TYPE_CHECK_RESPONSE, l_request,
...@@ -534,7 +536,7 @@ void s_stream_ch_packet_in(dap_stream_ch_t* a_ch , void* a_arg) ...@@ -534,7 +536,7 @@ void s_stream_ch_packet_in(dap_stream_ch_t* a_ch , void* a_arg)
dap_hash_fast(l_receipt,l_receipt_size,&l_receipt_hash); dap_hash_fast(l_receipt,l_receipt_size,&l_receipt_hash);
char *l_receipt_hash_str = dap_chain_hash_fast_to_str_new(&l_receipt_hash); char *l_receipt_hash_str = dap_chain_hash_fast_to_str_new(&l_receipt_hash);
dap_chain_global_db_gr_set(l_receipt_hash_str, l_receipt, l_receipt_size, "local.receipts"); dap_global_db_set("local.receipts",l_receipt_hash_str, l_receipt, l_receipt_size,false, NULL, NULL);
DAP_DELETE(l_receipt_hash_str); DAP_DELETE(l_receipt_hash_str);
size_t l_success_size; size_t l_success_size;
......
...@@ -299,7 +299,7 @@ static bool s_pkt_broadcast(dap_proc_thread_t * a_thread, void * a_arg) ...@@ -299,7 +299,7 @@ static bool s_pkt_broadcast(dap_proc_thread_t * a_thread, void * a_arg)
} }
s_callback_channel_pkt_free(0); //s_callback_channel_pkt_free(0);
return true; return true;
} }
...@@ -406,7 +406,7 @@ static void s_callback_pkt_items_send_all(dap_client_t *a_client, void *a_arg) ...@@ -406,7 +406,7 @@ static void s_callback_pkt_items_send_all(dap_client_t *a_client, void *a_arg)
l_pkts_list = l_pkts_list_next; l_pkts_list = l_pkts_list_next;
} }
pthread_rwlock_unlock(&s_pkt_items->rwlock_out); pthread_rwlock_unlock(&s_pkt_items->rwlock_out);
s_callback_channel_pkt_free(l_node_client->remote_node_addr.uint64); // s_callback_channel_pkt_free(l_node_client->remote_node_addr.uint64);
} }
} }
} }
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment