if (fd>=0) close(fd);
}
-#define PE(m) do{ \
- rc= cht_posixerr(ip, errno, "failed to " m); goto x_rc; \
- }while(0)
-
/*==================== Subsystems and subtypes ====================*/
/*---------- Pathbuf ----------*/
}
mainfd= open(pathbuf_sfx(&rw->pbsome,".main"), O_RDONLY);
- if (mainfd<0) PE("open exist3ing database file .main");
+ if (mainfd<0) PE("open existing database file .main");
rc= acquire_lock(ip, &rw->pbsome, &rw->lock_fd); if (rc) goto x_rc;
r= fstat(mainfd, &stab); if (r) PE("fstat .main");
const Byte **data_r, int *len_r /* -1 => notfound */) {
Rw *rw= rw_v;
const HashValue *val;
- int r;
val= ht_lookup(&rw->logincore, key);
if (val) {
else { *data_r= 0; *len_r= -1; return TCL_OK; }
}
- r= cdb_find(&rw->cdb, key, strlen(key));
- if (!r) { *data_r= 0; *len_r= -1; return TCL_OK; }
- if (r<0) return cht_posixerr(ip, errno, "cdb_find failed");
- assert(r==1);
- *len_r= cdb_datalen(&rw->cdb);
- assert(*len_r > 0);
- *data_r= cdb_getdata(&rw->cdb);
- if (!*data_r) return cht_posixerr(ip, errno, "cdb_getdata failed");
- return TCL_OK;
+ return cht_cdb_lookup_cdb(ip, &rw->cdb, key, strlen(key), data_r, len_r);
}
int cht_do_cdbwr_lookup(ClientData cd, Tcl_Interp *ip, void *rw_v,
const char *key, Tcl_Obj *def,
Tcl_Obj **result) {
- return cht_cdb_dosomelookup(ip, rw_v, key, def, result,
- lookup_rw, cht_cdb_storeanswer_string);
+ const Byte *data;
+ int dlen, r;
+
+ r= lookup_rw(ip, rw_v, key, &data, &dlen); if (r) return r;
+ return cht_cdb_donesomelookup(ip, rw_v, def, result, data, dlen,
+ cht_cdb_storeanswer_string);
}
int cht_do_cdbwr_lookup_hb(ClientData cd, Tcl_Interp *ip, void *rw_v,
const char *key, Tcl_Obj *def,
Tcl_Obj **result) {
- return cht_cdb_dosomelookup(ip, rw_v, key, def, result,
- lookup_rw, cht_cdb_storeanswer_hb);
+ const Byte *data;
+ int dlen, r;
+
+ r= lookup_rw(ip, rw_v, key, &data, &dlen); if (r) return r;
+ return cht_cdb_donesomelookup(ip, rw_v, def, result, data, dlen,
+ cht_cdb_storeanswer_hb);
+}
+
+int cht_do_cdbtoplevel_cdb_wr(ClientData cd, Tcl_Interp *ip,
+ const Cdbwr_SubCommand* subcmd,
+ int objc, Tcl_Obj *const *objv) {
+ return subcmd->func((void*)subcmd,ip,objc,objv);
}