mirror of
https://github.com/ilyakooo0/urbit.git
synced 2024-12-18 12:22:10 +03:00
580a7323f4
Carts are now batches of events waiting to be or just recently persisted. _lo_work calls u2_reck_kick on the last batch of events, removes every batch that's been through Raft, and then prepares the next batch. TODO make _lo_punk et al stick things on roe TODO move disk persistence to raft.c TODO raft_push: lo_open / mark / lo_shut
57 lines
2.1 KiB
C
57 lines
2.1 KiB
C
/* include/f/arvo.h
|
|
**
|
|
** This file is in the public domain.
|
|
*/
|
|
/** Data structures.
|
|
**/
|
|
/* u2_cart: ovum carton.
|
|
*/
|
|
struct _u2_reck;
|
|
|
|
typedef struct _u2_cart {
|
|
u2_noun egg; // ovum itself
|
|
u2_bean did; // cart considered for commit?
|
|
u2_bean cit; // cart committed?
|
|
c3_w ent_w; // entry in raft queue?
|
|
void (*clr_f) // ovum processing failed
|
|
(struct _u2_reck *rec_u, // system
|
|
u2_noun, // egg itself
|
|
u2_noun, // failure mode
|
|
u2_noun); // trace if any
|
|
struct _u2_cart* nex_u; // next in queue
|
|
} u2_cart;
|
|
|
|
/* u2_reck: modern arvo structure.
|
|
*/
|
|
typedef struct _u2_reck {
|
|
c3_w kno_w; // kernel stage
|
|
c3_w rno_w; // rotor index (always 0)
|
|
c3_w ent_w; // event counter XX 64
|
|
|
|
u2_noun yot; // new toy system
|
|
u2_noun now; // current time, as noun
|
|
u2_noun wen; // current time, as text
|
|
u2_noun sev_l; // instance number
|
|
u2_noun sen; // instance string
|
|
u2_noun own; // owner list
|
|
|
|
u2_noun roe; // temporary unsaved events
|
|
u2_noun key; // log key, or 0
|
|
|
|
u2_noun ken; // kernel formula (for now)
|
|
u2_noun roc; // rotor core
|
|
|
|
union {
|
|
struct { uint64_t a; uint64_t b; };
|
|
struct {
|
|
struct _u2_cart* egg_u; // exit of ovum queue
|
|
struct _u2_cart* geg_u; // entry of ovum queue
|
|
} ova;
|
|
};
|
|
} u2_reck;
|
|
|
|
/** Global variables.
|
|
**/
|
|
#define u2_Arv ((u2_reck*)u2_at_cord(u2_wire_arv_r(u2_Wire), sizeof(u2_reck)))
|
|
#define u2A u2_Arv
|