X-Git-Url: https://git.sesse.net/?a=blobdiff_plain;f=binloader.cpp;h=730f59279eba946af8073826b08cf775564cf994;hb=f3225963af3ef8bf33b49d5b51a37d36f47e1482;hp=115cba61f571298146cf66ad44c0d473f3dafb3c;hpb=a40e42df4c193ed82217e18652592f6b773b1f18;p=remoteglot-book

diff --git a/binloader.cpp b/binloader.cpp
index 115cba6..730f592 100644
--- a/binloader.cpp
+++ b/binloader.cpp
@@ -12,33 +12,36 @@
 #include <unordered_set>
 #include <string.h>
 #include "count.pb.h"
-#include "arena.h"
 #include "hash.h"
 
 #define DUMMY_TIMESTAMP 32503680000
 
 using namespace std;
 
-static int memcmp_different_len(const void *s1, size_t n1, const void *s2, size_t n2)
+static inline int memcmp_different_len(const void *s1, size_t n1, const void *s2, size_t n2)
 {
-	int shared_len = min(n1, n2);
+	size_t shared_len = min(n1, n2);
+	if (shared_len >= 8) {
+		uint64_t a1 = *(const uint64_t *)s1;
+		uint64_t a2 = *(const uint64_t *)s2;
+		if (a1 != a2) {
+			a1 = __builtin_bswap64(a1);
+			a2 = __builtin_bswap64(a2);
+			return (a1 < a2) ? -1 : 1;
+		}
+	}
+
 	int s = memcmp(s1, s2, shared_len);
 	if (s != 0) {
 		return s;
 	}
 
-	if (n1 < n2) {
-		return -1;
-	} else if (n1 > n2) {
-		return 1;
-	} else {
-		return 0;
-	}
+	return n2 - n1;
 }
 
 enum Result { WHITE = 0, DRAW, BLACK };
 struct Element {
-	char *bpfen;  // includes prev_board_hash
+	char bpfen[32];  // includes prev_board_hash
 	int bpfen_len;
 	char move[8];   // Na1xc3+
 	Result result;
@@ -55,7 +58,6 @@ struct Element {
 
 struct ShardData {
 	vector<Element> elems;
-	unique_ptr<Arena> arena;  // Used to allocate bpfen.
 	int num_written_subshards = 0;
 };
 
@@ -96,7 +98,7 @@ void write_subshard(const char *basename, ShardData* shard, int bucket)
 			c.set_pgn_file_num(e.file_num);
 			c.set_pgn_start_position(e.start_position);
 		}
-		if (!moves.count(e.move)) {
+		if (strlen(e.move) > 0 && !moves.count(e.move)) {
 			moves.insert(e.move);
 			c.add_move(e.move);
 		}
@@ -115,7 +117,6 @@ void write_subshard(const char *basename, ShardData* shard, int bucket)
 	mtbl_writer_destroy(&mtbl);
 
 	shard->elems.clear();
-	shard->arena.reset(new Arena);
 }
 
 int main(int argc, char **argv)
@@ -128,7 +129,6 @@ int main(int argc, char **argv)
 
 	for (int i = 0; i < num_buckets; ++i) {
 		shards[i].elems.reserve(num_pos_per_subshard);
-		shards[i].arena.reset(new Arena);
 	}
 
 	size_t num_elems = 0;
@@ -150,6 +150,7 @@ int main(int argc, char **argv)
 			if (bpfen_len == -1) {
 				break;
 			}
+			assert(bpfen_len <= 32);
 			if (bpfen_len >= int(sizeof(bpfen))) {
 				fprintf(stderr, "Overlong BPFEN (%d bytes)\n", bpfen_len);
 		//		exit(1);
@@ -213,7 +214,9 @@ int main(int argc, char **argv)
 		//		exit(1);
 				break;
 			}
-			if (fread(&move[0], l, 1, fp) != 1) {
+			if (l == 0) {
+				move[0] = 0;
+			} else if (fread(&move[0], l, 1, fp) != 1) {
 				perror("fread()");
 		//		exit(1);
 				break;
@@ -222,7 +225,6 @@ int main(int argc, char **argv)
 
 			int bucket = hash_key_to_bucket(bpfen, bpfen_len, num_buckets);
 			Element e;
-			e.bpfen = shards[bucket].arena->alloc(bpfen_len);
 			memcpy(e.bpfen, bpfen, bpfen_len);
 			e.bpfen_len = bpfen_len;
 			strcpy(e.move, move);