Browse Source

reftable: implement record equality generically

This simplifies unittests a little, and provides further coverage for
reftable_record_copy().

Signed-off-by: Han-Wen Nienhuys <hanwen@google.com>
Signed-off-by: Junio C Hamano <gitster@pobox.com>
maint
Han-Wen Nienhuys 3 years ago committed by Junio C Hamano
parent
commit
c983374035
  1. 57
      reftable/record.c
  2. 5
      reftable/record.h
  3. 23
      reftable/record_test.c

57
reftable/record.c

@ -430,6 +430,15 @@ static int reftable_ref_record_is_deletion_void(const void *p)
(const struct reftable_ref_record *)p); (const struct reftable_ref_record *)p);
} }



static int reftable_ref_record_equal_void(const void *a,
const void *b, int hash_size)
{
struct reftable_ref_record *ra = (struct reftable_ref_record *) a;
struct reftable_ref_record *rb = (struct reftable_ref_record *) b;
return reftable_ref_record_equal(ra, rb, hash_size);
}

static struct reftable_record_vtable reftable_ref_record_vtable = { static struct reftable_record_vtable reftable_ref_record_vtable = {
.key = &reftable_ref_record_key, .key = &reftable_ref_record_key,
.type = BLOCK_TYPE_REF, .type = BLOCK_TYPE_REF,
@ -439,6 +448,7 @@ static struct reftable_record_vtable reftable_ref_record_vtable = {
.decode = &reftable_ref_record_decode, .decode = &reftable_ref_record_decode,
.release = &reftable_ref_record_release_void, .release = &reftable_ref_record_release_void,
.is_deletion = &reftable_ref_record_is_deletion_void, .is_deletion = &reftable_ref_record_is_deletion_void,
.equal = &reftable_ref_record_equal_void,
}; };


static void reftable_obj_record_key(const void *r, struct strbuf *dest) static void reftable_obj_record_key(const void *r, struct strbuf *dest)
@ -572,6 +582,25 @@ static int not_a_deletion(const void *p)
return 0; return 0;
} }


static int reftable_obj_record_equal_void(const void *a, const void *b, int hash_size)
{
struct reftable_obj_record *ra = (struct reftable_obj_record *) a;
struct reftable_obj_record *rb = (struct reftable_obj_record *) b;

if (ra->hash_prefix_len != rb->hash_prefix_len
|| ra->offset_len != rb->offset_len)
return 0;

if (ra->hash_prefix_len &&
memcmp(ra->hash_prefix, rb->hash_prefix, ra->hash_prefix_len))
return 0;
if (ra->offset_len &&
memcmp(ra->offsets, rb->offsets, ra->offset_len * sizeof(uint64_t)))
return 0;

return 1;
}

static struct reftable_record_vtable reftable_obj_record_vtable = { static struct reftable_record_vtable reftable_obj_record_vtable = {
.key = &reftable_obj_record_key, .key = &reftable_obj_record_key,
.type = BLOCK_TYPE_OBJ, .type = BLOCK_TYPE_OBJ,
@ -580,7 +609,8 @@ static struct reftable_record_vtable reftable_obj_record_vtable = {
.encode = &reftable_obj_record_encode, .encode = &reftable_obj_record_encode,
.decode = &reftable_obj_record_decode, .decode = &reftable_obj_record_decode,
.release = &reftable_obj_record_release, .release = &reftable_obj_record_release,
.is_deletion = not_a_deletion, .is_deletion = &not_a_deletion,
.equal = &reftable_obj_record_equal_void,
}; };


void reftable_log_record_print(struct reftable_log_record *log, void reftable_log_record_print(struct reftable_log_record *log,
@ -881,6 +911,14 @@ static int zero_hash_eq(uint8_t *a, uint8_t *b, int sz)
return !memcmp(a, b, sz); return !memcmp(a, b, sz);
} }


static int reftable_log_record_equal_void(const void *a,
const void *b, int hash_size)
{
return reftable_log_record_equal((struct reftable_log_record *) a,
(struct reftable_log_record *) b,
hash_size);
}

int reftable_log_record_equal(const struct reftable_log_record *a, int reftable_log_record_equal(const struct reftable_log_record *a,
const struct reftable_log_record *b, int hash_size) const struct reftable_log_record *b, int hash_size)
{ {
@ -924,6 +962,7 @@ static struct reftable_record_vtable reftable_log_record_vtable = {
.decode = &reftable_log_record_decode, .decode = &reftable_log_record_decode,
.release = &reftable_log_record_release_void, .release = &reftable_log_record_release_void,
.is_deletion = &reftable_log_record_is_deletion_void, .is_deletion = &reftable_log_record_is_deletion_void,
.equal = &reftable_log_record_equal_void
}; };


struct reftable_record reftable_new_record(uint8_t typ) struct reftable_record reftable_new_record(uint8_t typ)
@ -1042,6 +1081,14 @@ static int reftable_index_record_decode(void *rec, struct strbuf key,
return start.len - in.len; return start.len - in.len;
} }


static int reftable_index_record_equal(const void *a, const void *b, int hash_size)
{
struct reftable_index_record *ia = (struct reftable_index_record *) a;
struct reftable_index_record *ib = (struct reftable_index_record *) b;

return ia->offset == ib->offset && !strbuf_cmp(&ia->last_key, &ib->last_key);
}

static struct reftable_record_vtable reftable_index_record_vtable = { static struct reftable_record_vtable reftable_index_record_vtable = {
.key = &reftable_index_record_key, .key = &reftable_index_record_key,
.type = BLOCK_TYPE_INDEX, .type = BLOCK_TYPE_INDEX,
@ -1051,6 +1098,7 @@ static struct reftable_record_vtable reftable_index_record_vtable = {
.decode = &reftable_index_record_decode, .decode = &reftable_index_record_decode,
.release = &reftable_index_record_release, .release = &reftable_index_record_release,
.is_deletion = &not_a_deletion, .is_deletion = &not_a_deletion,
.equal = &reftable_index_record_equal,
}; };


void reftable_record_key(struct reftable_record *rec, struct strbuf *dest) void reftable_record_key(struct reftable_record *rec, struct strbuf *dest)
@ -1098,6 +1146,13 @@ int reftable_record_is_deletion(struct reftable_record *rec)
return rec->ops->is_deletion(rec->data); return rec->ops->is_deletion(rec->data);
} }


