Skip to content
Snippets Groups Projects
Commit 60ac2517 authored by Dmitriy A. Gerasimov's avatar Dmitriy A. Gerasimov
Browse files

[*] Bugfixes and renames

parent 9ef4252a
No related branches found
No related tags found
No related merge requests found
...@@ -233,12 +233,12 @@ static void callback_trafic(dap_client_remote_t *a_client, dap_stream_ch_t* a_ch ...@@ -233,12 +233,12 @@ static void callback_trafic(dap_client_remote_t *a_client, dap_stream_ch_t* a_ch
* @brief ch_sf_socket_delete * @brief ch_sf_socket_delete
* @param sf * @param sf
*/ */
static void ch_sf_socket_delete(ch_vpn_socket_proxy_t * sf) static void ch_sf_socket_delete(ch_vpn_socket_proxy_t * a_vpn_socket_proxy)
{ {
close(sf->sock); close(a_vpn_socket_proxy->sock);
pthread_mutex_destroy(& (sf->mutex) ); pthread_mutex_destroy(& (a_vpn_socket_proxy->mutex) );
if (sf) if (a_vpn_socket_proxy)
free(sf); DAP_DELETE(a_vpn_socket_proxy);
} }
...@@ -247,18 +247,20 @@ static void ch_sf_socket_delete(ch_vpn_socket_proxy_t * sf) ...@@ -247,18 +247,20 @@ static void ch_sf_socket_delete(ch_vpn_socket_proxy_t * sf)
* @param ch * @param ch
* @param arg * @param arg
*/ */
void srv_ch_sf_new(dap_stream_ch_t* ch, void* arg) void srv_ch_sf_new(dap_stream_ch_t* a_stream_ch, void* a_arg)
{ {
ch->internal = calloc(1, sizeof(dap_chain_net_srv_vpn_t)); (void) a_arg;
dap_chain_net_srv_vpn_t * sf = CH_VPN(ch);
a_stream_ch->internal = DAP_NEW_Z(dap_chain_net_srv_vpn_t);
dap_chain_net_srv_vpn_t * sf = CH_VPN(a_stream_ch);
pthread_mutex_init(&sf->mutex, NULL); pthread_mutex_init(&sf->mutex, NULL);
sf->raw_l3_sock = socket(PF_INET, SOCK_RAW, IPPROTO_RAW); sf->raw_l3_sock = socket(PF_INET, SOCK_RAW, IPPROTO_RAW);
// //
if(ch->stream->session->service_key) { if(a_stream_ch->stream->session->service_key) {
char *l_addr_base58; char *l_addr_base58;
char *l_sign_hash_str; char *l_sign_hash_str;
ch->stream->session->service_key = a_stream_ch->stream->session->service_key =
"RpiDC8c1SxrT7TUExyGWNErgV6HtwkKhSd1yLEkTA9qHcSiYA4GXjE67KJQay2TzHdG2ouk42d8GgLyABu6rP55JeFYzBkqZ7CqijDEw;12345"; "RpiDC8c1SxrT7TUExyGWNErgV6HtwkKhSd1yLEkTA9qHcSiYA4GXjE67KJQay2TzHdG2ouk42d8GgLyABu6rP55JeFYzBkqZ7CqijDEw;12345";
const dap_chain_net_srv_abstract_t *l_cond = NULL; const dap_chain_net_srv_abstract_t *l_cond = NULL;
...@@ -266,7 +268,7 @@ void srv_ch_sf_new(dap_stream_ch_t* ch, void* arg) ...@@ -266,7 +268,7 @@ void srv_ch_sf_new(dap_stream_ch_t* ch, void* arg)
const char *l_net_name = "kelvin-testnet"; const char *l_net_name = "kelvin-testnet";
dap_ledger_t *l_ledger = dap_chain_ledger_by_net_name(l_net_name); dap_ledger_t *l_ledger = dap_chain_ledger_by_net_name(l_net_name);
// get value for service and fill l_cond struct // get value for service and fill l_cond struct
uint64_t l_value = dap_chain_net_srv_client_auth(l_ledger, ch->stream->session->service_key, &l_cond); uint64_t l_value = dap_chain_net_srv_client_auth(l_ledger, a_stream_ch->stream->session->service_key, &l_cond);
// add service // add service
if(l_cond && l_value > 0) if(l_cond && l_value > 0)
......
...@@ -269,7 +269,7 @@ static void ch_sf_new(dap_stream_ch_t* a_ch, void* arg) ...@@ -269,7 +269,7 @@ static void ch_sf_new(dap_stream_ch_t* a_ch, void* arg)
static void ch_sf_delete(dap_stream_ch_t* a_ch, void* arg) static void ch_sf_delete(dap_stream_ch_t* a_ch, void* arg)
{ {
log_it(L_DEBUG, "ch_sf_delete() for %s", a_ch->stream->events_socket->hostaddr); log_it(L_DEBUG, "ch_sf_delete()");
/* ch_vpn_socket_proxy_t * cur, *tmp; /* ch_vpn_socket_proxy_t * cur, *tmp;
ch_sf_tun_delete(CH_SF(a_ch)); ch_sf_tun_delete(CH_SF(a_ch));
HASH_ITER(hh, CH_SF(a_ch)->socks , cur, tmp) { HASH_ITER(hh, CH_SF(a_ch)->socks , cur, tmp) {
......
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