Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/KuiBaDB/KuiBaDB
/ functions
Functions
599 in github.com/KuiBaDB/KuiBaDB
⨍
Functions
599
◇
Types & classes
209
↓ 3 callers
Method
p2r
(&self, slot: *const Slot<V, E>)
src/utils/sb.rs:172
↓ 3 callers
Function
persist
Path::new(file).parent().unwrap() must not be empty.
src/utils.rs:287
↓ 3 callers
Function
read_level_files
( cursor: &mut Cursor<&[u8]>, mut on_file: impl FnMut(u32, u64, u32) -> T, )
src/access/sv.rs:205
↓ 3 callers
Method
reserve_datums
(&mut self, ndatum: usize, typlen: usize, typalign: usize)
src/datums.rs:168
↓ 3 callers
Function
ser_be_i32
(out: &mut Vec<u8>, val: i32)
src/utils/ser.rs:77
↓ 3 callers
Method
set_single_null
(&mut self)
src/datums.rs:109
↓ 3 callers
Function
sync
()
src/bin/initdb/main.rs:25
↓ 3 callers
Method
unref
Arc::drop
src/utils/marc.rs:69
↓ 3 callers
Function
write_level_files
( files: &Vec<T>, out: &mut Vec<u8>, on_file: impl Fn(&T) -> (u32, u64, u32), )
src/access/sv.rs:298
↓ 2 callers
Method
abortio
(&self)
src/utils/sb.rs:488
↓ 2 callers
Method
advance
(&mut self)
src/executor.rs:45
↓ 2 callers
Function
alloc_from
(output: &mut Vec<FileMeta>, num: usize, input: &[L0File])
src/access/sv.rs:404
↓ 2 callers
Method
as_bytes_from
(&self, s: isize)
src/access/csmvcc.rs:56
↓ 2 callers
Method
as_mut_bytes
(&mut self)
src/access/csmvcc.rs:84
↓ 2 callers
Function
as_varchar
(v: &[u8])
src/datums.rs:64
↓ 2 callers
Method
blob_at
(&self, idx: isize)
src/datums.rs:261
↓ 2 callers
Method
cal_crc32c
(&self)
src/access/wal.rs:112
↓ 2 callers
Method
calc_crc32c
(&self)
src/access/csmvcc.rs:62
↓ 2 callers
Function
char_has_case
(c: char)
build.rs:104
↓ 2 callers
Method
check_termreq
(&self)
src/utils.rs:238
↓ 2 callers
Method
clone
(&self)
src/utils/marc.rs:114
↓ 2 callers
Method
commit_tran_cmd
(&mut self)
src/access/xact.rs:524
↓ 2 callers
Function
cond_get_type
(state: &SessionState, cond: &str)
src/catalog.rs:219
↓ 2 callers
Function
conflict_modes
(mode: LockMode)
src/access/lmgr.rs:105
↓ 2 callers
Method
create_slot
(&self, dat: &mut (Map<V, E>, E), k: &V::K)
src/utils/sb.rs:142
↓ 2 callers
Method
data_as_bytes
(&self)
src/access/csmvcc.rs:93
↓ 2 callers
Method
datums_as_bytes
(&self, from: isize, len: usize)
src/datums.rs:206
↓ 2 callers
Method
datums_at
(&self, idx: isize)
src/datums.rs:193
↓ 2 callers
Method
do_flush
FlushBuffer, flush current slot, we have the read lock on self.v, and v is always self.v. If do_flush() returns Err, everything is unchanged except SL
src/utils/sb.rs:409
↓ 2 callers
Function
do_resize_fdcache
(gucstate: &GucState)
src/access/fd.rs:71
↓ 2 callers
Method
do_unref
(&mut self, ctx: &T::DestoryCtx)
src/utils/marc.rs:54
↓ 2 callers
Method
done
(&self, start: u64, end: u64)
src/access/wal.rs:529
↓ 2 callers
Function
end_xid
(sess: &mut SessionState)
src/access/xact.rs:391
↓ 2 callers
Function
exec_init_expr
( node: &sem::Expr, state: &WorkerState, initctx: &mut ExprInitCtx, )
src/executor.rs:194
↓ 2 callers
Method
exit
(&self)
src/utils.rs:83
↓ 2 callers
Method
find
(&self, lsn: Lsn)
src/access/wal.rs:322
↓ 2 callers
Method
find_l0
(&self, fileid: FileId)
src/access/sv.rs:141
↓ 2 callers
Method
flush
(&mut self)
src/access/cs.rs:82
↓ 2 callers
Function
free_static
(v: &'static T)
src/lib.rs:479
↓ 2 callers
Method
fsync
(&self, end_lsn: u64)
src/access/wal.rs:623
↓ 2 callers
Method
get_blob_at
(&self, s: usize, e: usize)
src/datums.rs:276
↓ 2 callers
Function
get_ckpt
(recdata: &[u8])
src/access/wal.rs:84
↓ 2 callers
Method
get_dirty_keys
(&self)
src/utils/sb.rs:114
↓ 2 callers
Function
get_fn_addr
(oid: Oid, map: &FmgrBuiltinsMap)
src/utils/fmgr.rs:55
↓ 2 callers
Function
get_guc_generic
(idx: GucIdx)
src/guc.rs:104
↓ 2 callers
Method
get_mut_unchecked
(&mut self)
src/utils/marc.rs:50
↓ 2 callers
Function
get_oid
(d: &[u8])
src/access/wal.rs:1089
↓ 2 callers
Function
get_opers
( state: &SessionState, oprname: &str, oprleft: OptOid, oprright: Oid, )
src/catalog.rs:95
↓ 2 callers
Function
get_rel_locktag
SetLocktagRelationOid
src/access/lmgr.rs:347
↓ 2 callers
Function
get_str
(gucvals: &GucState, guckey: gucdef::S)
src/guc.rs:250
↓ 2 callers
Function
get_type
(state: &SessionState, oid: Oid)
src/catalog.rs:243
↓ 2 callers
Method
get_varchar_at
(&self, idx: isize)
src/datums.rs:299
↓ 2 callers
Function
get_xact_rec
(d: &[u8])
src/access/xact.rs:307
↓ 2 callers
Method
get_xid
(&mut self)
src/access/xact.rs:686
↓ 2 callers
Function
global_cleanup
(lmgrg: &GlobalStateExt, tag: &LockTag)
src/access/lmgr.rs:312
↓ 2 callers
Method
handle_insert_ret
(&self, ret: InsertRet)
src/access/wal.rs:946
↓ 2 callers
Method
has_done
activity on all offset less than has_done() has been done
src/lib.rs:127
↓ 2 callers
Function
hdr_crc_area
(rec: &[u8])
src/access/wal.rs:694
↓ 2 callers
Function
init_log
()
src/lib.rs:59
↓ 2 callers
Method
insert_record
(&mut self, id: RmgrId, info: u8, mut rec: Vec<u8>)
src/access/xact.rs:664
↓ 2 callers
Method
internal_session
(self, sessid: u32)
src/lib.rs:577
↓ 2 callers
Function
io_in_progress
(state: u32)
src/utils/sb.rs:276
↓ 2 callers
Function
is_transblock
IsTransactionBlock
src/access/xact.rs:466
↓ 2 callers
Function
is_wal
(filename: &[u8])
src/access/wal.rs:560
↓ 2 callers
Function
load_yaml
(filepath: &str)
common.rs:16
↓ 2 callers
Method
lock_acquire
(&mut self, tag: &LockTag, mode: LockMode)
src/access/lmgr.rs:359
↓ 2 callers
Method
lock_release_all
(&mut self)
src/access/lmgr.rs:408
↓ 2 callers
Function
lockbit_off
(l: LockMode)
src/access/lmgr.rs:52
↓ 2 callers
Function
log_xact_rec
(sess: &mut SessionState, xact_endts: KBSystemTime, info: XactInfo)
src/access/xact.rs:349
↓ 2 callers
Method
lsn
(&self)
src/access/csmvcc.rs:103
↓ 2 callers
Function
lsn2u64
(v: Option<Lsn>)
src/access/xact.rs:250
↓ 2 callers
Method
make_mut
(&mut self, ctx: &T::DestoryCtx)
src/utils/marc.rs:77
↓ 2 callers
Function
make_op
( pstate: &mut ParseState, opname: &Vec<syn::StrVal>, ltree: Option<Expr>, rtree: Expr, lo
src/parser/sem.rs:221
↓ 2 callers
Function
new_indatums
(attcnt: usize, batch_size: u32)
src/commands/copy.rs:50
↓ 2 callers
Method
new_session
( self, dbname: &str, sessid: u32, termreq: Arc<AtomicBool>, )
src/lib.rs:552
↓ 2 callers
Function
oid_in_used
(sess: &SessionState, oid: Oid, catalog: &str)
src/catalog/namespace.rs:71
↓ 2 callers
Function
on_error
(level: &str, err: &anyhow::Error, writer: &mut SockWriter)
src/lib.rs:277
↓ 2 callers
Method
opername_get_oprid
( &mut self, names: &Vec<syn::StrVal>, oprleft: OptOid, oprright: Oid, )
src/catalog/namespace.rs:162
↓ 2 callers
Method
p2r
(&self, l: *const LockState)
src/access/lmgr.rs:186
↓ 2 callers
Function
parse_wal_filename
(filename: &[u8])
src/access/wal.rs:576
↓ 2 callers
Method
persist
(&self)
src/access/wal.rs:121
↓ 2 callers
Method
pin
(&self, l: &LockState, mode: LockMode)
src/access/lmgr.rs:190
↓ 2 callers
Method
pin_slot
(&self, v: &Slot<V, E>)
src/utils/sb.rs:93
↓ 2 callers
Method
pool
(&self)
src/utils.rs:190
↓ 2 callers
Method
pread
(&self, buf: &mut [u8], offset: u64)
src/access/wal.rs:257
↓ 2 callers
Function
pwritevn
( fd: RawFd, iov: &'a mut [IoVec<&'a [u8]>], mut offset: off_t, )
src/utils.rs:430
↓ 2 callers
Function
qualname_get_type
( state: &SessionState, nsoid: Oid, typname: &str, )
src/catalog.rs:257
↓ 2 callers
Function
rc
(state: u32)
src/utils/sb.rs:268
↓ 2 callers
Function
read_body
(stream: &mut SockReader, content: &mut Vec<u8>)
src/protocol.rs:27
↓ 2 callers
Function
read_cstr
(cursor: &mut Cursor<&'a [u8]>)
src/protocol.rs:113
↓ 2 callers
Function
read_startup_message
(stream: &mut SockReader, content: &mut Vec<u8>)
src/protocol.rs:41
↓ 2 callers
Function
realloc
(ptr: NonNull<u8>, align: usize, mut osize: usize, mut nsize: usize)
src/utils.rs:390
↓ 2 callers
Method
redo
(&mut self, hdr: &RecordHdr, data: &[u8], state: &mut RedoState)
src/access/wal.rs:1098
↓ 2 callers
Function
relname_get_relid
get_relname_relid
src/catalog.rs:292
↓ 2 callers
Method
req
(&mut self, mode: LockMode)
src/access/lmgr.rs:132
↓ 2 callers
Method
reserve_blob
(&mut self, ncap: usize)
src/datums.rs:248
↓ 2 callers
Method
resize_clog_l1cache
(&self)
src/access/clog.rs:165
↓ 2 callers
Method
resize_fdcache
(&self)
src/access/fd.rs:85
↓ 2 callers
Function
resize_l1cache
(gucstate: &GucState)
src/access/clog.rs:57
↓ 2 callers
Method
resize_varlen
(&mut self, ndatum: u32)
src/datums.rs:225
← previous
next →
101–200 of 599, ranked by callers