projects
/
l2tpns.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
- fix leak in session freelist when initial RADIUS session allocation fails
[l2tpns.git]
/
cluster.c
diff --git
a/cluster.c
b/cluster.c
index
95c64a2
..
e3e7f01
100644
(file)
--- a/
cluster.c
+++ b/
cluster.c
@@
-1,6
+1,6
@@
// L2TPNS Clustering Stuff
// L2TPNS Clustering Stuff
-char const *cvs_id_cluster = "$Id: cluster.c,v 1.26.2.
3 2005/02/14 05:59
:27 bodea Exp $";
+char const *cvs_id_cluster = "$Id: cluster.c,v 1.26.2.
5 2005/05/02 09:03
:27 bodea Exp $";
#include <stdio.h>
#include <stdlib.h>
#include <stdio.h>
#include <stdlib.h>
@@
-579,9
+579,12
@@
void cluster_check_master(void)
continue;
}
continue;
}
- // Reset
all the
idle timeouts..
+ // Reset idle timeouts..
session[i].last_packet = time_now;
session[i].last_packet = time_now;
+ // Reset die relative to our uptime rather than the old master's
+ if (session[i].die) session[i].die = TIME;
+
// Accumulate un-sent byte counters.
session[i].cin += sess_local[i].cin;
session[i].cout += sess_local[i].cout;
// Accumulate un-sent byte counters.
session[i].cin += sess_local[i].cin;
session[i].cout += sess_local[i].cout;
@@
-1028,7
+1031,9
@@
static int cluster_handle_bytes(char *data, int size)
session[b->sid].cin += b->in;
session[b->sid].cout += b->out;
session[b->sid].cin += b->in;
session[b->sid].cout += b->out;
- session[b->sid].last_packet = time_now; // Reset idle timer!
+
+ if (b->in)
+ session[b->sid].last_packet = time_now; // Reset idle timer!
size -= sizeof(*b);
++b;
size -= sizeof(*b);
++b;