manage groupes in cluster mode

[l2tpns.git] / l2tpns.c

diff --git a/l2tpns.c b/l2tpns.c
index 08c8bed..17c440b 100644 (file)
--- a/l2tpns.c
+++ b/l2tpns.c
@@ -1394,7 +1394,6 @@ static void update_session_out_stat(sessionidt s, sessiont *sp, int len)
 {
        increment_counter(&sp->cout, &sp->cout_wrap, len); // byte count
        sp->cout_delta += len;
-       sp->coutgrp_delta += len;
        sp->pout++;
        sp->last_data = time_now;
 
@@ -1804,7 +1803,6 @@ static void processipv6out(uint8_t * buf, int len)
 
        increment_counter(&sp->cout, &sp->cout_wrap, len); // byte count
        sp->cout_delta += len;
-       sp->coutgrp_delta += len;
        sp->pout++;
        udp_tx += len;
 
@@ -1854,7 +1852,6 @@ static void send_ipout(sessionidt s, uint8_t *buf, int len)
 
        increment_counter(&sp->cout, &sp->cout_wrap, len); // byte count
        sp->cout_delta += len;
-       sp->coutgrp_delta += len;
        sp->pout++;
        udp_tx += len;
 
@@ -5179,6 +5176,9 @@ int main(int argc, char *argv[])
                        LOG(0, 0, 0, "Can't lock pages: %s\n", strerror(errno));
        }
 
+       //LOG(3, 0, 0, "Debug sizeof struct: sessiont %lu, tunnelt %lu, bundlet %lu, groupsesst %lu\n",
+       //      sizeof(sessiont), sizeof(tunnelt), sizeof(bundlet), sizeof(groupsesst));
+
        mainloop();
 
        /* remove plugins (so cleanup code gets run) */
@@ -5679,6 +5679,7 @@ int sessionsetup(sessionidt s, tunnelidt t)
                if ((g = grp_groupbysession(s)))
                {
                        grp_setgrouproute(g, 1);
+                       cluster_send_groupe(g);
                }
        }