Commit b2d4e2f662ceec309a1231a20e81f0fb105e7542
2023-03-28T16:54:36
facts serial id
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56
diff --git a/libc3/facts.c b/libc3/facts.c
index 6f8d841..53435d3 100644
--- a/libc3/facts.c
+++ b/libc3/facts.c
@@ -48,6 +48,12 @@ s_fact * facts_add_fact (s_facts *facts, const s_fact *fact)
facts_lock_unlock_w(facts);
return &item->data;
}
+ tmp.id = facts->next_id;
+ if (facts->next_id == UW_MAX) {
+ errx(1, "facts serial id exhausted");
+ return NULL;
+ }
+ facts->next_id++;
if (facts->log)
facts_log_add(facts->log, &tmp);
item = set_add__fact(&facts->facts, &tmp);
diff --git a/libc3/types.h b/libc3/types.h
index f2555c3..ef5dc89 100644
--- a/libc3/types.h
+++ b/libc3/types.h
@@ -37,7 +37,9 @@ typedef uint64_t u64;
#define S32_MAX LONG_MAX
#define S64_MAX LLONG_MAX
+#define SW_MAX LONG_MAX
#define U64_MAX ULLONG_MAX
+#define UW_MAX ULONG_MAX
/* IEEE 754 floating point numbers. */
typedef float f32;
@@ -152,14 +154,14 @@ struct fact {
const s_tag *subject;
const s_tag *predicate;
const s_tag *object;
- uw id; /* XXX random without collision */
+ uw id; /* serial id */
};
struct fact_w {
s_tag *subject;
s_tag *predicate;
s_tag *object;
- uw id; /* XXX random without collision */
+ uw id; /* serial id */
};
struct frame {
@@ -421,6 +423,7 @@ struct facts {
pthread_rwlock_t rwlock;
sw rwlock_count;
pthread_t rwlock_thread;
+ uw next_id;
};
struct facts_cursor {