MCPcopy Create free account

hub / github.com/KuiBaDB/KuiBaDB / functions

Functions599 in github.com/KuiBaDB/KuiBaDB

↓ 3 callersMethodp2r
(&self, slot: *const Slot<V, E>)
src/utils/sb.rs:172
↓ 3 callersFunctionpersist
Path::new(file).parent().unwrap() must not be empty.
src/utils.rs:287
↓ 3 callersFunctionread_level_files
( cursor: &mut Cursor<&[u8]>, mut on_file: impl FnMut(u32, u64, u32) -> T, )
src/access/sv.rs:205
↓ 3 callersMethodreserve_datums
(&mut self, ndatum: usize, typlen: usize, typalign: usize)
src/datums.rs:168
↓ 3 callersFunctionser_be_i32
(out: &mut Vec<u8>, val: i32)
src/utils/ser.rs:77
↓ 3 callersMethodset_single_null
(&mut self)
src/datums.rs:109
↓ 3 callersFunctionsync
()
src/bin/initdb/main.rs:25
↓ 3 callersMethodunref
Arc::drop
src/utils/marc.rs:69
↓ 3 callersFunctionwrite_level_files
( files: &Vec<T>, out: &mut Vec<u8>, on_file: impl Fn(&T) -> (u32, u64, u32), )
src/access/sv.rs:298
↓ 2 callersMethodabortio
(&self)
src/utils/sb.rs:488
↓ 2 callersMethodadvance
(&mut self)
src/executor.rs:45
↓ 2 callersFunctionalloc_from
(output: &mut Vec<FileMeta>, num: usize, input: &[L0File])
src/access/sv.rs:404
↓ 2 callersMethodas_bytes_from
(&self, s: isize)
src/access/csmvcc.rs:56
↓ 2 callersMethodas_mut_bytes
(&mut self)
src/access/csmvcc.rs:84
↓ 2 callersFunctionas_varchar
(v: &[u8])
src/datums.rs:64
↓ 2 callersMethodblob_at
(&self, idx: isize)
src/datums.rs:261
↓ 2 callersMethodcal_crc32c
(&self)
src/access/wal.rs:112
↓ 2 callersMethodcalc_crc32c
(&self)
src/access/csmvcc.rs:62
↓ 2 callersFunctionchar_has_case
(c: char)
build.rs:104
↓ 2 callersMethodcheck_termreq
(&self)
src/utils.rs:238
↓ 2 callersMethodclone
(&self)
src/utils/marc.rs:114
↓ 2 callersMethodcommit_tran_cmd
(&mut self)
src/access/xact.rs:524
↓ 2 callersFunctioncond_get_type
(state: &SessionState, cond: &str)
src/catalog.rs:219
↓ 2 callersFunctionconflict_modes
(mode: LockMode)
src/access/lmgr.rs:105
↓ 2 callersMethodcreate_slot
(&self, dat: &mut (Map<V, E>, E), k: &V::K)
src/utils/sb.rs:142
↓ 2 callersMethoddata_as_bytes
(&self)
src/access/csmvcc.rs:93
↓ 2 callersMethoddatums_as_bytes
(&self, from: isize, len: usize)
src/datums.rs:206
↓ 2 callersMethoddatums_at
(&self, idx: isize)
src/datums.rs:193
↓ 2 callersMethoddo_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 callersFunctiondo_resize_fdcache
(gucstate: &GucState)
src/access/fd.rs:71
↓ 2 callersMethoddo_unref
(&mut self, ctx: &T::DestoryCtx)
src/utils/marc.rs:54
↓ 2 callersMethoddone
(&self, start: u64, end: u64)
src/access/wal.rs:529
↓ 2 callersFunctionend_xid
(sess: &mut SessionState)
src/access/xact.rs:391
↓ 2 callersFunctionexec_init_expr
( node: &sem::Expr, state: &WorkerState, initctx: &mut ExprInitCtx, )
src/executor.rs:194
↓ 2 callersMethodexit
(&self)
src/utils.rs:83
↓ 2 callersMethodfind
(&self, lsn: Lsn)
src/access/wal.rs:322
↓ 2 callersMethodfind_l0
(&self, fileid: FileId)
src/access/sv.rs:141
↓ 2 callersMethodflush
(&mut self)
src/access/cs.rs:82
↓ 2 callersFunctionfree_static
(v: &'static T)
src/lib.rs:479
↓ 2 callersMethodfsync
(&self, end_lsn: u64)
src/access/wal.rs:623
↓ 2 callersMethodget_blob_at
(&self, s: usize, e: usize)
src/datums.rs:276
↓ 2 callersFunctionget_ckpt
(recdata: &[u8])
src/access/wal.rs:84
↓ 2 callersMethodget_dirty_keys
(&self)
src/utils/sb.rs:114
↓ 2 callersFunctionget_fn_addr
(oid: Oid, map: &FmgrBuiltinsMap)
src/utils/fmgr.rs:55
↓ 2 callersFunctionget_guc_generic
(idx: GucIdx)
src/guc.rs:104
↓ 2 callersMethodget_mut_unchecked
(&mut self)
src/utils/marc.rs:50
↓ 2 callersFunctionget_oid
(d: &[u8])
src/access/wal.rs:1089
↓ 2 callersFunctionget_opers
( state: &SessionState, oprname: &str, oprleft: OptOid, oprright: Oid, )
src/catalog.rs:95
↓ 2 callersFunctionget_rel_locktag
SetLocktagRelationOid
src/access/lmgr.rs:347
↓ 2 callersFunctionget_str
(gucvals: &GucState, guckey: gucdef::S)
src/guc.rs:250
↓ 2 callersFunctionget_type
(state: &SessionState, oid: Oid)
src/catalog.rs:243
↓ 2 callersMethodget_varchar_at
(&self, idx: isize)
src/datums.rs:299
↓ 2 callersFunctionget_xact_rec
(d: &[u8])
src/access/xact.rs:307
↓ 2 callersMethodget_xid
(&mut self)
src/access/xact.rs:686
↓ 2 callersFunctionglobal_cleanup
(lmgrg: &GlobalStateExt, tag: &LockTag)
src/access/lmgr.rs:312
↓ 2 callersMethodhandle_insert_ret
(&self, ret: InsertRet)
src/access/wal.rs:946
↓ 2 callersMethodhas_done
activity on all offset less than has_done() has been done
src/lib.rs:127
↓ 2 callersFunctionhdr_crc_area
(rec: &[u8])
src/access/wal.rs:694
↓ 2 callersFunctioninit_log
()
src/lib.rs:59
↓ 2 callersMethodinsert_record
(&mut self, id: RmgrId, info: u8, mut rec: Vec<u8>)
src/access/xact.rs:664
↓ 2 callersMethodinternal_session
(self, sessid: u32)
src/lib.rs:577
↓ 2 callersFunctionio_in_progress
(state: u32)
src/utils/sb.rs:276
↓ 2 callersFunctionis_transblock
IsTransactionBlock
src/access/xact.rs:466
↓ 2 callersFunctionis_wal
(filename: &[u8])
src/access/wal.rs:560
↓ 2 callersFunctionload_yaml
(filepath: &str)
common.rs:16
↓ 2 callersMethodlock_acquire
(&mut self, tag: &LockTag, mode: LockMode)
src/access/lmgr.rs:359
↓ 2 callersMethodlock_release_all
(&mut self)
src/access/lmgr.rs:408
↓ 2 callersFunctionlockbit_off
(l: LockMode)
src/access/lmgr.rs:52
↓ 2 callersFunctionlog_xact_rec
(sess: &mut SessionState, xact_endts: KBSystemTime, info: XactInfo)
src/access/xact.rs:349
↓ 2 callersMethodlsn
(&self)
src/access/csmvcc.rs:103
↓ 2 callersFunctionlsn2u64
(v: Option<Lsn>)
src/access/xact.rs:250
↓ 2 callersMethodmake_mut
(&mut self, ctx: &T::DestoryCtx)
src/utils/marc.rs:77
↓ 2 callersFunctionmake_op
( pstate: &mut ParseState, opname: &Vec<syn::StrVal>, ltree: Option<Expr>, rtree: Expr, lo
src/parser/sem.rs:221
↓ 2 callersFunctionnew_indatums
(attcnt: usize, batch_size: u32)
src/commands/copy.rs:50
↓ 2 callersMethodnew_session
( self, dbname: &str, sessid: u32, termreq: Arc<AtomicBool>, )
src/lib.rs:552
↓ 2 callersFunctionoid_in_used
(sess: &SessionState, oid: Oid, catalog: &str)
src/catalog/namespace.rs:71
↓ 2 callersFunctionon_error
(level: &str, err: &anyhow::Error, writer: &mut SockWriter)
src/lib.rs:277
↓ 2 callersMethodopername_get_oprid
( &mut self, names: &Vec<syn::StrVal>, oprleft: OptOid, oprright: Oid, )
src/catalog/namespace.rs:162
↓ 2 callersMethodp2r
(&self, l: *const LockState)
src/access/lmgr.rs:186
↓ 2 callersFunctionparse_wal_filename
(filename: &[u8])
src/access/wal.rs:576
↓ 2 callersMethodpersist
(&self)
src/access/wal.rs:121
↓ 2 callersMethodpin
(&self, l: &LockState, mode: LockMode)
src/access/lmgr.rs:190
↓ 2 callersMethodpin_slot
(&self, v: &Slot<V, E>)
src/utils/sb.rs:93
↓ 2 callersMethodpool
(&self)
src/utils.rs:190
↓ 2 callersMethodpread
(&self, buf: &mut [u8], offset: u64)
src/access/wal.rs:257
↓ 2 callersFunctionpwritevn
( fd: RawFd, iov: &'a mut [IoVec<&'a [u8]>], mut offset: off_t, )
src/utils.rs:430
↓ 2 callersFunctionqualname_get_type
( state: &SessionState, nsoid: Oid, typname: &str, )
src/catalog.rs:257
↓ 2 callersFunctionrc
(state: u32)
src/utils/sb.rs:268
↓ 2 callersFunctionread_body
(stream: &mut SockReader, content: &mut Vec<u8>)
src/protocol.rs:27
↓ 2 callersFunctionread_cstr
(cursor: &mut Cursor<&'a [u8]>)
src/protocol.rs:113
↓ 2 callersFunctionread_startup_message
(stream: &mut SockReader, content: &mut Vec<u8>)
src/protocol.rs:41
↓ 2 callersFunctionrealloc
(ptr: NonNull<u8>, align: usize, mut osize: usize, mut nsize: usize)
src/utils.rs:390
↓ 2 callersMethodredo
(&mut self, hdr: &RecordHdr, data: &[u8], state: &mut RedoState)
src/access/wal.rs:1098
↓ 2 callersFunctionrelname_get_relid
get_relname_relid
src/catalog.rs:292
↓ 2 callersMethodreq
(&mut self, mode: LockMode)
src/access/lmgr.rs:132
↓ 2 callersMethodreserve_blob
(&mut self, ncap: usize)
src/datums.rs:248
↓ 2 callersMethodresize_clog_l1cache
(&self)
src/access/clog.rs:165
↓ 2 callersMethodresize_fdcache
(&self)
src/access/fd.rs:85
↓ 2 callersFunctionresize_l1cache
(gucstate: &GucState)
src/access/clog.rs:57
↓ 2 callersMethodresize_varlen
(&mut self, ndatum: u32)
src/datums.rs:225
← previousnext →101–200 of 599, ranked by callers