From 3d188ab6d9ae84497a672c9d0c27e3ab1500db23 Mon Sep 17 00:00:00 2001
From: skywind3000 <skywind3000@gmail.com>
Date: Tue, 17 Mar 2020 02:05:41 +0800
Subject: [PATCH] update

---
 czmod/czmod.c | 65 ++++++++++++++++++++++++++++++++++++++++++++++++++-
 1 file changed, 64 insertions(+), 1 deletion(-)

diff --git a/czmod/czmod.c b/czmod/czmod.c
index 3105cad..1ec1dd4 100644
--- a/czmod/czmod.c
+++ b/czmod/czmod.c
@@ -17,8 +17,11 @@
 #include <windows.h>
 #elif defined(__linux)
 // #include <linux/limits.h>
+#include <limits.h>
 #endif
 
+#define IB_STRING_SSO 256
+
 #include "iposix.c"
 #include "imembase.c"
 
@@ -281,6 +284,61 @@ void data_add(ib_array *items, const char *path)
 }
 
 
+//---------------------------------------------------------------------
+// 
+//---------------------------------------------------------------------
+void z_insert(const char *newpath)
+{
+	static char tmpname[PATH_MAX + 10];
+	static char text[PATH_MAX + 100];
+	const char *data = get_data_file();
+	FILE *fin = fopen(data, "r");
+	FILE *fout;
+	while (1) {
+		char tmp[100];
+		sprintf(tmp, ".%u%03u%d", (uint32_t)time(NULL), 
+				(uint32_t)(clock() % 1000), rand() % 10000);
+		sprintf(tmpname, "%s%s", data, tmp);
+		if (iposix_path_isdir(tmpname) < 0) break;
+	}
+	fout = fopen(tmpname, "w");
+	if (fin) {
+		int found = 0;
+		while (!feof(fin)) {
+			uint32_t rank, ts;
+			text[0] = 0;
+			fgets(text, PATH_MAX + 100, fin);
+			char *p1 = strchr(text, '|');
+			if (p1 == NULL) continue;
+			*p1++ = 0;
+			char *p2 = strchr(p1, '|');
+			if (p2 == NULL) continue;
+			*p2++ = 0;
+			if (strcmp(text, newpath) == 0) {
+				found = 1;
+				sscanf(p1, "%u", &rank);
+				sscanf(p2, "%u", &ts);
+				rank++;
+				ts = (uint32_t)time(NULL);
+				fprintf(fout, "%s|%u|%u\n", text, rank, ts);
+			}
+			else {
+				fprintf(fout, "%s|%s|%s\n", text, p1, p2);
+			}
+		}
+		if (!found) {
+			fprintf(fout, "%s|1|%u\n", newpath, (uint32_t)time(NULL));
+		}
+		fclose(fin);
+	}
+	else {
+		fprintf(fout, "%s|1|%u\n", newpath, (uint32_t)time(NULL));
+	}
+	fclose(fout);
+	rename(tmpname, data);
+}
+
+
 //---------------------------------------------------------------------
 // add to database
 //---------------------------------------------------------------------
@@ -307,7 +365,8 @@ int main(int argc, char *argv[])
 		printf("begin\n");
 		clock_t ts = (uint64_t)clock();
 		for (i = 0; i < 1000; i++) {
-			z_add("/tmp");
+			// z_add("/tmp");
+			z_insert("/tmp");
 		}
 		ts = clock() - ts;
 		ts = (ts * 1000) / CLOCKS_PER_SEC;
@@ -316,7 +375,11 @@ int main(int argc, char *argv[])
 	}
 	if (strcmp(argv[1], "--add") == 0) {
 		if (argc >= 3) {
+#if 0
 			z_add(argv[2]);
+#else
+			z_insert(argv[2]);
+#endif
 		}
 	}
 	return 0;