int reftable_record_equal(struct reftable_record *a, struct reftable_record *b, int hash_size)
{
if (a->ops != b->ops)
return 0;
return a->ops->equal(a->data, b->data, hash_size);
}

void reftable_record_from_ref(struct reftable_record *rec, void reftable_record_from_ref(struct reftable_record *rec,
struct reftable_ref_record *ref_rec) struct reftable_ref_record *ref_rec)
{ {

5
reftable/record.h

@ -58,6 +58,9 @@ struct reftable_record_vtable {


/* is this a tombstone? */ /* is this a tombstone? */
int (*is_deletion)(const void *rec); int (*is_deletion)(const void *rec);

/* Are two records equal? This assumes they have the same type. Returns 0 for non-equal. */
int (*equal)(const void *a, const void *b, int hash_size);
}; };


/* record is a generic wrapper for different types of records. */ /* record is a generic wrapper for different types of records. */
@ -98,7 +101,7 @@ struct reftable_obj_record {
}; };


/* see struct record_vtable */ /* see struct record_vtable */

int reftable_record_equal(struct reftable_record *a, struct reftable_record *b, int hash_size);
void reftable_record_key(struct reftable_record *rec, struct strbuf *dest); void reftable_record_key(struct reftable_record *rec, struct strbuf *dest);
uint8_t reftable_record_type(struct reftable_record *rec); uint8_t reftable_record_type(struct reftable_record *rec);
void reftable_record_copy_from(struct reftable_record *rec, void reftable_record_copy_from(struct reftable_record *rec,

23
reftable/record_test.c

@ -21,18 +21,7 @@ static void test_copy(struct reftable_record *rec)
reftable_record_copy_from(&copy, rec, GIT_SHA1_RAWSZ); reftable_record_copy_from(&copy, rec, GIT_SHA1_RAWSZ);
/* do it twice to catch memory leaks */ /* do it twice to catch memory leaks */
reftable_record_copy_from(&copy, rec, GIT_SHA1_RAWSZ); reftable_record_copy_from(&copy, rec, GIT_SHA1_RAWSZ);
switch (reftable_record_type(&copy)) { EXPECT(reftable_record_equal(rec, &copy, GIT_SHA1_RAWSZ));
case BLOCK_TYPE_REF:
EXPECT(reftable_ref_record_equal(reftable_record_as_ref(&copy),
reftable_record_as_ref(rec),
GIT_SHA1_RAWSZ));
break;
case BLOCK_TYPE_LOG:
EXPECT(reftable_log_record_equal(reftable_record_as_log(&copy),
reftable_record_as_log(rec),
GIT_SHA1_RAWSZ));
break;
}
reftable_record_destroy(&copy); reftable_record_destroy(&copy);
} }


@ -346,13 +335,7 @@ static void test_reftable_obj_record_roundtrip(void)
GIT_SHA1_RAWSZ); GIT_SHA1_RAWSZ);
EXPECT(n == m); EXPECT(n == m);


EXPECT(in.hash_prefix_len == out.hash_prefix_len); EXPECT(reftable_record_equal(&rec, &rec_out, GIT_SHA1_RAWSZ));
EXPECT(in.offset_len == out.offset_len);

EXPECT(!memcmp(in.hash_prefix, out.hash_prefix,
in.hash_prefix_len));
EXPECT(0 == memcmp(in.offsets, out.offsets,
sizeof(uint64_t) * in.offset_len));
strbuf_release(&key); strbuf_release(&key);
reftable_record_release(&rec_out); reftable_record_release(&rec_out);
} }
@ -390,7 +373,7 @@ static void test_reftable_index_record_roundtrip(void)
m = reftable_record_decode(&out_rec, key, extra, dest, GIT_SHA1_RAWSZ); m = reftable_record_decode(&out_rec, key, extra, dest, GIT_SHA1_RAWSZ);
EXPECT(m == n); EXPECT(m == n);


EXPECT(in.offset == out.offset); EXPECT(reftable_record_equal(&rec, &out_rec, GIT_SHA1_RAWSZ));


reftable_record_release(&out_rec); reftable_record_release(&out_rec);
strbuf_release(&key); strbuf_release(&key);

Loading…
Cancel
Save