Functions — github.com/bytedance/InfiniStore

CodeHub MCPcopy Create free account

hub / github.com/bytedance/InfiniStore / functions

Functions292 in github.com/bytedance/InfiniStore

⨍ Functions 292◇ Types & classes 102↳ Endpoints 3

↓ 21 callersMethodregister_mr

Registers a memory region (MR) for the given argument. Args: arg (Union[int]): The argument for which the memory region

infinistore/lib.py:504

↓ 20 callersMethodclose

Closes the connection to the Infinistore instance.

infinistore/lib.py:352

↓ 18 callersMethodrun

↓ 17 callersMethodconnect

Establishes a connection to the Infinistore instance based on the configuration. Raises: Exception: If already connected

infinistore/lib.py:329

↓ 13 callersMethodrdma_write_cache_async

( self, blocks: List[Tuple[str, int]], block_size: int, ptr: int )

infinistore/lib.py:397

↓ 11 callersMethodrdma_read_cache_async

( self, blocks: List[Tuple[str, int]], block_size: int, ptr: int )

infinistore/lib.py:430

↓ 9 callersMethodFinish

src/local_meta_generated.h:39

↓ 9 callersFunctiongenerate_random_string

infinistore/test_infinistore.py:60

↓ 6 callersFunctionrun

infinistore/test_infinistore.py:183

↓ 5 callersMethodcheck_exist

Check if a given key exists in the store. Args: key (str): The key to check for existence. Returns:

infinistore/lib.py:467

↓ 5 callersMethodconnect_async

Asynchronously establishes a connection based on the configuration. Raises: Exception: If the initialization of the remo

infinistore/lib.py:304

↓ 5 callersMethodtcp_read_cache

Retrieve a single cached item from the TCP connection. Parameters: key (str): The key associated with the cached item.

infinistore/lib.py:358

↓ 5 callersMethodtcp_write_cache

Writes a single cache entry to the remote memory using TCP. Args: key (str): The key of the cache entry to write.

infinistore/lib.py:371

↓ 4 callersFunctionget_ptr

(mv: memoryview)

infinistore/example/client_async_single.py:23

↓ 4 callersMethodinfo

infinistore/lib.py:151

↓ 4 callersFunctionprint_rdma_conn_info

src/utils.cpp:83

↓ 4 callersMethodusage

src/mempool.h:68

↓ 3 callersFunctionCreateRemoteMetaRequest

src/meta_request_generated.h:66

↓ 3 callersFunctionget_ptr

(mv: memoryview)

infinistore/test_infinistore.py:513

↓ 3 callersMethodreset_client_read_state

src/infinistore.cpp:661

↓ 2 callersFunctionCreateDeleteKeysRequest

src/delete_keys_generated.h:43

↓ 2 callersFunctionCreateGetMatchLastIndexRequest

src/get_match_last_index_generated.h:43

↓ 2 callersFunctionCreateTCPPayloadRequestDirect

src/tcp_payload_request_generated.h:61

↓ 2 callersMethodFinish

src/get_match_last_index_generated.h:36

↓ 2 callersMethodFinish

src/delete_keys_generated.h:36

↓ 2 callersMethodFinish

src/tcp_payload_request_generated.h:44

↓ 2 callersMethodFinish

src/allocate_response_generated.h:60

↓ 2 callersMethodFinish

src/meta_request_generated.h:59

↓ 2 callersMethodallocate

src/mempool.cpp:55

↓ 2 callersFunctionblocks

src/local_meta_generated.h:73

↓ 2 callersFunctionevict_cache

src/infinistore.cpp:252

↓ 2 callersMethodget_allocated_blocks

src/mempool.h:37

↓ 2 callersFunctionget_kvmap_len

Returns the length of the key-value map in the infinistore. This function calls the underlying _infinistore.get_kvmap_len() method to ge

infinistore/lib.py:171

↓ 2 callersMethodget_lkey

src/mempool.h:77

↓ 2 callersMethodget_total_blocks

src/mempool.h:36

↓ 2 callersMethodget_wr_type

src/libinfinistore.h:47

↓ 2 callersFunctionibv_find_sgid_type

src/ibv_helper.cpp:102

↓ 2 callersMethodinit_connection

src/libinfinistore.cpp:409

↓ 2 callersFunctionkeys

src/get_match_last_index_generated.h:14

↓ 2 callersFunctionkeys

src/delete_keys_generated.h:14

↓ 2 callersFunctionkeys

src/meta_request_generated.h:20

↓ 2 callersFunctionmain

infinistore/example/client_async.py:24

↓ 2 callersFunctionop_name

src/protocol.cpp:11

↓ 2 callersMethodr_rdma_async

src/libinfinistore.cpp:885

↓ 2 callersMethodr_tcp

src/libinfinistore.cpp:713

↓ 2 callersMethodsend_resp

send_resp send fixed size response to client.

src/infinistore.cpp:939

↓ 2 callersMethodset_log_level

infinistore/lib.py:167

