1 d957951b 2005-02-11 devnull #include <u.h>
2 d957951b 2005-02-11 devnull #include <libc.h>
3 d957951b 2005-02-11 devnull #include <bio.h>
4 d957951b 2005-02-11 devnull #include <ndb.h>
6 d957951b 2005-02-11 devnull struct Ndbcache
8 d957951b 2005-02-11 devnull Ndbcache *next;
9 d957951b 2005-02-11 devnull char *attr;
10 d957951b 2005-02-11 devnull char *val;
12 d957951b 2005-02-11 devnull Ndbtuple *t;
17 cbeb0b26 2006-04-01 devnull Maxcached= 128
20 d957951b 2005-02-11 devnull static void
21 d957951b 2005-02-11 devnull ndbcachefree(Ndbcache *c)
23 d957951b 2005-02-11 devnull free(c->val);
24 d957951b 2005-02-11 devnull free(c->attr);
26 d957951b 2005-02-11 devnull ndbfree(c->t);
30 d957951b 2005-02-11 devnull static Ndbtuple*
31 d957951b 2005-02-11 devnull ndbcopy(Ndb *db, Ndbtuple *from_t, Ndbs *from_s, Ndbs *to_s)
33 d957951b 2005-02-11 devnull Ndbtuple *first, *to_t, *last, *line;
34 d957951b 2005-02-11 devnull int newline;
36 d957951b 2005-02-11 devnull *to_s = *from_s;
37 d957951b 2005-02-11 devnull to_s->t = nil;
38 d957951b 2005-02-11 devnull to_s->db = db;
40 d957951b 2005-02-11 devnull newline = 1;
41 d957951b 2005-02-11 devnull last = nil;
42 d957951b 2005-02-11 devnull first = nil;
43 d957951b 2005-02-11 devnull line = nil;
44 d957951b 2005-02-11 devnull for(; from_t != nil; from_t = from_t->entry){
45 d957951b 2005-02-11 devnull to_t = ndbnew(from_t->attr, from_t->val);
47 d957951b 2005-02-11 devnull /* have s point to matching tuple */
48 d957951b 2005-02-11 devnull if(from_s->t == from_t)
49 d957951b 2005-02-11 devnull to_s->t = to_t;
51 d957951b 2005-02-11 devnull if(newline)
52 d957951b 2005-02-11 devnull line = to_t;
54 d957951b 2005-02-11 devnull last->line = to_t;
56 d957951b 2005-02-11 devnull if(last != nil)
57 d957951b 2005-02-11 devnull last->entry = to_t;
59 d957951b 2005-02-11 devnull first = to_t;
60 d957951b 2005-02-11 devnull line = to_t;
62 d957951b 2005-02-11 devnull to_t->entry = nil;
63 d957951b 2005-02-11 devnull to_t->line = line;
64 d957951b 2005-02-11 devnull last = to_t;
65 d957951b 2005-02-11 devnull newline = from_t->line != from_t->entry;
67 d957951b 2005-02-11 devnull return first;
71 d957951b 2005-02-11 devnull * if found, move to front
74 d957951b 2005-02-11 devnull _ndbcachesearch(Ndb *db, Ndbs *s, char *attr, char *val, Ndbtuple **t)
76 d957951b 2005-02-11 devnull Ndbcache *c, **l;
78 d957951b 2005-02-11 devnull *t = nil;
80 d957951b 2005-02-11 devnull for(l = &db->cache; *l != nil; l = &(*l)->next){
82 d957951b 2005-02-11 devnull if(strcmp(c->attr, attr) == 0 && strcmp(c->val, val) == 0)
85 d957951b 2005-02-11 devnull if(*l == nil)
86 d957951b 2005-02-11 devnull return -1;
88 d957951b 2005-02-11 devnull /* move to front */
89 d957951b 2005-02-11 devnull *l = c->next;
90 d957951b 2005-02-11 devnull c->next = db->cache;
91 d957951b 2005-02-11 devnull db->cache = c;
93 d957951b 2005-02-11 devnull *t = ndbcopy(db, c->t, &c->s, s);
94 d957951b 2005-02-11 devnull return 0;
97 d957951b 2005-02-11 devnull Ndbtuple*
98 d957951b 2005-02-11 devnull _ndbcacheadd(Ndb *db, Ndbs *s, char *attr, char *val, Ndbtuple *t)
100 d957951b 2005-02-11 devnull Ndbcache *c, **l;
102 d957951b 2005-02-11 devnull c = mallocz(sizeof *c, 1);
103 d957951b 2005-02-11 devnull if(c == nil)
104 d957951b 2005-02-11 devnull return nil;
105 d957951b 2005-02-11 devnull c->attr = strdup(attr);
106 d957951b 2005-02-11 devnull if(c->attr == nil)
107 d957951b 2005-02-11 devnull goto err;
108 d957951b 2005-02-11 devnull c->val = strdup(val);
109 d957951b 2005-02-11 devnull if(c->val == nil)
110 d957951b 2005-02-11 devnull goto err;
111 d957951b 2005-02-11 devnull c->t = ndbcopy(db, t, s, &c->s);
112 d957951b 2005-02-11 devnull if(c->t == nil && t != nil)
113 d957951b 2005-02-11 devnull goto err;
115 d957951b 2005-02-11 devnull /* add to front */
116 d957951b 2005-02-11 devnull c->next = db->cache;
117 d957951b 2005-02-11 devnull db->cache = c;
119 d957951b 2005-02-11 devnull /* trim list */
120 d957951b 2005-02-11 devnull if(db->ncache < Maxcached){
121 d957951b 2005-02-11 devnull db->ncache++;
122 d957951b 2005-02-11 devnull return t;
124 d957951b 2005-02-11 devnull for(l = &db->cache; (*l)->next; l = &(*l)->next)
127 d957951b 2005-02-11 devnull *l = nil;
129 d957951b 2005-02-11 devnull ndbcachefree(c);
130 d957951b 2005-02-11 devnull return t;
134 d957951b 2005-02-11 devnull _ndbcacheflush(Ndb *db)
136 d957951b 2005-02-11 devnull Ndbcache *c;
138 d957951b 2005-02-11 devnull while(db->cache != nil){
139 d957951b 2005-02-11 devnull c = db->cache;
140 d957951b 2005-02-11 devnull db->cache = c->next;
141 d957951b 2005-02-11 devnull ndbcachefree(c);
143 d957951b 2005-02-11 devnull db->ncache = 0;