Lines Matching refs:iwrc
5 static iwrc _jb_put_new_lw(JBCOLL jbc, JBL jbl, int64_t *id);
9 IW_INLINE iwrc _jb_meta_nrecs_removedb(EJDB db, uint32_t dbid) { in _jb_meta_nrecs_removedb()
18 IW_INLINE iwrc _jb_meta_nrecs_update(EJDB db, uint32_t dbid, int64_t delta) { in _jb_meta_nrecs_update()
72 static iwrc _jb_coll_load_index_lr(JBCOLL jbc, IWKV_val *mval) { in _jb_coll_load_index_lr()
81 iwrc rc = jbl_from_buf_keep_onstack(&imeta, mval->data, mval->size); in _jb_coll_load_index_lr()
109 static iwrc _jb_coll_load_indexes_lr(JBCOLL jbc) { in _jb_coll_load_indexes_lr()
110 iwrc rc = 0; in _jb_coll_load_indexes_lr()
152 static iwrc _jb_coll_load_meta_lr(JBCOLL jbc) { in _jb_coll_load_meta_lr()
156 iwrc rc = jbl_at(jbm, "/name", &jbv); in _jb_coll_load_meta_lr()
196 static iwrc _jb_coll_init(JBCOLL jbc, IWKV_val *meta) { in _jb_coll_init()
198 iwrc rc = 0; in _jb_coll_init()
226 static iwrc _jb_idx_add_meta_lr(JBIDX idx, binn *list) { in _jb_idx_add_meta_lr()
227 iwrc rc = 0; in _jb_idx_add_meta_lr()
259 static iwrc _jb_coll_add_meta_lr(JBCOLL jbc, binn *list) { in _jb_coll_add_meta_lr()
260 iwrc rc = 0; in _jb_coll_add_meta_lr()
299 static iwrc _jb_db_meta_load(EJDB db) { in _jb_db_meta_load()
300 iwrc rc = 0; in _jb_db_meta_load()
345 static iwrc _jb_db_release(EJDB *dbp) { in _jb_db_release()
346 iwrc rc = 0; in _jb_db_release()
381 static iwrc _jb_coll_acquire_keeplock2(EJDB db, const char *coll, jb_coll_acquire_t acm, JBCOLL *jb… in _jb_coll_acquire_keeplock2()
386 iwrc rc = 0; in _jb_coll_acquire_keeplock2()
491 IW_INLINE iwrc _jb_coll_acquire_keeplock(EJDB db, const char *coll, bool wl, JBCOLL *jbcp) { in _jb_coll_acquire_keeplock()
495 static iwrc _jb_idx_record_add(JBIDX idx, int64_t id, JBL jbl, JBL jblprev) { in _jb_idx_record_add()
505 iwrc rc = 0; in _jb_idx_record_add()
655 IW_INLINE iwrc _jb_idx_record_remove(JBIDX idx, int64_t id, JBL jbl) { in _jb_idx_record_remove()
659 static iwrc _jb_idx_fill(JBIDX idx) { in _jb_idx_fill()
666 iwrc rc = iwkv_cursor_open(idx->jbc->cdb, &cur, IWKV_CURSOR_BEFORE_FIRST, 0); in _jb_idx_fill()
688 static iwrc _jb_put_handler_after(iwrc rc, struct _JBPHCTX *ctx) { in _jb_put_handler_after()
734 static iwrc _jb_put_handler(const IWKV_val *key, const IWKV_val *val, IWKV_val *oldval, void *op) { in _jb_put_handler()
742 static iwrc _jb_exec_scan_init(JBEXEC *ctx) { in _jb_exec_scan_init()
758 iwrc rc = jbi_selection(ctx); in _jb_exec_scan_init()
786 static iwrc _jb_noop_visitor(struct _EJDB_EXEC *ctx, EJDB_DOC doc, int64_t *step) { in _jb_noop_visitor()
790 IW_INLINE iwrc _jb_put_impl(JBCOLL jbc, JBL jbl, int64_t id) { in _jb_put_impl()
800 iwrc rc = jbl_as_buf(jbl, &val.data, &val.size); in _jb_put_impl()
805 iwrc jb_put(JBCOLL jbc, JBL jbl, int64_t id) { in jb_put()
809 iwrc jb_cursor_set(JBCOLL jbc, IWKV_cursor cur, int64_t id, JBL jbl) { in jb_cursor_set()
816 iwrc rc = jbl_as_buf(jbl, &val.data, &val.size); in jb_cursor_set()
821 static iwrc _jb_exec_upsert_lw(JBEXEC *ctx) { in _jb_exec_upsert_lw()
824 iwrc rc = 0; in _jb_exec_upsert_lw()
865 iwrc ejdb_exec(EJDB_EXEC *ux) { in ejdb_exec()
870 iwrc rc = 0; in ejdb_exec()
933 static iwrc _jb_exec_list_visitor(struct _EJDB_EXEC *ctx, EJDB_DOC doc, int64_t *step) { in _jb_exec_list_visitor()
961 static iwrc _jb_list(EJDB db, JQL q, EJDB_DOC *first, int64_t limit, IWXSTR *log, IWPOOL *pool) { in _jb_list()
965 iwrc rc = 0; in _jb_list()
985 static iwrc _jb_count(EJDB db, JQL q, int64_t *count, int64_t limit, IWXSTR *log) { in _jb_count()
995 iwrc rc = ejdb_exec(&ux); in _jb_count()
1000 iwrc ejdb_count(EJDB db, JQL q, int64_t *count, int64_t limit) { in ejdb_count()
1004 iwrc ejdb_count2(EJDB db, const char *coll, const char *q, int64_t *count, int64_t limit) { in ejdb_count2()
1006 iwrc rc = jql_create(&jql, coll, q); in ejdb_count2()
1013 iwrc ejdb_update(EJDB db, JQL q) { in ejdb_update()
1018 iwrc ejdb_update2(EJDB db, const char *coll, const char *q) { in ejdb_update2()
1023 iwrc ejdb_list(EJDB db, JQL q, EJDB_DOC *first, int64_t limit, IWPOOL *pool) { in ejdb_list()
1027 iwrc ejdb_list3(EJDB db, const char *coll, const char *query, int64_t limit, IWXSTR *log, EJDB_LIST… in ejdb_list3()
1031 iwrc rc = 0; in ejdb_list3()
1058 iwrc ejdb_list4(EJDB db, JQL q, int64_t limit, IWXSTR *log, EJDB_LIST *listp) { in ejdb_list4()
1062 iwrc rc = 0; in ejdb_list4()
1088 iwrc ejdb_list2(EJDB db, const char *coll, const char *query, int64_t limit, EJDB_LIST *listp) { in ejdb_list2()
1107 iwrc ejdb_remove_index(EJDB db, const char *coll, const char *path, ejdb_idx_mode_t mode) { in ejdb_remove_index()
1117 …iwrc rc = _jb_coll_acquire_keeplock2(db, coll, JB_COLL_ACQUIRE_WRITE | JB_COLL_ACQUIRE_EXISTING, &… in ejdb_remove_index()
1154 iwrc ejdb_ensure_index(EJDB db, const char *coll, const char *path, ejdb_idx_mode_t mode) { in ejdb_ensure_index()
1176 iwrc rc = _jb_coll_acquire_keeplock(db, coll, true, &jbc); in ejdb_ensure_index()
1261 static iwrc _jb_patch( in _jb_patch()
1277 iwrc rc = _jb_coll_acquire_keeplock(db, coll, true, &jbc); in _jb_patch()
1358 static iwrc _jb_wal_lock_interceptor(bool before, void *op) { in _jb_wal_lock_interceptor()
1360 iwrc rc = 0; in _jb_wal_lock_interceptor()
1371 iwrc ejdb_patch(EJDB db, const char *coll, const char *patchjson, int64_t id) { in ejdb_patch()
1375 iwrc ejdb_patch_jbn(EJDB db, const char *coll, JBL_NODE patch, int64_t id) { in ejdb_patch_jbn()
1379 iwrc ejdb_patch_jbl(EJDB db, const char *coll, JBL patch, int64_t id) { in ejdb_patch_jbl()
1383 iwrc ejdb_merge_or_put(EJDB db, const char *coll, const char *patchjson, int64_t id) { in ejdb_merge_or_put()
1387 iwrc ejdb_merge_or_put_jbn(EJDB db, const char *coll, JBL_NODE patch, int64_t id) { in ejdb_merge_or_put_jbn()
1391 iwrc ejdb_merge_or_put_jbl(EJDB db, const char *coll, JBL patch, int64_t id) { in ejdb_merge_or_put_jbl()
1395 iwrc ejdb_put(EJDB db, const char *coll, JBL jbl, int64_t id) { in ejdb_put()
1401 iwrc rc = _jb_coll_acquire_keeplock(db, coll, true, &jbc); in ejdb_put()
1411 static iwrc _jb_put_new_lw(JBCOLL jbc, JBL jbl, int64_t *id) { in _jb_put_new_lw()
1412 iwrc rc = 0; in _jb_put_new_lw()
1436 iwrc ejdb_put_new(EJDB db, const char *coll, JBL jbl, int64_t *id) { in ejdb_put_new()
1445 iwrc rc = _jb_coll_acquire_keeplock(db, coll, true, &jbc); in ejdb_put_new()
1454 iwrc ejdb_put_new_jbn(EJDB db, const char *coll, JBL_NODE jbn, int64_t *id) { in ejdb_put_new_jbn()
1456 iwrc rc = jbl_from_node(&jbl, jbn); in ejdb_put_new_jbn()
1463 iwrc jb_get(EJDB db, const char *coll, int64_t id, jb_coll_acquire_t acm, JBL *jblp) { in jb_get()
1473 iwrc rc = _jb_coll_acquire_keeplock2(db, coll, acm, &jbc); in jb_get()
1494 iwrc ejdb_get(EJDB db, const char *coll, int64_t id, JBL *jblp) { in ejdb_get()
1498 iwrc ejdb_del(EJDB db, const char *coll, int64_t id) { in ejdb_del()
1504 …iwrc rc = _jb_coll_acquire_keeplock2(db, coll, JB_COLL_ACQUIRE_WRITE | JB_COLL_ACQUIRE_EXISTING, &… in ejdb_del()
1529 iwrc jb_del(JBCOLL jbc, JBL jbl, int64_t id) { in jb_del()
1530 iwrc rc = 0; in jb_del()
1542 iwrc jb_cursor_del(JBCOLL jbc, IWKV_cursor cur, int64_t id, JBL jbl) { in jb_cursor_del()
1543 iwrc rc = 0; in jb_cursor_del()
1554 iwrc ejdb_ensure_collection(EJDB db, const char *coll) { in ejdb_ensure_collection()
1557 iwrc rc = _jb_coll_acquire_keeplock(db, coll, false, &jbc); in ejdb_ensure_collection()
1563 iwrc ejdb_remove_collection(EJDB db, const char *coll) { in ejdb_remove_collection()
1565 iwrc rc = 0; in ejdb_remove_collection()
1609 iwrc jb_collection_join_resolver(int64_t id, const char *coll, JBL *out, JBEXEC *ctx) { in jb_collection_join_resolver()
1630 iwrc ejdb_rename_collection(EJDB db, const char *coll, const char *new_coll) { in ejdb_rename_collection()
1635 iwrc rc = 0; in ejdb_rename_collection()
1713 iwrc ejdb_get_meta(EJDB db, JBL *jblp) { in ejdb_get_meta()
1717 iwrc rc = jbl_create_empty_object(&jbl); in ejdb_get_meta()
1766 iwrc ejdb_online_backup(EJDB db, uint64_t *ts, const char *target_file) { in ejdb_online_backup()
1771 iwrc ejdb_get_iwkv(EJDB db, IWKV *kvp) { in ejdb_get_iwkv()
1779 iwrc ejdb_open(const EJDB_OPTS *_opts, EJDB *ejdbp) { in ejdb_open()
1782 iwrc rc = ejdb_init(); in ejdb_open()
1879 iwrc ejdb_close(EJDB *ejdbp) { in ejdb_close()
1888 iwrc rc = _jb_db_release(ejdbp); in ejdb_close()
1939 iwrc ejdb_init() { in ejdb_init()
1944 iwrc rc = iw_init(); in ejdb_init()