↓ 2 callersMethodsetup_rdma

src/libinfinistore.cpp:371

↓ 2 callersMethodw_rdma_async

src/libinfinistore.cpp:822

↓ 2 callersMethodw_tcp

src/libinfinistore.cpp:769

↓ 2 callersMethodwarn

infinistore/lib.py:163

↓ 1 callersMethodConnection

src/libinfinistore.h:97

↓ 1 callersFunctionCreateBlock

src/local_meta_generated.h:46

↓ 1 callersFunctionCreateLocalMeta

src/local_meta_generated.h:108

↓ 1 callersFunctionCreateRdmaAllocateResponse

src/allocate_response_generated.h:67

↓ 1 callersFunctionCreateTCPPayloadRequest

src/tcp_payload_request_generated.h:51

↓ 1 callersFunctionGetDeleteKeysRequest

src/delete_keys_generated.h:58

↓ 1 callersFunctionGetGetMatchLastIndexRequest

src/get_match_last_index_generated.h:58

↓ 1 callersFunctionGetRemoteMetaRequest

src/meta_request_generated.h:90

↓ 1 callersFunctionGetTCPPayloadRequest

src/tcp_payload_request_generated.h:68

↓ 1 callersFunctionRemoteBlock

src/allocate_response_generated.h:21

↓ 1 callersMethod__init__

(self, **kwargs)

infinistore/lib.py:51

↓ 1 callersMethodadd_block_size

src/local_meta_generated.h:92

↓ 1 callersMethodadd_block_size

src/meta_request_generated.h:48

↓ 1 callersMethodadd_blocks

src/local_meta_generated.h:95

↓ 1 callersMethodadd_blocks

src/allocate_response_generated.h:51

↓ 1 callersMethodadd_error_code

src/allocate_response_generated.h:54

↓ 1 callersMethodadd_ipc_handle

src/local_meta_generated.h:89

↓ 1 callersMethodadd_key

src/local_meta_generated.h:32

↓ 1 callersMethodadd_key

src/tcp_payload_request_generated.h:34

↓ 1 callersMethodadd_keys

src/get_match_last_index_generated.h:29

↓ 1 callersMethodadd_keys

src/delete_keys_generated.h:29

↓ 1 callersMethodadd_keys

src/meta_request_generated.h:44

↓ 1 callersFunctionadd_mempool

src/infinistore.cpp:466

↓ 1 callersMethodadd_mempool

src/mempool.cpp:151

↓ 1 callersMethodadd_offset

src/local_meta_generated.h:35

↓ 1 callersMethodadd_op

src/tcp_payload_request_generated.h:40

↓ 1 callersMethodadd_op

src/meta_request_generated.h:55

↓ 1 callersMethodadd_remote_addrs

src/meta_request_generated.h:52

↓ 1 callersMethodadd_rkey

src/meta_request_generated.h:51

↓ 1 callersMethodadd_value_length

src/tcp_payload_request_generated.h:37

↓ 1 callersFunctionas_pyarray

src/pybind.cpp:24

↓ 1 callersFunctionblocks

src/allocate_response_generated.h:36

↓ 1 callersMethodcheck_key

src/infinistore.cpp:954

↓ 1 callersMethodcq_poll_handle

src/infinistore.cpp:345

↓ 1 callersMethoddeallocate

src/mempool.cpp:114

↓ 1 callersMethoddebug

infinistore/lib.py:155

↓ 1 callersMethoddelete_keys

* The function deletes a list of keys in kv_map. * * Input: * request: the request contains a list of the keys to delete * * Output: * t

src/infinistore.cpp:1001

↓ 1 callersMethoddelete_keys

Delete a list of keys Args: keys (List[str]): The list of string keys to delete Returns: int: The c

infinistore/lib.py:541

↓ 1 callersMethoderror

infinistore/lib.py:159

↓ 1 callersFunctionevict_cache

Evicts the cache in the infinistore. This function calls the underlying _infinistore.evict_cache() method to clear all entries in the ca

infinistore/lib.py:226

↓ 1 callersFunctiongenerate_uuid

infinistore/benchmark.py:111

↓ 1 callersFunctiongenerate_uuid

infinistore/example/tcp_client.py:7

↓ 1 callersFunctiongenerate_uuid

infinistore/example/client_async_single.py:8

↓ 1 callersFunctiongenerate_uuid

infinistore/example/client_async.py:9

↓ 1 callersFunctionget_active_rdma_devices

infinistore/test_infinistore.py:66

↓ 1 callersFunctionget_gpu_count

infinistore/test_infinistore.py:90

↓ 1 callersMethodget_match_last_index

src/infinistore.cpp:969

↓ 1 callersMethodget_match_last_index

Retrieve the last index of a match for the given keys. Args: keys (List[str]): A list of string keys to search for match

infinistore/lib.py:485

↓ 1 callersFunctionget_ptr

(mv: memoryview)

infinistore/example/tcp_client.py:11

next →1–100 of 292, ranked by callers