From: sapanb <sapanb@8c455092-636d-4788-adf5-e71def0336e8>
Date: Thu, 15 Nov 2007 22:07:28 +0000 (+0000)
Subject: Graceful recovery.
X-Git-Tag: fprobe-ulog-1.1.3-3~53
X-Git-Url: http://git.onelab.eu/?p=fprobe-ulog.git;a=commitdiff_plain;h=4ca11171ac9fca22562dc2c2f2255f74bf4c6f88

Graceful recovery.



git-svn-id: http://svn.planet-lab.org/svn/fprobe-ulog/trunk@6928 8c455092-636d-4788-adf5-e71def0336e8
---

diff --git a/src/fprobe-ulog.c b/src/fprobe-ulog.c
index 31d1e02..c5be35f 100644
--- a/src/fprobe-ulog.c
+++ b/src/fprobe-ulog.c
@@ -378,6 +378,18 @@ inline void copy_flow(struct Flow *src, struct Flow *dst)
 	dst->flags = src->flags;
 }
 
+void get_cur_epoch() {
+	int fd, len;
+	fd = open("/tmp/fprobe_last_epoch",O_RDONLY);
+	if (fd != -1) {
+		char snum[7];
+		read(fd, snum, 7);
+		sscanf(snum,"%d",&cur_epoch);
+	}
+	return;
+}
+
+
 void update_cur_epoch_file(int n) {
 	int fd, len;
 	char snum[7];
@@ -1447,6 +1459,8 @@ bad_collector:
 		peers[npeers].write_fd = START_VALUE;
 		peers[npeers].type = PEER_FILE;
 		peers[npeers].seq = 0;
+
+		get_cur_epoch();
 		npeers++;
 	}
 	else