|
|
|
|
@ -128,8 +128,7 @@ struct ETCP_CONN* etcp_connection_create(struct UTUN_INSTANCE* instance) {
|
|
|
|
|
etcp->io_pool = memory_pool_init(sizeof(struct ETCP_FRAGMENT)); |
|
|
|
|
etcp->optimal_inflight=10000; |
|
|
|
|
// Initialize log_name with local node_id (peer will be updated later when known)
|
|
|
|
|
snprintf(etcp->log_name, sizeof(etcp->log_name), "%04llu->????", |
|
|
|
|
(unsigned long long)(instance->node_id % 10000)); |
|
|
|
|
snprintf(etcp->log_name, sizeof(etcp->log_name), "%04X->????", (uint16_t)instance->node_id); |
|
|
|
|
|
|
|
|
|
if (!etcp->input_queue || !etcp->output_queue || !etcp->input_send_q || !etcp->recv_q || !etcp->ack_q || |
|
|
|
|
!etcp->input_wait_ack || !etcp->inflight_pool || !etcp->io_pool) { |
|
|
|
|
@ -316,10 +315,9 @@ void etcp_conn_reinit(struct ETCP_CONN* etcp) {
|
|
|
|
|
void etcp_update_log_name(struct ETCP_CONN* etcp) { |
|
|
|
|
DEBUG_TRACE(DEBUG_CATEGORY_ETCP, ""); |
|
|
|
|
if (!etcp || !etcp->instance) return; |
|
|
|
|
uint64_t local_id = etcp->instance->node_id % 10000; |
|
|
|
|
uint64_t peer_id = etcp->peer_node_id % 10000; |
|
|
|
|
snprintf(etcp->log_name, sizeof(etcp->log_name), "%04llu->%04llu", |
|
|
|
|
(unsigned long long)local_id, (unsigned long long)peer_id); |
|
|
|
|
uint16_t local_id = etcp->instance->node_id; |
|
|
|
|
uint16_t peer_id = etcp->peer_node_id; |
|
|
|
|
snprintf(etcp->log_name, sizeof(etcp->log_name), "%04X->%04X", local_id, peer_id); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|