Home
last modified time | relevance | path

Searched refs:db (Results 1 – 25 of 134) sorted by relevance

123456

/f-stack/freebsd/contrib/openzfs/module/zfs/
H A Ddbuf.c952 ASSERT3U(db->db.db_offset, ==, db->db_blkid * db->db.db_size); in dbuf_verify()
1363 bzero(db->db.db_data, db->db.db_size); in dbuf_read_hole()
1481 db->db.db_object, db->db_level, db->db_blkid); in dbuf_read_impl()
1635 db->db.db_object, db->db_level, db->db_blkid); in dbuf_read()
1876 bzero(db->db.db_data, db->db.db_size); in dbuf_free_range()
2581 bzero(db->db.db_data, db->db.db_size); in dmu_buf_fill_done()
2762 db->db.db_size, db); in dbuf_destroy()
3472 db->db.db_size, db); in dbuf_hold_impl()
3714 db->db.db_size, db); in dbuf_rele_and_unlock()
4486 bzero(db->db.db_data, db->db.db_size); in dbuf_write_children_ready()
[all …]
H A Ddnode_sync.c82 ASSERT(db->db.db_data); in dnode_increase_indirection()
84 ASSERT3U(sizeof (blkptr_t) * nblkptr, <=, db->db.db_size); in dnode_increase_indirection()
85 bcopy(dn->dn_phys->dn_blkptr, db->db.db_data, in dnode_increase_indirection()
112 if (db->db.db_data) in dnode_increase_indirection()
113 child->db_blkptr = (blkptr_t *)db->db.db_data + i; in dnode_increase_indirection()
191 ASSERT3U(db->db.db_size, ==, 1 << dn->dn_phys->dn_indblkshift); in free_verify()
192 ASSERT3U(off+num, <=, db->db.db_size >> SPA_BLKPTRSHIFT); in free_verify()
304 bp = db->db.db_data; in free_children()
347 for (i = 0, bp = db->db.db_data; i < 1 << epbs; i++, bp++) in free_children()
349 bzero(db->db.db_data, db->db.db_size); in free_children()
[all …]
H A Ddbuf_stats.c69 dnode_t *dn = DB_DNODE(db); in __dbuf_stats_hash_table_data()
72 if (db->db_buf) in __dbuf_stats_hash_table_data()
85 (longlong_t)db->db.db_object, in __dbuf_stats_hash_table_data()
88 (u_longlong_t)db->db.db_offset, in __dbuf_stats_hash_table_data()
89 (u_longlong_t)db->db.db_size, in __dbuf_stats_hash_table_data()
90 !!dbuf_is_metadata(db), in __dbuf_stats_hash_table_data()
91 db->db_state, in __dbuf_stats_hash_table_data()
132 dmu_buf_impl_t *db; in dbuf_stats_hash_table_data() local
141 for (db = h->hash_table[dsh->idx]; db != NULL; db = db->db_hash_next) { in dbuf_stats_hash_table_data()
151 mutex_enter(&db->db_mtx); in dbuf_stats_hash_table_data()
[all …]
H A Ddmu.c169 if (db == NULL) { in dmu_buf_hold_noread_by_dnode()
174 *dbp = &db->db; in dmu_buf_hold_noread_by_dnode()
195 if (db == NULL) { in dmu_buf_hold_noread()
200 *dbp = &db->db; in dmu_buf_hold_noread()
383 *dbp = &db->db; in dmu_bonus_hold_by_dnode()
432 *dbp = &db->db; in dmu_spill_hold_by_dnode()
552 dbp[i] = &db->db; in dmu_buf_hold_array_by_dnode()
579 cv_wait(&db->db_changed, &db->db_mtx); in dmu_buf_hold_array_by_dnode()
1147 dmu_buf_t *db; in dmu_write_embedded() local
1454 if (offset == db->db.db_offset && blksz == db->db.db_size) { in dmu_assign_arcbuf_by_dnode()
[all …]
H A Dbptree.c63 dmu_buf_t *db; in bptree_alloc() local
76 bt = db->db_data; in bptree_alloc()
82 dmu_buf_rele(db, FTAG); in bptree_alloc()
90 dmu_buf_t *db; in bptree_free() local
94 bt = db->db_data; in bptree_free()
99 dmu_buf_rele(db, FTAG); in bptree_free()
107 dmu_buf_t *db; in bptree_is_empty() local
112 bt = db->db_data; in bptree_is_empty()
122 dmu_buf_t *db; in bptree_add() local
134 bt = db->db_data; in bptree_add()
[all …]
H A Ddnode.c1367 epb = db->db.db_size >> DNODE_SHIFT; in dnode_hold_impl()
1373 dnc = dmu_buf_get_user(&db->db); in dnode_hold_impl()
1765 db = AVL_NEXT(&dn->dn_dbufs, db)) { in dnode_set_blksz()
1943 dmu_buf_will_dirty(&db->db, tx); in dnode_dirty_l1()
1973 if (db == NULL || db->db_level != 1 || in dnode_dirty_l1range()
2007 for (; db != NULL; db = AVL_NEXT(&dn->dn_dbufs, db)) { in dnode_dirty_l1range()
2115 dmu_buf_will_dirty(&db->db, tx); in dnode_free_range()
2116 data = db->db.db_data; in dnode_free_range()
2158 dmu_buf_will_dirty(&db->db, tx); in dnode_free_range()
2159 bzero(db->db.db_data, tail); in dnode_free_range()
[all …]
H A Dspace_map.c101 dmu_buf_t *db; in space_map_iterate() local
188 dmu_buf_rele(db, FTAG); in space_map_iterate()
206 dmu_buf_t *db; in space_map_reversed_last_block_entries() local
264 dmu_buf_rele(db, FTAG); in space_map_reversed_last_block_entries()
565 dmu_buf_t *db = *dbp; in space_map_write_seg() local
592 dmu_buf_rele(db, tag); in space_map_write_seg()
601 *dbp = db; in space_map_write_seg()
605 block_base = db->db_data; in space_map_write_seg()
673 dmu_buf_t *db; in space_map_write_impl() local
698 dmu_buf_will_dirty(db, tx); in space_map_write_impl()
[all …]
/f-stack/freebsd/contrib/openzfs/include/os/linux/zfs/sys/
H A Dtrace_dbuf.h62 if (db != NULL) { \
69 __entry->db_object = db->db.db_object; \
70 __entry->db_level = db->db_level; \
72 __entry->db_offset = db->db.db_offset; \
73 __entry->db_size = db->db.db_size; \
105 TP_ARGS(db, zio),
113 TP_ARGS(db, why),
124 TP_ARGS(db, zio))
132 TP_ARGS(db, why))
139 TP_ARGS(db, mls),
[all …]
/f-stack/dpdk/drivers/net/nfp/nfpcore/
H A Dnfp_hwinfo.c60 size = db->size; in nfp_hwinfo_db_validate()
86 uint8_t *db; in nfp_hwinfo_try_fetch() local
103 if (!db) in nfp_hwinfo_try_fetch()
110 header = (void *)db; in nfp_hwinfo_try_fetch()
124 return (void *)db; in nfp_hwinfo_try_fetch()
126 free(db); in nfp_hwinfo_try_fetch()
143 if (db) in nfp_hwinfo_fetch()
144 return db; in nfp_hwinfo_fetch()
162 if (!db) in nfp_hwinfo_read()
167 free(db); in nfp_hwinfo_read()
[all …]
/f-stack/app/redis-5.0.5/src/
H A Dexpire.c62 dbAsyncDelete(db,keyobj); in activeExpireCycleTryExpire()
64 dbSyncDelete(db,keyobj); in activeExpireCycleTryExpire()
66 "expired",keyobj,db->id); in activeExpireCycleTryExpire()
151 redisDb *db = server.db+(current_db % server.dbnum); in activeExpireCycle() local
168 db->avg_ttl = 0; in activeExpireCycle()
212 if (db->avg_ttl == 0) db->avg_ttl = avg_ttl; in activeExpireCycle()
213 db->avg_ttl = (db->avg_ttl/50)*49 + (avg_ttl/50); in activeExpireCycle()
302 redisDb *db = server.db+dbid; in expireSlaveKeys() local
356 if (db->id > 63) return; in rememberSlaveKeyWithExpire()
369 dbids |= (uint64_t)1 << db->id; in rememberSlaveKeyWithExpire()
[all …]
H A Ddb.c153 expireIfNeeded(db,key); in lookupKeyWrite()
218 dbAdd(db,key,val); in setKey()
223 removeExpire(db,key); in setKey()
238 int allvolatile = dictSize(db->dict) == dictSize(db->expires); in dbRandomKey()
274 if (dictSize(db->expires) > 0) dictDelete(db->expires,key->ptr); in dbSyncDelete()
382 c->db = &server.db[id]; in selectDb()
683 ht = c->db->dict; in scanGenericCommand()
931 src = c->db; in moveCommand()
932 srcid = c->db->id; in moveCommand()
941 dst = c->db; in moveCommand()
[all …]
H A Dt_string.c86 setKey(c->db,key,val); in setGenericCommand()
91 "expire",key,c->db->id); in setGenericCommand()
179 setKey(c->db,c->argv[1],c->argv[2]); in getsetCommand()
197 o = lookupKeyWrite(c->db,c->argv[1]); in setrangeCommand()
210 dbAdd(c->db,c->argv[1],o); in setrangeCommand()
343 o = lookupKeyWrite(c->db,c->argv[1]); in incrDecrCommand()
366 dbAdd(c->db,c->argv[1],new); in incrDecrCommand()
369 signalModifiedKey(c->db,c->argv[1]); in incrDecrCommand()
418 dbAdd(c->db,c->argv[1],new); in incrbyfloatCommand()
419 signalModifiedKey(c->db,c->argv[1]); in incrbyfloatCommand()
[all …]
H A Dlazyfree.c54 int dbAsyncDelete(redisDb *db, robj *key) { in dbAsyncDelete() argument
57 if (dictSize(db->expires) > 0) dictDelete(db->expires,key->ptr); in dbAsyncDelete()
62 dictEntry *de = dictUnlink(db->dict,key->ptr); in dbAsyncDelete()
78 dictSetVal(db->dict,de,NULL); in dbAsyncDelete()
85 dictFreeUnlinkedEntry(db->dict,de); in dbAsyncDelete()
107 void emptyDbAsync(redisDb *db) { in emptyDbAsync() argument
108 dict *oldht1 = db->dict, *oldht2 = db->expires; in emptyDbAsync()
109 db->dict = dictCreate(&dbDictType,NULL); in emptyDbAsync()
110 db->expires = dictCreate(&keyptrDictType,NULL); in emptyDbAsync()
H A Dt_list.c211 dbAdd(c->db,c->argv[1],lobj); in pushGenericCommand()
220 signalModifiedKey(c->db,c->argv[1]); in pushGenericCommand()
383 dbDelete(c->db,c->argv[1]); in popGenericCommand()
482 dbDelete(c->db,c->argv[1]); in ltrimCommand()
485 signalModifiedKey(c->db,c->argv[1]); in ltrimCommand()
527 dbDelete(c->db,c->argv[1]); in lremCommand()
556 dbAdd(c->db,dstkey,dstobj); in rpoplpushHandlePush()
558 signalModifiedKey(c->db,dstkey); in rpoplpushHandlePush()
592 dbDelete(c->db,touchedkey); in rpoplpushCommand()
660 db->id,argv,2, in serveClientBlockedOnList()
[all …]
H A Dt_set.c271 dbAdd(c->db,c->argv[1],set); in saddCommand()
351 dbDelete(c->db,c->argv[1]); in smoveCommand()
358 dbAdd(c->db,c->argv[2],dstset); in smoveCommand()
361 signalModifiedKey(c->db,c->argv[1]); in smoveCommand()
362 signalModifiedKey(c->db,c->argv[2]); in smoveCommand()
442 dbDelete(c->db,c->argv[1]); in spopWithCountCommand()
597 dbDelete(c->db,c->argv[1]); in spopCommand()
903 dstkey,c->db->id); in sinterGenericCommand()
909 dstkey,c->db->id); in sinterGenericCommand()
1077 dstkey,c->db->id); in sunionDiffGenericCommand()
[all …]
H A Dblocked.c263 dictDelete(rl->db->ready_keys,rl->key); in handleClientsBlockedOnKeys()
266 robj *o = lookupKeyWrite(rl->db,rl->key); in handleClientsBlockedOnKeys()
320 dbDelete(rl->db,rl->key); in handleClientsBlockedOnKeys()
366 propagate(cmd,receiver->db->id, in handleClientsBlockedOnKeys()
524 de = dictFind(c->db->blocking_keys,keys[j]); in blockForKeys()
555 l = dictFetchValue(c->db->blocking_keys,key); in unblockClientWaitingData()
560 dictDelete(c->db->blocking_keys,key); in unblockClientWaitingData()
585 void signalKeyAsReady(redisDb *db, robj *key) { in signalKeyAsReady() argument
589 if (dictFind(db->blocking_keys,key) == NULL) return; in signalKeyAsReady()
592 if (dictFind(db->ready_keys,key) != NULL) return; in signalKeyAsReady()
[all …]
H A Devict.c474 redisDb *db; in freeMemoryIfNeeded() local
490 db = server.db+i; in freeMemoryIfNeeded()
492 db->dict : db->expires; in freeMemoryIfNeeded()
506 de = dictFind(server.db[pool[k].dbid].dict, in freeMemoryIfNeeded()
540 db = server.db+j; in freeMemoryIfNeeded()
542 db->dict : db->expires; in freeMemoryIfNeeded()
554 db = server.db+bestdbid; in freeMemoryIfNeeded()
556 propagateExpire(db,keyobj,server.lazyfree_lazy_eviction); in freeMemoryIfNeeded()
568 dbAsyncDelete(db,keyobj); in freeMemoryIfNeeded()
570 dbSyncDelete(db,keyobj); in freeMemoryIfNeeded()
[all …]
H A Dmulti.c111 propagate(server.multiCommand,c->db->id,&multistring,1, in execCommandPropagateMulti()
230 redisDb *db; member
244 if (wk->db == c->db && equalStringObjects(key,wk->key)) in watchForKey()
248 clients = dictFetchValue(c->db->watched_keys,key); in watchForKey()
251 dictAdd(c->db->watched_keys,key,clients); in watchForKey()
258 wk->db = c->db; in watchForKey()
283 dictDelete(wk->db->watched_keys, wk->key); in unwatchAllKeys()
293 void touchWatchedKey(redisDb *db, robj *key) { in touchWatchedKey() argument
298 if (dictSize(db->watched_keys) == 0) return; in touchWatchedKey()
299 clients = dictFetchValue(db->watched_keys, key); in touchWatchedKey()
[all …]
/f-stack/freebsd/contrib/openzfs/include/sys/
H A Ddbuf.h205 dmu_buf_t db; member
359 uint64_t dbuf_refcount(dmu_buf_impl_t *db);
384 void dbuf_destroy(dmu_buf_impl_t *db);
388 void dbuf_release_bp(dmu_buf_impl_t *db);
419 for (dr = list_head(&db->db_dirty_records); in dbuf_find_dirty_lte()
431 dr = dbuf_find_dirty_lte(db, txg); in dbuf_find_dirty_eq()
466 uint64_t __db_obj = (dbuf)->db.db_object; \
488 #define DBUF_VERIFY(db) dbuf_verify(db) argument
492 #define dprintf_dbuf(db, fmt, ...) argument
493 #define dprintf_dbuf_bp(db, bp, fmt, ...) argument
[all …]
/f-stack/dpdk/drivers/net/bnxt/tf_core/
H A Dtf_shadow_identifier.c40 struct tf_shadow_ident_element *db; member
50 struct tf_shadow_ident_element *db; in tf_shadow_ident_create_db() local
72 db = shadow_db->db; in tf_shadow_ident_create_db()
91 db[i].ref_count = (uint32_t *)cparms.mem_va; in tf_shadow_ident_create_db()
98 tfp_free((void *)db->ref_count); in tf_shadow_ident_create_db()
99 tfp_free((void *)db); in tf_shadow_ident_create_db()
116 tfp_free((void *)shadow_db->db[i].ref_count); in tf_shadow_ident_free_db()
118 tfp_free((void *)shadow_db->db); in tf_shadow_ident_free_db()
137 shadow_db->db[parms->type].ref_count[parms->search_id] = in tf_shadow_ident_search()
160 shadow_db->db[parms->type].ref_count[parms->id]++; in tf_shadow_ident_insert()
[all …]
H A Dtf_rm.c74 struct tf_rm_element *db; member
524 db = rm_db->db; in tf_rm_create_db()
585 db[i].cfg_type); in tf_rm_create_db()
615 tfp_free((void *)db); in tf_rm_create_db()
709 if (!rm_db->db) in tf_rm_allocate()
777 if (!rm_db->db) in tf_rm_free()
824 if (!rm_db->db) in tf_rm_is_allocated()
869 if (!rm_db->db) in tf_rm_get_info()
894 if (!rm_db->db) in tf_rm_get_hcapi_type()
918 if (!rm_db->db) in tf_rm_get_inuse_count()
[all …]
/f-stack/freebsd/contrib/openzfs/module/os/freebsd/zfs/
H A Ddmu_os.c120 dmu_buf_t *db = dbp[i]; in dmu_write_pages() local
131 if (tocpy == db->db_size) in dmu_write_pages()
132 dmu_buf_will_fill(db, tx); in dmu_write_pages()
134 dmu_buf_will_dirty(db, tx); in dmu_write_pages()
138 db->db_offset + bufoff); in dmu_write_pages()
147 if (tocpy == db->db_size) in dmu_write_pages()
148 dmu_buf_fill_done(db, tx); in dmu_write_pages()
165 dmu_buf_t *db; in dmu_read_pages() local
194 db = dbp[0]; in dmu_read_pages()
238 db = dbp[di]; in dmu_read_pages()
[all …]
/f-stack/dpdk/app/test/
H A Dtest_distributor.c138 rte_distributor_flush(db); in sanity_test()
166 rte_distributor_flush(db); in sanity_test()
195 rte_distributor_flush(db); in sanity_test()
222 rte_distributor_flush(db); in sanity_test()
234 rte_distributor_process(db, in sanity_test()
241 rte_distributor_flush(db); in sanity_test()
248 rte_distributor_flush(db); in sanity_test()
661 rte_distributor_flush(db); in sanity_mark_test()
835 if (db == NULL) { in test_distributor()
839 if (db == NULL) { in test_distributor()
[all …]
H A Dtest_distributor_perf.c207 static struct rte_distributor *db; in test_distributor_perf() local
230 if (db == NULL) { in test_distributor_perf()
231 db = rte_distributor_create("Test_burst", rte_socket_id(), in test_distributor_perf()
234 if (db == NULL) { in test_distributor_perf()
239 rte_distributor_clear_returns(db); in test_distributor_perf()
260 rte_eal_mp_remote_launch(handle_work, db, SKIP_MAIN); in test_distributor_perf()
261 if (perf_test(db, p) < 0) in test_distributor_perf()
263 quit_workers(db, p); in test_distributor_perf()
/f-stack/dpdk/drivers/net/bnxt/
H A Dbnxt_ring.h83 static inline void bnxt_db_write(struct bnxt_db_info *db, uint32_t idx) in bnxt_db_write() argument
85 if (db->db_64) in bnxt_db_write()
86 rte_write64(db->db_key64 | idx, db->doorbell); in bnxt_db_write()
88 rte_write32(db->db_key32 | idx, db->doorbell); in bnxt_db_write()
115 struct bnxt_db_info *db = &cpr->cp_db; in bnxt_db_cq() local
118 if (db->db_64) { in bnxt_db_cq()
119 uint64_t key_idx = db->db_key64 | idx; in bnxt_db_cq()
120 void *doorbell = db->doorbell; in bnxt_db_cq()

123456