mirror of
https://github.com/open5gs/open5gs.git
synced 2025-11-02 13:03:31 +00:00
adjust trace_level
This commit is contained in:
@@ -22,7 +22,7 @@ status_t mutex_final(void)
|
||||
d_error("%d not freed in mutex_pool[%d]",
|
||||
pool_size(&mutex_pool) - pool_avail(&mutex_pool),
|
||||
pool_size(&mutex_pool));
|
||||
d_trace(7, "%d not freed in mutex_pool[%d]\n",
|
||||
d_trace(9, "%d not freed in mutex_pool[%d]\n",
|
||||
pool_size(&mutex_pool) - pool_avail(&mutex_pool),
|
||||
pool_size(&mutex_pool));
|
||||
pool_final(&mutex_pool);
|
||||
|
||||
@@ -86,49 +86,49 @@ void pkbuf_show(void)
|
||||
if (pool_used(&pkbuf_pool))
|
||||
d_error("%d not freed in pkbuf_pool[%d]",
|
||||
pool_used(&pkbuf_pool), pool_size(&pkbuf_pool));
|
||||
d_trace(7, "%d not freed in pkbuf_pool[%d]\n",
|
||||
d_trace(9, "%d not freed in pkbuf_pool[%d]\n",
|
||||
pool_used(&pkbuf_pool), pool_size(&pkbuf_pool));
|
||||
|
||||
if (pool_used(&clbuf_pool))
|
||||
d_error("%d not freed in clbuf_pool[%d]",
|
||||
pool_used(&clbuf_pool), pool_size(&clbuf_pool));
|
||||
d_trace(7, "%d not freed in clbuf_pool[%d]\n",
|
||||
d_trace(9, "%d not freed in clbuf_pool[%d]\n",
|
||||
pool_used(&clbuf_pool), pool_size(&clbuf_pool));
|
||||
|
||||
if (pool_used(&cluster_128_pool))
|
||||
d_error("%d not freed in cluster128_pool[%d]",
|
||||
pool_used(&cluster_128_pool), pool_size(&cluster_128_pool));
|
||||
d_trace(7, "%d not freed in cluster128_pool[%d]\n",
|
||||
d_trace(9, "%d not freed in cluster128_pool[%d]\n",
|
||||
pool_used(&cluster_128_pool), pool_size(&cluster_128_pool));
|
||||
|
||||
if (pool_used(&cluster_256_pool))
|
||||
d_error("%d not freed in cluster256_pool[%d]",
|
||||
pool_used(&cluster_256_pool), pool_size(&cluster_256_pool));
|
||||
d_trace(7, "%d not freed in cluster256_pool[%d]\n",
|
||||
d_trace(9, "%d not freed in cluster256_pool[%d]\n",
|
||||
pool_used(&cluster_256_pool), pool_size(&cluster_256_pool));
|
||||
|
||||
if (pool_used(&cluster_512_pool))
|
||||
d_error("%d not freed in cluster512_pool[%d]",
|
||||
pool_used(&cluster_512_pool), pool_size(&cluster_512_pool));
|
||||
d_trace(7, "%d not freed in cluster512_pool[%d]\n",
|
||||
d_trace(9, "%d not freed in cluster512_pool[%d]\n",
|
||||
pool_used(&cluster_512_pool), pool_size(&cluster_512_pool));
|
||||
|
||||
if (pool_used(&cluster_1024_pool))
|
||||
d_error("%d not freed in cluster1024_pool[%d]",
|
||||
pool_used(&cluster_1024_pool), pool_size(&cluster_1024_pool));
|
||||
d_trace(7, "%d not freed in cluster1024_pool[%d]\n",
|
||||
d_trace(9, "%d not freed in cluster1024_pool[%d]\n",
|
||||
pool_used(&cluster_1024_pool), pool_size(&cluster_1024_pool));
|
||||
|
||||
if (pool_used(&cluster_2048_pool))
|
||||
d_error("%d not freed in cluster2048_pool[%d]",
|
||||
pool_used(&cluster_2048_pool), pool_size(&cluster_2048_pool));
|
||||
d_trace(7, "%d not freed in cluster2048_pool[%d]\n",
|
||||
d_trace(9, "%d not freed in cluster2048_pool[%d]\n",
|
||||
pool_used(&cluster_2048_pool), pool_size(&cluster_2048_pool));
|
||||
|
||||
if (pool_used(&cluster_8192_pool))
|
||||
d_error("%d not freed in cluster8192_pool[%d]",
|
||||
pool_used(&cluster_8192_pool), pool_size(&cluster_8192_pool));
|
||||
d_trace(7, "%d not freed in cluster8192_pool[%d]\n",
|
||||
d_trace(9, "%d not freed in cluster8192_pool[%d]\n",
|
||||
pool_used(&cluster_8192_pool), pool_size(&cluster_8192_pool));
|
||||
}
|
||||
|
||||
|
||||
@@ -124,37 +124,37 @@ static void * fd_stats_worker(void * arg)
|
||||
CHECK_SYS_DO( clock_gettime(CLOCK_REALTIME, &now), );
|
||||
|
||||
/* Now, display everything */
|
||||
d_trace(7, "------- fd statistics ---------\n");
|
||||
d_trace(15, "------- fd statistics ---------\n");
|
||||
if (now.tv_nsec >= start.tv_nsec)
|
||||
{
|
||||
d_trace(7, " Executing for: %d.%06ld sec\n",
|
||||
d_trace(15, " Executing for: %d.%06ld sec\n",
|
||||
(int)(now.tv_sec - start.tv_sec),
|
||||
(long)(now.tv_nsec - start.tv_nsec) / 1000);
|
||||
}
|
||||
else
|
||||
{
|
||||
d_trace(7, " Executing for: %d.%06ld sec\n",
|
||||
d_trace(15, " Executing for: %d.%06ld sec\n",
|
||||
(int)(now.tv_sec - 1 - start.tv_sec),
|
||||
(long)(now.tv_nsec + 1000000000 - start.tv_nsec) / 1000);
|
||||
}
|
||||
|
||||
if (self.mode & FD_MODE_SERVER) {
|
||||
d_trace(7, " Server: %llu message(s) echoed\n",
|
||||
d_trace(15, " Server: %llu message(s) echoed\n",
|
||||
copy.nb_echoed);
|
||||
}
|
||||
if (self.mode & FD_MODE_CLIENT) {
|
||||
d_trace(7, " Client:\n");
|
||||
d_trace(7, " %llu message(s) sent\n", copy.nb_sent);
|
||||
d_trace(7, " %llu error(s) received\n", copy.nb_errs);
|
||||
d_trace(7, " %llu answer(s) received\n", copy.nb_recv);
|
||||
d_trace(7, " fastest: %ld.%06ld sec.\n",
|
||||
d_trace(15, " Client:\n");
|
||||
d_trace(15, " %llu message(s) sent\n", copy.nb_sent);
|
||||
d_trace(15, " %llu error(s) received\n", copy.nb_errs);
|
||||
d_trace(15, " %llu answer(s) received\n", copy.nb_recv);
|
||||
d_trace(15, " fastest: %ld.%06ld sec.\n",
|
||||
copy.shortest / 1000000, copy.shortest % 1000000);
|
||||
d_trace(7, " slowest: %ld.%06ld sec.\n",
|
||||
d_trace(15, " slowest: %ld.%06ld sec.\n",
|
||||
copy.longest / 1000000, copy.longest % 1000000);
|
||||
d_trace(7, " Average: %ld.%06ld sec.\n",
|
||||
d_trace(15, " Average: %ld.%06ld sec.\n",
|
||||
copy.avg / 1000000, copy.avg % 1000000);
|
||||
}
|
||||
d_trace(7, "-------------------------------------\n");
|
||||
d_trace(15, "-------------------------------------\n");
|
||||
}
|
||||
|
||||
return NULL; /* never called */
|
||||
|
||||
@@ -21,7 +21,7 @@ status_t gtp_node_final(void)
|
||||
if (pool_used(>p_node_pool))
|
||||
d_error("%d not freed in gtp_node_pool[%d]",
|
||||
pool_used(>p_node_pool), pool_size(>p_node_pool));
|
||||
d_trace(7, "%d not freed in gtp_node_pool[%d]\n",
|
||||
d_trace(9, "%d not freed in gtp_node_pool[%d]\n",
|
||||
pool_used(>p_node_pool), pool_size(>p_node_pool));
|
||||
pool_final(>p_node_pool);
|
||||
|
||||
|
||||
@@ -95,7 +95,7 @@ status_t mme_context_final()
|
||||
d_error("%d not freed in M-TMSI pool[%d] in MME-Context",
|
||||
pool_used(&self.m_tmsi), pool_size(&self.m_tmsi));
|
||||
}
|
||||
d_trace(7, "%d not freed in M-TMSI pool[%d] in MME-Context\n",
|
||||
d_trace(9, "%d not freed in M-TMSI pool[%d] in MME-Context\n",
|
||||
pool_used(&self.m_tmsi), pool_size(&self.m_tmsi));
|
||||
|
||||
d_assert(self.enb_sock_hash, , "Null param");
|
||||
@@ -2009,11 +2009,11 @@ mme_ue_t* mme_ue_find_by_message(nas_message_t *message)
|
||||
mme_ue = mme_ue_find_by_imsi_bcd(imsi_bcd);
|
||||
if (mme_ue)
|
||||
{
|
||||
d_trace(7, "known UE by IMSI[%s]\n", imsi_bcd);
|
||||
d_trace(9, "known UE by IMSI[%s]\n", imsi_bcd);
|
||||
}
|
||||
else
|
||||
{
|
||||
d_trace(7, "Unknown UE by IMSI[%s]\n", imsi_bcd);
|
||||
d_trace(9, "Unknown UE by IMSI[%s]\n", imsi_bcd);
|
||||
}
|
||||
break;
|
||||
}
|
||||
@@ -2031,7 +2031,7 @@ mme_ue_t* mme_ue_find_by_message(nas_message_t *message)
|
||||
mme_ue = mme_ue_find_by_guti(&guti);
|
||||
if (mme_ue)
|
||||
{
|
||||
d_trace(7, "Known UE by GUTI[G:%d,C:%d,M_TMSI:0x%x]\n",
|
||||
d_trace(9, "Known UE by GUTI[G:%d,C:%d,M_TMSI:0x%x]\n",
|
||||
guti.mme_gid,
|
||||
guti.mme_code,
|
||||
guti.m_tmsi);
|
||||
@@ -2083,7 +2083,7 @@ mme_ue_t* mme_ue_find_by_message(nas_message_t *message)
|
||||
mme_ue = mme_ue_find_by_guti(&guti);
|
||||
if (mme_ue)
|
||||
{
|
||||
d_trace(7, "Known UE by GUTI[G:%d,C:%d,M_TMSI:0x%x]\n",
|
||||
d_trace(9, "Known UE by GUTI[G:%d,C:%d,M_TMSI:0x%x]\n",
|
||||
guti.mme_gid,
|
||||
guti.mme_code,
|
||||
guti.m_tmsi);
|
||||
@@ -2509,7 +2509,7 @@ mme_bearer_t* mme_bearer_find_or_add_by_message(
|
||||
pti = message->esm.h.procedure_transaction_identity;
|
||||
ebi = message->esm.h.eps_bearer_identity;
|
||||
|
||||
d_trace(7, "mme_bearer_find_or_add_by_message() [PTI:%d, EBI:%d]\n",
|
||||
d_trace(9, "mme_bearer_find_or_add_by_message() [PTI:%d, EBI:%d]\n",
|
||||
pti, ebi);
|
||||
|
||||
if (ebi != NAS_EPS_BEARER_IDENTITY_UNASSIGNED)
|
||||
@@ -2710,7 +2710,7 @@ status_t mme_m_tmsi_pool_generate()
|
||||
int i, j;
|
||||
int index = 0;
|
||||
|
||||
d_trace(7, "M-TMSI Pool try to generate...\n");
|
||||
d_trace(5, "M-TMSI Pool try to generate...\n");
|
||||
for (i = 0; index < MAX_POOL_OF_UE; i++)
|
||||
{
|
||||
mme_m_tmsi_t *m_tmsi = NULL;
|
||||
@@ -2733,7 +2733,7 @@ status_t mme_m_tmsi_pool_generate()
|
||||
index++;
|
||||
}
|
||||
self.m_tmsi.size = index;
|
||||
d_trace(7, "M-TMSI Pool generate...done\n");
|
||||
d_trace(5, "M-TMSI Pool generate...done\n");
|
||||
|
||||
return CORE_OK;
|
||||
}
|
||||
|
||||
@@ -427,11 +427,11 @@ out:
|
||||
|
||||
/* Display how long it took */
|
||||
if (ts.tv_nsec > sess_data->ts.tv_nsec)
|
||||
d_trace(7, "in %d.%06ld sec\n",
|
||||
d_trace(9, "in %d.%06ld sec\n",
|
||||
(int)(ts.tv_sec - sess_data->ts.tv_sec),
|
||||
(long)(ts.tv_nsec - sess_data->ts.tv_nsec) / 1000);
|
||||
else
|
||||
d_trace(7, "in %d.%06ld sec\n",
|
||||
d_trace(9, "in %d.%06ld sec\n",
|
||||
(int)(ts.tv_sec + 1 - sess_data->ts.tv_sec),
|
||||
(long)(1000000000 + ts.tv_nsec - sess_data->ts.tv_nsec) / 1000);
|
||||
|
||||
@@ -1072,11 +1072,11 @@ static void mme_s6a_ula_cb(void *data, struct msg **msg)
|
||||
|
||||
/* Display how long it took */
|
||||
if (ts.tv_nsec > sess_data->ts.tv_nsec)
|
||||
d_trace(7, "in %d.%06ld sec\n",
|
||||
d_trace(9, "in %d.%06ld sec\n",
|
||||
(int)(ts.tv_sec - sess_data->ts.tv_sec),
|
||||
(long)(ts.tv_nsec - sess_data->ts.tv_nsec) / 1000);
|
||||
else
|
||||
d_trace(7, "in %d.%06ld sec\n",
|
||||
d_trace(9, "in %d.%06ld sec\n",
|
||||
(int)(ts.tv_sec + 1 - sess_data->ts.tv_sec),
|
||||
(long)(1000000000 + ts.tv_nsec - sess_data->ts.tv_nsec) / 1000);
|
||||
|
||||
@@ -1127,7 +1127,7 @@ void mme_fd_final(void)
|
||||
if (pool_used(&mme_s6a_sess_pool))
|
||||
d_error("%d not freed in mme_s6a_sess_pool[%d] of GX-SM",
|
||||
pool_used(&mme_s6a_sess_pool), pool_size(&mme_s6a_sess_pool));
|
||||
d_trace(7, "%d not freed in mme_s6a_sess_pool[%d] of GX-SM\n",
|
||||
d_trace(9, "%d not freed in mme_s6a_sess_pool[%d] of GX-SM\n",
|
||||
pool_used(&mme_s6a_sess_pool), pool_size(&mme_s6a_sess_pool));
|
||||
|
||||
pool_final(&mme_s6a_sess_pool);
|
||||
|
||||
@@ -97,7 +97,7 @@ status_t sctp_server(sock_id *new, int type, c_sockaddr_t *sa_list)
|
||||
{
|
||||
if (s1ap_usrsctp_bind(*new, addr) == CORE_OK)
|
||||
{
|
||||
d_trace(7, "sctp_server [%s]:%d\n",
|
||||
d_trace(9, "sctp_server [%s]:%d\n",
|
||||
CORE_ADDR(addr, buf), CORE_PORT(addr));
|
||||
break;
|
||||
}
|
||||
@@ -136,7 +136,7 @@ status_t sctp_client(sock_id *new, int type, c_sockaddr_t *sa_list)
|
||||
{
|
||||
if (s1ap_usrsctp_connect(*new, addr) == CORE_OK)
|
||||
{
|
||||
d_trace(7, "sctp_client [%s]:%d\n",
|
||||
d_trace(9, "sctp_client [%s]:%d\n",
|
||||
CORE_ADDR(addr, buf), CORE_PORT(addr));
|
||||
break;
|
||||
}
|
||||
@@ -292,7 +292,7 @@ static status_t s1ap_usrsctp_bind(sock_id id, c_sockaddr_t *sa)
|
||||
return CORE_ERROR;
|
||||
}
|
||||
|
||||
d_trace(7, "usrsctp_bind [%s]:%d\n", CORE_ADDR(sa, buf), CORE_PORT(sa));
|
||||
d_trace(9, "usrsctp_bind [%s]:%d\n", CORE_ADDR(sa, buf), CORE_PORT(sa));
|
||||
|
||||
return CORE_OK;
|
||||
}
|
||||
@@ -315,7 +315,7 @@ static status_t s1ap_usrsctp_connect(sock_id id, c_sockaddr_t *sa)
|
||||
return CORE_ERROR;
|
||||
}
|
||||
|
||||
d_trace(7, "usrsctp_connect [%s]:%d\n", CORE_ADDR(sa, buf), CORE_PORT(sa));
|
||||
d_trace(9, "usrsctp_connect [%s]:%d\n", CORE_ADDR(sa, buf), CORE_PORT(sa));
|
||||
|
||||
return CORE_OK;
|
||||
}
|
||||
@@ -354,7 +354,7 @@ static int s1ap_usrsctp_recv_handler(struct socket *sock,
|
||||
switch(not->sn_header.sn_type)
|
||||
{
|
||||
case SCTP_ASSOC_CHANGE :
|
||||
d_trace(7, "SCTP_ASSOC_CHANGE"
|
||||
d_trace(9, "SCTP_ASSOC_CHANGE"
|
||||
"(type:0x%x, flags:0x%x, state:0x%x)\n",
|
||||
not->sn_assoc_change.sac_type,
|
||||
not->sn_assoc_change.sac_flags,
|
||||
|
||||
@@ -1153,11 +1153,11 @@ static void pcrf_gx_raa_cb(void *data, struct msg **msg)
|
||||
|
||||
/* Display how long it took */
|
||||
if (ts.tv_nsec > sess_data->ts.tv_nsec)
|
||||
d_trace(7, "in %d.%06ld sec\n",
|
||||
d_trace(15, "in %d.%06ld sec\n",
|
||||
(int)(ts.tv_sec - sess_data->ts.tv_sec),
|
||||
(long)(ts.tv_nsec - sess_data->ts.tv_nsec) / 1000);
|
||||
else
|
||||
d_trace(7, "in %d.%06ld sec\n",
|
||||
d_trace(15, "in %d.%06ld sec\n",
|
||||
(int)(ts.tv_sec + 1 - sess_data->ts.tv_sec),
|
||||
(long)(1000000000 + ts.tv_nsec - sess_data->ts.tv_nsec) / 1000);
|
||||
|
||||
@@ -1222,12 +1222,12 @@ void pcrf_gx_final(void)
|
||||
if (pool_used(&pcrf_gx_sess_pool))
|
||||
d_error("%d not freed in pcrf_gx_sess_pool[%d] of GX-SM",
|
||||
pool_used(&pcrf_gx_sess_pool), pool_size(&pcrf_gx_sess_pool));
|
||||
d_trace(7, "%d not freed in pcrf_gx_sess_pool[%d] of GX-SM\n",
|
||||
d_trace(9, "%d not freed in pcrf_gx_sess_pool[%d] of GX-SM\n",
|
||||
pool_used(&pcrf_gx_sess_pool), pool_size(&pcrf_gx_sess_pool));
|
||||
if (pool_used(&pcrf_gx_rx_sess_pool))
|
||||
d_error("%d not freed in pcrf_gx_rx_sess_pool[%d] of GX-SM",
|
||||
pool_used(&pcrf_gx_rx_sess_pool), pool_size(&pcrf_gx_rx_sess_pool));
|
||||
d_trace(7, "%d not freed in pcrf_gx_rx_sess_pool[%d] of GX-SM\n",
|
||||
d_trace(9, "%d not freed in pcrf_gx_rx_sess_pool[%d] of GX-SM\n",
|
||||
pool_used(&pcrf_gx_rx_sess_pool), pool_size(&pcrf_gx_rx_sess_pool));
|
||||
|
||||
pool_final(&pcrf_gx_sess_pool);
|
||||
|
||||
@@ -845,7 +845,7 @@ void pcrf_rx_final(void)
|
||||
if (pool_used(&pcrf_rx_sess_pool))
|
||||
d_error("%d not freed in pcrf_rx_sess_pool[%d] of GX-SM",
|
||||
pool_used(&pcrf_rx_sess_pool), pool_size(&pcrf_rx_sess_pool));
|
||||
d_trace(7, "%d not freed in pcrf_rx_sess_pool[%d] of GX-SM\n",
|
||||
d_trace(9, "%d not freed in pcrf_rx_sess_pool[%d] of GX-SM\n",
|
||||
pool_used(&pcrf_rx_sess_pool), pool_size(&pcrf_rx_sess_pool));
|
||||
|
||||
pool_final(&pcrf_rx_sess_pool);
|
||||
|
||||
@@ -84,7 +84,7 @@ status_t pgw_context_final()
|
||||
if (index_used(&pgw_sess_pool))
|
||||
d_error("%d not freed in pgw_sess_pool[%d] in PGW-Context",
|
||||
index_used(&pgw_sess_pool), index_size(&pgw_sess_pool));
|
||||
d_trace(7, "%d not freed in pgw_sess_pool[%d] in PGW-Context\n",
|
||||
d_trace(9, "%d not freed in pgw_sess_pool[%d] in PGW-Context\n",
|
||||
index_used(&pgw_sess_pool), index_size(&pgw_sess_pool));
|
||||
|
||||
pgw_dev_remove_all();
|
||||
@@ -1129,7 +1129,7 @@ pgw_sess_t *pgw_sess_add_by_message(gtp_message_t *message)
|
||||
|
||||
apn_parse(apn, req->access_point_name.data, req->access_point_name.len);
|
||||
|
||||
d_trace(7, "pgw_sess_add_by_message() [APN:%s, PDN:%d, EDI:%d]\n",
|
||||
d_trace(9, "pgw_sess_add_by_message() [APN:%s, PDN:%d, EDI:%d]\n",
|
||||
apn, req->pdn_type.u8,
|
||||
req->bearer_contexts_to_be_created.eps_bearer_id.u8);
|
||||
|
||||
@@ -1673,7 +1673,7 @@ status_t pgw_subnet_remove(pgw_subnet_t *subnet)
|
||||
d_warn("%d not freed in ue_ip_pool[%d] in PGW-Context",
|
||||
pool_used(&subnet->pool), pool_size(&subnet->pool));
|
||||
}
|
||||
d_trace(7, "%d not freed in ue_ip_pool[%d] in PGW-Context\n",
|
||||
d_trace(9, "%d not freed in ue_ip_pool[%d] in PGW-Context\n",
|
||||
pool_used(&subnet->pool), pool_size(&subnet->pool));
|
||||
pool_final(&subnet->pool);
|
||||
|
||||
|
||||
@@ -243,8 +243,6 @@ CORE_DECLARE(pgw_bearer_t*) pgw_default_bearer_in_sess(pgw_sess_t *sess);
|
||||
CORE_DECLARE(pgw_bearer_t*) pgw_bearer_first(pgw_sess_t *sess);
|
||||
CORE_DECLARE(pgw_bearer_t*) pgw_bearer_next(pgw_bearer_t *bearer);
|
||||
|
||||
CORE_DECLARE(pgw_bearer_t*) pgw_bearer_find_by_packet(pkbuf_t *pkt);
|
||||
|
||||
CORE_DECLARE(pgw_pf_t*) pgw_pf_add(
|
||||
pgw_bearer_t *bearer, c_uint32_t precedence);
|
||||
CORE_DECLARE(status_t ) pgw_pf_remove(pgw_pf_t *pf);
|
||||
|
||||
@@ -762,11 +762,11 @@ out:
|
||||
|
||||
/* Display how long it took */
|
||||
if (ts.tv_nsec > sess_data->ts.tv_nsec)
|
||||
d_trace(7, "in %d.%06ld sec\n",
|
||||
d_trace(15, "in %d.%06ld sec\n",
|
||||
(int)(ts.tv_sec - sess_data->ts.tv_sec),
|
||||
(long)(ts.tv_nsec - sess_data->ts.tv_nsec) / 1000);
|
||||
else
|
||||
d_trace(7, "in %d.%06ld sec\n",
|
||||
d_trace(15, "in %d.%06ld sec\n",
|
||||
(int)(ts.tv_sec + 1 - sess_data->ts.tv_sec),
|
||||
(long)(1000000000 + ts.tv_nsec - sess_data->ts.tv_nsec) / 1000);
|
||||
|
||||
@@ -1063,7 +1063,7 @@ void pgw_fd_final(void)
|
||||
if (pool_used(&pgw_gx_sess_pool))
|
||||
d_error("%d not freed in pgw_gx_sess_pool[%d] of GX-SM",
|
||||
pool_used(&pgw_gx_sess_pool), pool_size(&pgw_gx_sess_pool));
|
||||
d_trace(7, "%d not freed in pgw_gx_sess_pool[%d] of GX-SM\n",
|
||||
d_trace(9, "%d not freed in pgw_gx_sess_pool[%d] of GX-SM\n",
|
||||
pool_used(&pgw_gx_sess_pool), pool_size(&pgw_gx_sess_pool));
|
||||
|
||||
pool_final(&pgw_gx_sess_pool);
|
||||
|
||||
@@ -10,6 +10,7 @@
|
||||
#include "pgw_context.h"
|
||||
#include "pgw_event.h"
|
||||
#include "pgw_gtp_path.h"
|
||||
#include "pgw_ipfw.h"
|
||||
|
||||
#define PGW_GTP_HANDLED 1
|
||||
|
||||
|
||||
@@ -228,7 +228,7 @@ static status_t decode_ipv6_header(
|
||||
return CORE_OK;
|
||||
}
|
||||
|
||||
pgw_bearer_t*pgw_bearer_find_by_packet(pkbuf_t *pkt)
|
||||
pgw_bearer_t *pgw_bearer_find_by_packet(pkbuf_t *pkt)
|
||||
{
|
||||
hash_index_t *hi = NULL;
|
||||
struct ip *ip_h = NULL;
|
||||
@@ -271,10 +271,10 @@ pgw_bearer_t*pgw_bearer_find_by_packet(pkbuf_t *pkt)
|
||||
else
|
||||
d_error("Invalid IP version = %d\n", ip_h->ip_v);
|
||||
|
||||
d_trace(50, "PROTO:%d SRC:%08x %08x %08x %08x\n",
|
||||
d_trace(9, "PROTO:%d SRC:%08x %08x %08x %08x\n",
|
||||
proto, ntohl(src_addr[0]), ntohl(src_addr[1]),
|
||||
ntohl(src_addr[2]), ntohl(src_addr[3]));
|
||||
d_trace(50, "HLEN:%d DST:%08x %08x %08x %08x\n",
|
||||
d_trace(9, "HLEN:%d DST:%08x %08x %08x %08x\n",
|
||||
ip_hlen, ntohl(dst_addr[0]), ntohl(dst_addr[1]),
|
||||
ntohl(dst_addr[2]), ntohl(dst_addr[3]));
|
||||
|
||||
@@ -290,9 +290,9 @@ pgw_bearer_t*pgw_bearer_find_by_packet(pkbuf_t *pkt)
|
||||
d_assert(sess, return NULL,);
|
||||
|
||||
if (sess->ipv4)
|
||||
d_trace(50, "PAA IPv4:%s\n", INET_NTOP(&sess->ipv4->addr, buf));
|
||||
d_trace(9, "PAA IPv4:%s\n", INET_NTOP(&sess->ipv4->addr, buf));
|
||||
if (sess->ipv6)
|
||||
d_trace(50, "PAA IPv6:%s\n", INET6_NTOP(&sess->ipv6->addr, buf));
|
||||
d_trace(9, "PAA IPv6:%s\n", INET6_NTOP(&sess->ipv6->addr, buf));
|
||||
|
||||
if ((sess->ipv4 && memcmp(dst_addr, sess->ipv4->addr, addr_len) == 0) ||
|
||||
(sess->ipv6 && memcmp(dst_addr, sess->ipv6->addr, addr_len) == 0))
|
||||
@@ -323,13 +323,13 @@ pgw_bearer_t*pgw_bearer_find_by_packet(pkbuf_t *pkt)
|
||||
c_uint32_t src_mask[4];
|
||||
c_uint32_t dst_mask[4];
|
||||
|
||||
d_trace(50, "DIR:%d PROTO:%d SRC:%d-%d DST:%d-%d\n",
|
||||
d_trace(9, "DIR:%d PROTO:%d SRC:%d-%d DST:%d-%d\n",
|
||||
pf->direction, pf->rule.proto,
|
||||
pf->rule.port.local.low,
|
||||
pf->rule.port.local.high,
|
||||
pf->rule.port.remote.low,
|
||||
pf->rule.port.remote.high);
|
||||
d_trace(50, "SRC:%08x %08x %08x %08x/%08x %08x %08x %08x\n",
|
||||
d_trace(9, "SRC:%08x %08x %08x %08x/%08x %08x %08x %08x\n",
|
||||
ntohl(pf->rule.ip.local.addr[0]),
|
||||
ntohl(pf->rule.ip.local.addr[1]),
|
||||
ntohl(pf->rule.ip.local.addr[2]),
|
||||
@@ -338,7 +338,7 @@ pgw_bearer_t*pgw_bearer_find_by_packet(pkbuf_t *pkt)
|
||||
ntohl(pf->rule.ip.local.mask[1]),
|
||||
ntohl(pf->rule.ip.local.mask[2]),
|
||||
ntohl(pf->rule.ip.local.mask[3]));
|
||||
d_trace(50, "DST:%08x %08x %08x %08x/%08x %08x %08x %08x\n",
|
||||
d_trace(9, "DST:%08x %08x %08x %08x/%08x %08x %08x %08x\n",
|
||||
ntohl(pf->rule.ip.remote.addr[0]),
|
||||
ntohl(pf->rule.ip.remote.addr[1]),
|
||||
ntohl(pf->rule.ip.remote.addr[2]),
|
||||
@@ -465,7 +465,7 @@ pgw_bearer_t*pgw_bearer_find_by_packet(pkbuf_t *pkt)
|
||||
if (pf)
|
||||
{
|
||||
bearer = pf->bearer;
|
||||
d_trace(50,"FOUND Bearer EBI = %d\n", bearer->ebi);
|
||||
d_trace(5, "FOUND Bearer EBI = %d\n", bearer->ebi);
|
||||
break;
|
||||
}
|
||||
|
||||
|
||||
@@ -8,4 +8,6 @@
|
||||
CORE_DECLARE(status_t) pgw_compile_packet_filter(
|
||||
pgw_rule_t *pf, c_int8_t *description);
|
||||
|
||||
CORE_DECLARE(pgw_bearer_t*) pgw_bearer_find_by_packet(pkbuf_t *pkt);
|
||||
|
||||
#endif /* __PGW_IPFW_H__ */
|
||||
|
||||
@@ -546,8 +546,8 @@ sgw_ue_t *sgw_ue_add_by_message(gtp_message_t *message)
|
||||
return NULL;
|
||||
}
|
||||
|
||||
d_trace(7, "sgw_ue_add_by_message() - IMSI ");
|
||||
d_trace_hex(7, req->imsi.data, req->imsi.len);
|
||||
d_trace(9, "sgw_ue_add_by_message() - IMSI ");
|
||||
d_trace_hex(9, req->imsi.data, req->imsi.len);
|
||||
|
||||
sgw_ue = sgw_ue_find_by_imsi(req->imsi.data, req->imsi.len);
|
||||
if (!sgw_ue)
|
||||
|
||||
@@ -185,13 +185,13 @@ static int _gtpv1_u_recv_cb(sock_id sock, void *data)
|
||||
|
||||
if ((SGW_GET_UE_STATE(sgw_ue) & SGW_S1U_INACTIVE))
|
||||
{
|
||||
d_trace(7, " SGW-S1U Inactive\n");
|
||||
d_trace(9, " SGW-S1U Inactive\n");
|
||||
if ( !(SGW_GET_UE_STATE(sgw_ue) & SGW_DL_NOTI_SENT))
|
||||
{
|
||||
event_t e;
|
||||
status_t rv;
|
||||
|
||||
d_trace(7, " EVENT DL Data Notification\n");
|
||||
d_trace(9, " EVENT DL Data Notification\n");
|
||||
event_set(&e, SGW_EVT_LO_DLDATA_NOTI);
|
||||
event_set_param1(&e, (c_uintptr_t)bearer->index);
|
||||
rv = sgw_event_send(&e);
|
||||
|
||||
Reference in New Issue
Block a user