mirror of
https://github.com/stedolan/jq.git
synced 2024-05-11 05:55:39 +00:00
4f747e6fff
A few more tests, now passes valgrind.
154 lines
4.0 KiB
C
154 lines
4.0 KiB
C
#ifndef FORKABLE_STACK_H
|
|
#define FORKABLE_STACK_H
|
|
#include <stdlib.h>
|
|
#include <stddef.h>
|
|
#include <assert.h>
|
|
#include <string.h>
|
|
|
|
struct forkable_stack_header {
|
|
int next;
|
|
};
|
|
|
|
#define FORKABLE_STACK_HEADER struct forkable_stack_header fk_header_
|
|
|
|
struct forkable_stack {
|
|
// Stack grows down from stk+length
|
|
|
|
char* stk;
|
|
|
|
// stk+length is just past end of allocated area
|
|
// stk = malloc(length)
|
|
int length;
|
|
|
|
// stk+pos is header of top object, or stk+length if empty
|
|
int pos;
|
|
|
|
// everything after-or-including stk+savedlimit must be preserved
|
|
int savedlimit;
|
|
};
|
|
|
|
static void forkable_stack_check(struct forkable_stack* s) {
|
|
assert(s->stk);
|
|
assert(s->length > 0);
|
|
assert(s->pos >= 0 && s->pos <= s->length);
|
|
assert(s->savedlimit >= 0 && s->savedlimit <= s->length);
|
|
}
|
|
|
|
static int forkable_stack_empty(struct forkable_stack* s) {
|
|
return s->pos == s->length;
|
|
}
|
|
|
|
static void forkable_stack_init(struct forkable_stack* s, size_t sz) {
|
|
s->stk = malloc(sz);
|
|
s->length = sz;
|
|
s->pos = s->length;
|
|
s->savedlimit = s->length;
|
|
forkable_stack_check(s);
|
|
}
|
|
|
|
static void forkable_stack_free(struct forkable_stack* s) {
|
|
assert(forkable_stack_empty(s));
|
|
assert(s->savedlimit == s->length);
|
|
free(s->stk);
|
|
s->stk = 0;
|
|
}
|
|
|
|
static void* forkable_stack_push(struct forkable_stack* s, size_t size) {
|
|
forkable_stack_check(s);
|
|
int curr = s->pos < s->savedlimit ? s->pos : s->savedlimit;
|
|
if (curr - size < 0) {
|
|
assert(0);
|
|
int oldlen = s->length;
|
|
s->length = (size + oldlen + 1024) * 2;
|
|
s->stk = realloc(s->stk, s->length);
|
|
int shift = s->length - oldlen;
|
|
memmove(s->stk + shift, s->stk, oldlen);
|
|
s->pos += shift;
|
|
s->savedlimit += shift;
|
|
curr += shift;
|
|
}
|
|
void* ret = (void*)(s->stk + curr - size);
|
|
((struct forkable_stack_header*)ret)->next = s->pos;
|
|
s->pos = curr - size;
|
|
forkable_stack_check(s);
|
|
return ret;
|
|
}
|
|
|
|
static void* forkable_stack_peek(struct forkable_stack* s) {
|
|
assert(!forkable_stack_empty(s));
|
|
forkable_stack_check(s);
|
|
return (void*)(s->stk + s->pos);
|
|
}
|
|
|
|
static void* forkable_stack_peek_next(struct forkable_stack* s, void* top) {
|
|
forkable_stack_check(s);
|
|
struct forkable_stack_header* elem = top;
|
|
if (elem->next < s->length) {
|
|
return (void*)(s->stk + elem->next);
|
|
} else {
|
|
return 0;
|
|
}
|
|
}
|
|
|
|
// Returns 1 if the next forkable_stack_pop will permanently remove an
|
|
// object from the stack (i.e. the top object was not saved with a fork)
|
|
static int forkable_stack_pop_will_free(struct forkable_stack* s) {
|
|
return s->pos < s->savedlimit ? 1 : 0;
|
|
}
|
|
|
|
static void forkable_stack_pop(struct forkable_stack* s) {
|
|
forkable_stack_check(s);
|
|
struct forkable_stack_header* elem = forkable_stack_peek(s);
|
|
s->pos = elem->next;
|
|
}
|
|
|
|
|
|
|
|
struct forkable_stack_state {
|
|
int prevpos, prevlimit;
|
|
};
|
|
|
|
static void forkable_stack_save(struct forkable_stack* s, struct forkable_stack_state* state) {
|
|
forkable_stack_check(s);
|
|
state->prevpos = s->pos;
|
|
state->prevlimit = s->savedlimit;
|
|
if (s->pos < s->savedlimit) s->savedlimit = s->pos;
|
|
}
|
|
|
|
static void forkable_stack_switch(struct forkable_stack* s, struct forkable_stack_state* state) {
|
|
forkable_stack_check(s);
|
|
int curr_pos = s->pos;
|
|
s->pos = state->prevpos;
|
|
state->prevpos = curr_pos;
|
|
|
|
int curr_limit = s->savedlimit;
|
|
if (curr_pos < curr_limit) s->savedlimit = curr_pos;
|
|
//state->prevlimit = curr_limit; FIXME clean up
|
|
forkable_stack_check(s);
|
|
}
|
|
|
|
static void forkable_stack_restore(struct forkable_stack* s, struct forkable_stack_state* state) {
|
|
forkable_stack_check(s);
|
|
assert(s->savedlimit <= state->prevpos);
|
|
assert(s->savedlimit <= state->prevlimit);
|
|
s->pos = state->prevpos;
|
|
s->savedlimit = state->prevlimit;
|
|
forkable_stack_check(s);
|
|
}
|
|
|
|
typedef int stack_idx;
|
|
|
|
static stack_idx forkable_stack_to_idx(struct forkable_stack* s, void* ptr) {
|
|
char* item = ptr;
|
|
int pos = item - s->stk;
|
|
assert(pos >= 0 && pos < s->length);
|
|
return s->length - pos;
|
|
}
|
|
|
|
static void* forkable_stack_from_idx(struct forkable_stack* s, stack_idx idx) {
|
|
assert(idx >= 1 && idx <= s->length);
|
|
return &s->stk[s->length - idx];
|
|
}
|
|
|
|
#endif
|