welterde/l2tpns
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

rename sess_count to sess_local, fiddle with packet_limit log output

Browse source
This commit is contained in:
Brendan O'Dea 2005-01-13 07:57:35 +00:00
parent 17714a3ca7
commit 17fd46618e
4 changed files with 34 additions and 32 deletions
Download patch file Download diff file Expand all files Collapse all files

20
cluster.c
View file

@ -1,6 +1,6 @@
// L2TPNS Clustering Stuff
char const *cvs_id_cluster = "$Id: cluster.c,v 1.28 2004-12-22 05:30:58 bodea Exp $";
char const *cvs_id_cluster = "$Id: cluster.c,v 1.29 2005-01-13 07:57:35 bodea Exp $";
#include <stdio.h>
#include <stdlib.h>
@ -406,18 +406,18 @@ void master_update_counts(void)
if ( walk_session_number > config->cluster_highest_sessionid)
walk_session_number = 1;
if (!sess_count[walk_session_number].cin && !sess_count[walk_session_number].cout)
if (!sess_local[walk_session_number].cin && !sess_local[walk_session_number].cout)
continue; // Unused. Skip it.
b[c].sid = walk_session_number;
b[c].in = sess_count[walk_session_number].cin;
b[c].out = sess_count[walk_session_number].cout;
b[c].in = sess_local[walk_session_number].cin;
b[c].out = sess_local[walk_session_number].cout;
if (++c > MAX_B_RECS) // Send a max of 400 elements in a packet.
break;
// Reset counters.
sess_count[walk_session_number].cin = sess_count[walk_session_number].cout = 0;
sess_local[walk_session_number].cin = sess_local[walk_session_number].cout = 0;
}
if (!c) // Didn't find any that changes. Get out of here!
@ -581,12 +581,12 @@ void cluster_check_master(void)
session[i].last_packet = time_now;
// Accumulate un-sent byte counters.
session[i].cin += sess_count[i].cin;
session[i].cout += sess_count[i].cout;
session[i].total_cin += sess_count[i].cin;
session[i].total_cout += sess_count[i].cout;
session[i].cin += sess_local[i].cin;
session[i].cout += sess_local[i].cout;
session[i].total_cin += sess_local[i].cin;
session[i].total_cout += sess_local[i].cout;
sess_count[i].cin = sess_count[i].cout = 0;
sess_local[i].cin = sess_local[i].cout = 0;
session[i].radius = 0; // Reset authentication as the radius blocks aren't up to date.