Re-numbering duplicated log.

[ultramonkey-l7/ultramonkey-l7-v2.git] / src / conn.c

diff --git a/src/conn.c b/src/conn.c
index 4b74ddb..fa184f2 100644 (file)
--- a/src/conn.c
+++ b/src/conn.c
@@ -75,7 +75,7 @@ l7vs_conn_init(void)
 {
     /*-------- DEBUG LOG --------*/
     if (LOG_LV_DEBUG == logger_get_log_level(LOG_CAT_L7VSD_NETWORK)) {
-        LOGGER_PUT_LOG_DEBUG(LOG_CAT_L7VSD_NETWORK,341,
+        LOGGER_PUT_LOG_DEBUG(LOG_CAT_L7VSD_NETWORK,353,
             "in_function: int lvs_conn_init() ");
     }
     /*------ DEBUG LOG END ------*/
@@ -412,7 +412,7 @@ l7vs_conn_create(int lfd, struct l7vs_lsock *lsock)
         struct l7vs_dest* dest;
         conn->ciom->status = iomux_conn_received;
         if (!l7vs_conn_is_rs_connected(conn->ciom, conn, &srv, &dest)) {
-            LOGGER_PUT_LOG_ERROR(LOG_CAT_L7VSD_NETWORK,16, "error / is realserver connected failed");
+            LOGGER_PUT_LOG_ERROR(LOG_CAT_L7VSD_NETWORK,38, "error / is realserver connected failed");
         }
         else {
             switch (conn->ciom->status) {
@@ -422,12 +422,12 @@ l7vs_conn_create(int lfd, struct l7vs_lsock *lsock)
             case iomux_conn_service_selected:
                 //service and destination were selected then attempt to connect the real server
                 if (!l7vs_conn_connection_establish(conn->ciom, conn, srv, dest)) {
-                    LOGGER_PUT_LOG_ERROR(LOG_CAT_L7VSD_NETWORK,17, "error / client connect rs failed");
+                    LOGGER_PUT_LOG_ERROR(LOG_CAT_L7VSD_NETWORK,39, "error / client connect rs failed");
                 }
                 break;
             default:
                 //invalid status
-                LOGGER_PUT_LOG_ERROR(LOG_CAT_L7VSD_PROGRAM,34, "error / invalid status(%d)", conn->ciom->status);
+                LOGGER_PUT_LOG_ERROR(LOG_CAT_L7VSD_PROGRAM,79, "error / invalid status(%d)", conn->ciom->status);
                 break;
             }
         }
@@ -1261,7 +1261,8 @@ l7vs_conn_is_rs_connected(struct l7vs_iomux *iom, struct l7vs_conn *conn, struct
     if (conn->srv) {
         ret = conn->srv->pm->analyze_cldata(conn->srv, conn, conn->cldata, &conn->cldata_len);
         if (ret != 0) {
-            // XXX
+            LOGGER_PUT_LOG_INFO(LOG_CAT_L7VSD_PROTOCOL,19,
+                "Failed to modify client data: %d", ret);
         }
     }
 
@@ -2484,7 +2485,7 @@ l7vs_conn_recv(struct l7vs_iomux *iom, int source_fd)
     if( (source_fd == conn->riom->fd) && !l7vs_conn_QoS_control( conn, QOS_DOWN ) ){
         /*-------- DEBUG LOG --------*/
         if (LOG_LV_DEBUG == logger_get_log_level(LOG_CAT_L7VSD_NETWORK)) {
-            LOGGER_PUT_LOG_DEBUG(LOG_CAT_L7VSD_NETWORK,223,
+            LOGGER_PUT_LOG_DEBUG(LOG_CAT_L7VSD_NETWORK,346,
                 "iom->status change: %d->%d",
                 iom->status, iomux_conn_receiving);
         }
@@ -2492,7 +2493,7 @@ l7vs_conn_recv(struct l7vs_iomux *iom, int source_fd)
         iom->status = iomux_conn_receiving;
         /*-------- DEBUG LOG --------*/
         if (LOG_LV_DEBUG == logger_get_log_level(LOG_CAT_L7VSD_NETWORK)) {
-            LOGGER_PUT_LOG_DEBUG(LOG_CAT_L7VSD_NETWORK,224,
+            LOGGER_PUT_LOG_DEBUG(LOG_CAT_L7VSD_NETWORK,347,
                 "out_function: static int l7vs_conn_recv(struct l7vs_iomux *iom, int source_fd) "
                 "return_value: 1");
         }
@@ -3567,7 +3568,7 @@ l7vs_conn_QoS_control( struct l7vs_conn *conn, int direction )
     if (!conn->srv) {
         /*-------- DEBUG LOG --------*/
         if (LOG_LV_DEBUG == logger_get_log_level(LOG_CAT_L7VSD_NETWORK)) {
-            LOGGER_PUT_LOG_DEBUG(LOG_CAT_L7VSD_NETWORK,317,
+            LOGGER_PUT_LOG_DEBUG(LOG_CAT_L7VSD_NETWORK,348,
                 "out_function: static int l7vs_conn_QoS_control( struct l7vs_conn *conn, int direction ) "
                 "return_value: 1");
         }
@@ -3626,8 +3627,8 @@ l7vs_conn_QoS_control( struct l7vs_conn *conn, int direction )
         //QoS Control check : to client
         conn->srv->throughput_to_client = conn->srv->cur_recvsize_from_server * 1000000ULL / throughput_interval;
         if (LOG_LV_DEBUG == logger_get_log_level(LOG_CAT_L7VSD_NETWORK)) {
-            LOGGER_PUT_LOG_DEBUG(LOG_CAT_L7VSD_NETWORK,323, "QoS threshold to client:%lld ", conn->srv->qos_threshold_down);
-            LOGGER_PUT_LOG_DEBUG(LOG_CAT_L7VSD_NETWORK,324, "(current throughput:%lld)", conn->srv->throughput_to_client);
+            LOGGER_PUT_LOG_DEBUG(LOG_CAT_L7VSD_NETWORK,349, "QoS threshold to client:%lld ", conn->srv->qos_threshold_down);
+            LOGGER_PUT_LOG_DEBUG(LOG_CAT_L7VSD_NETWORK,350, "(current throughput:%lld)", conn->srv->throughput_to_client);
         }
         if( (conn->srv->qos_threshold_down) && (conn->srv->throughput_to_client + l7vs_conn_read_bufsize > conn->srv->qos_threshold_down) ){
             if (conn->srv->qos_down_flag == 0) {
@@ -3636,7 +3637,7 @@ l7vs_conn_QoS_control( struct l7vs_conn *conn, int direction )
             }
             /*-------- DEBUG LOG --------*/
             if (LOG_LV_DEBUG == logger_get_log_level(LOG_CAT_L7VSD_NETWORK)) {
-                LOGGER_PUT_LOG_DEBUG(LOG_CAT_L7VSD_NETWORK,326,
+                LOGGER_PUT_LOG_DEBUG(LOG_CAT_L7VSD_NETWORK,351,
                     "out_function: static int l7vs_conn_QoS_control( struct l7vs_conn *conn, int direction ) "
                     "return_value: 0");
             }
@@ -3723,7 +3724,7 @@ l7vs_conn_QoS_recvsize_register( struct l7vs_conn *conn, const size_t in_recvsiz
             "tv_usec=%ld}"
             , CurrTime.tv_sec
             , CurrTime.tv_usec);
-        LOGGER_PUT_LOG_DEBUG(LOG_CAT_L7VSD_NETWORK,339,
+        LOGGER_PUT_LOG_DEBUG(LOG_CAT_L7VSD_NETWORK,352,
             "gettimeofday result: CurrTime=%s",
             time_str);
     }