MCPcopy Create free account

hub / github.com/apache/incubator-pegasus / functions

Functions8,667 in github.com/apache/incubator-pegasus

↓ 2 callersMethodinitTableConfiguration
(query_cfg_response resp)
java-client/src/main/java/org/apache/pegasus/rpc/async/TableHandler.java:155
↓ 2 callersMethodinit_checkpoint
ThreadPool: THREAD_POOL_REPLICATION
src/replica/replica_chkpt.cpp:220
↓ 2 callersMethodinit_disk
src/meta/test/meta_bulk_load_ingestion_test.cpp:65
↓ 2 callersFunctioninit_sasl
src/runtime/security/sasl_init.cpp:126
↓ 2 callersMethodinitialize
src/zookeeper/lock_struct.cpp:112
↓ 2 callersMethodinitialize_start
src/replica/replica_stub.cpp:852
↓ 2 callersMethodinject_error
src/replica/replica_check.cpp:271
↓ 2 callersMethodinsert_before
insert me before existing link node o [p (this) o]
src/utils/link.h:128
↓ 2 callersMethodinstall
src/runtime/tracer.cpp:299
↓ 2 callersFunctionis_directory_empty
src/utils/filesystem.cpp:779
↓ 2 callersMethodis_duplication_follower
src/replica/replica.h:256
↓ 2 callersFunctionis_engine_ready
src/runtime/service_api_c.cpp:319
↓ 2 callersMethodis_from_balancer
return the action in acts & whether the action is from balancer
src/meta/meta_data.h:127
↓ 2 callersFunctionis_hex_digit
Helper function for sdssplitargs() that returns non zero if 'c' * is a valid hex digit. */
src/shell/sds/sds.c:896
↓ 2 callersFunctionis_name_ignored
(name)
scripts/check_license.py:84
↓ 2 callersMethodis_need_duplicate
src/replica/duplication/replica_follower.h:52
↓ 2 callersFunctionis_partition_config_equal
src/common/replication_other_types.h:73
↓ 2 callersFunctionis_path_ignored
(path)
scripts/check_license.py:72
↓ 2 callersMethodis_stale
src/utils/metrics.cpp:189
↓ 2 callersFunctionis_trailing_space
src/utils/strings.cpp:152
↓ 2 callersMethodis_under_backuping
src/meta/meta_backup_service.cpp:904
↓ 2 callersMethodissueBackupMetas
(ctx context.Context)
go-client/session/meta_call.go:125
↓ 2 callersMethodissueSingleMeta
issueSingleMeta returns false if we should try another meta
go-client/session/meta_call.go:109
↓ 2 callersFunctionjson_decode_map
src/common/json_helper.h:459
↓ 2 callersFunctionjson_decode_set
src/common/json_helper.h:475
↓ 2 callersFunctionjson_encode_map
src/common/json_helper.h:446
↓ 2 callersFunctionkth_percentile_to_nth_index
src/utils/metrics.h:1026
↓ 2 callersMethodlast_prepared_decree
src/replica/replica.cpp:454
↓ 2 callersMethodleft_potential_secondary_ack_count
src/replica/mutation.h:97
↓ 2 callersMethodless_primaries
src/meta/server_load_balancer.cpp:57
↓ 2 callersFunctionlinenoiseBeep
Beep, used for completion when there is nothing to complete or when all * the choices were already shown. */
src/shell/linenoise/linenoise.c:328
↓ 2 callersFunctionlinenoiseEditDelete
Delete the character at the right of the cursor without altering the cursor * position. Basically this is what happens with the "Delete" keyboard key
src/shell/linenoise/linenoise.c:724
↓ 2 callersFunctionlinenoiseEditMoveLeft
Move cursor on the left. */
src/shell/linenoise/linenoise.c:665
↓ 2 callersFunctionlinenoiseEditMoveRight
Move cursor on the right. */
src/shell/linenoise/linenoise.c:673
↓ 2 callersFunctionlist_all_files
extern*/
src/replica/mutation_log_utils.cpp:53
↓ 2 callersMethodlock
src/utils/hpc_locks/benaphore.h:69
↓ 2 callersMethodlogin
()
java-client/src/main/java/org/apache/pegasus/security/KerberosProtocol.java:150
↓ 2 callersMethodloop_op
(self)
python-client/tests/test_integration.py:132
↓ 2 callersFunctionmarshall_thrift_binary
src/common/serialization_helper/thrift_helper.h:725
↓ 2 callersFunctionmarshall_thrift_internal
src/common/serialization_helper/thrift_helper.h:692
↓ 2 callersMethodmarshalling
src/redis_protocol/proxy_lib/redis_parser.cpp:1309
↓ 2 callersMethodmax
static*/
src/utils/error_code.cpp:32
↓ 2 callersMethodmax_gced_decree
src/replica/mutation_log.cpp:877
↓ 2 callersFunctionmean_stddev
src/utils/math.cpp:30
↓ 2 callersMethodmetricsToJson
()
java-client/src/main/java/org/apache/pegasus/metrics/MetricsPool.java:92
↓ 2 callersMethodmultiDel
sync version of MultiDel, please refer to the async version {@link #asyncMultiDel(byte[], List, int)}
java-client/src/main/java/org/apache/pegasus/client/PegasusTableInterface.java:1202
↓ 2 callersMethodmultiGet
( byte[] hashKey, List<byte[]> sortKeys, int maxFetchCount, int maxFetchSize, int timeout)
java-client/src/main/java/org/apache/pegasus/client/PegasusTable.java:1297
↓ 2 callersMethodmultiGetSortKeys
Get multiple sort keys under the same hash key. @param tableName table name @param hashKey used to decide which partition to put this k-v, should not
java-client/src/main/java/org/apache/pegasus/client/PegasusClientInterface.java:297
↓ 2 callersMethodname
()
java-client/src/main/java/org/apache/pegasus/operator/client_operator.java:101
↓ 2 callersMethodnet_delay_milliseconds
src/runtime/rpc/network.sim.cpp:197
↓ 2 callersFunctionnewMetaCall
(lead int, metas []*metaSession, callFunc metaCallFunc)
go-client/session/meta_call.go:52
↓ 2 callersFunctionnewPegasusScannerImpl
(table *pegasusTableConnector, gpidSlice []*base.Gpid, hashSlice []uint64, options *ScannerOptions, startKey
go-client/pegasus/scanner.go:95
↓ 2 callersFunctionnewScanCommand
(c *grumble.Context)
pegic/interactive/cmd/scan.go:78
↓ 2 callersMethodnew_message_parser
src/runtime/rpc/network.cpp:562
↓ 2 callersMethodnewly_remove_primary
src/meta/server_load_balancer.cpp:103
↓ 2 callersMethodnext_app_id
util function
src/meta/server_state.h:306
↓ 2 callersFunctionno_registered_function_error_notice
src/runtime/rpc/serialization.h:38
↓ 2 callersFunctionnode_to_address
src/replica/storage/simple_kv/test/common.cpp:106
↓ 2 callersMethodnotifyCallerAndDrop
(req *requestListener)
go-client/session/session.go:214
↓ 2 callersMethodnotify_replica_state_update
src/replica/replica_stub.cpp:2463
↓ 2 callersMethodnow_timestamp
src/server/pegasus_manual_compact_service.cpp:217
↓ 2 callersMethodonAuthSucceed
()
java-client/src/main/java/org/apache/pegasus/rpc/async/ReplicaSession.java:390
↓ 2 callersMethodonConnected
(ReplicaSession session)
java-client/src/main/java/org/apache/pegasus/rpc/interceptor/ReplicaSessionInterceptor.java:25
↓ 2 callersMethodonRecvRpcResponse
(error_code err, scan_response response)
java-client/src/main/java/org/apache/pegasus/client/PegasusScanner.java:283
↓ 2 callersMethodonRecvScanResponse
(response *rrdb.ScanResponse, err error)
go-client/pegasus/scanner.go:260
↓ 2 callersMethodonSendMessage
(ReplicaSession session, final ReplicaSession.RequestEntry entry)
java-client/src/main/java/org/apache/pegasus/rpc/interceptor/ReplicaSessionInterceptor.java:29
↓ 2 callersMethodon_backup_reply
src/meta/backup_engine.cpp:251
↓ 2 callersMethodon_batched_write_requests
src/server/pegasus_server_impl.cpp:317
↓ 2 callersMethodon_client_read
src/replica/replica.cpp:244
↓ 2 callersMethodon_client_write
src/replica/replica_2pc.cpp:120
↓ 2 callersMethodon_copy_mutation_reply
ThreadPool: THREAD_POOL_REPLICATION
src/replica/split/replica_split_manager.cpp:1343
↓ 2 callersMethodon_disk_migrate
src/replica/replica_stub.cpp:1130
↓ 2 callersMethodon_disk_stat
src/replica/replica_stub.cpp:2041
↓ 2 callersMethodon_duplication_sync_reply
src/replica/duplication/duplication_sync_timer.cpp:89
↓ 2 callersMethodon_meta_server_connected
src/replica/replica_stub.cpp:1445
↓ 2 callersMethodon_query_bulk_load_status
src/meta/meta_service.cpp:1220
↓ 2 callersMethodon_start_bulk_load
src/meta/meta_service.cpp:1189
↓ 2 callersMethodon_state_change
src/replica/storage/simple_kv/test/case.cpp:1372
↓ 2 callersMethodon_work_completed
called when the current operation is completed, which triggers further round of operations as returned
src/utils/work_queue.h:77
↓ 2 callersMethodon_write
src/replica/backup/cold_backup_context.cpp:946
↓ 2 callersMethodon_write_completed
src/aio/disk_engine.cpp:130
↓ 2 callersMethodonly_copy_primary
src/meta/load_balance_policy.h:295
↓ 2 callersMethodopen_new_internal
src/replica/replication_app_base.cpp:312
↓ 2 callersMethodopen_replica
src/replica/test/replica_disk_migrate_test.cpp:138
↓ 2 callersFunctionoverwrite_file
src/replica/test/mutation_log_test.cpp:93
↓ 2 callersMethodowner_delete_prepare
src/runtime/task/task_tracker.h:214
↓ 2 callersMethodparent_handle_child_catch_up
ThreadPool: THREAD_POOL_REPLICATION
src/replica/split/replica_split_manager.cpp:621
↓ 2 callersMethodparse_compression_types
src/server/pegasus_server_impl.cpp:2983
↓ 2 callersFunctionparse_kv_map
src/utils/strings.cpp:317
↓ 2 callersMethodpartition_count
src/meta/server_load_balancer.h:75
↓ 2 callersFunctionpegasus_update_expire_ts
Update expire_ts in rocksdb value with given version. The value schema must be in v0 or v1.
src/base/pegasus_value_schema.h:99
↓ 2 callersMethodpop_one
src/utils/link.h:96
↓ 2 callersMethodprepare_buffer_header
src/runtime/rpc/rpc_message.cpp:384
↓ 2 callersMethodprepare_on_send
src/runtime/rpc/dsn_message_parser.cpp:111
↓ 2 callersMethodprepare_thrift_header
(self, body_length)
python-client/pypegasus/operate/packet.py:77
↓ 2 callersMethodprepare_ts_ms
src/replica/mutation.h:138
↓ 2 callersMethodprimary_address
src/runtime/service_app.h:100
↓ 2 callersMethodprimary_count
src/meta/server_load_balancer.h:71
↓ 2 callersMethodprimary_parent_handle_stop_split
ThreadPool: THREAD_POOL_REPLICATION
src/replica/split/replica_split_manager.cpp:1432
↓ 2 callersFunctionprintNodesInfo
(client *Client, nodes map[string]*nodeInfoStruct)
admin-cli/executor/list_nodes.go:120
← previousnext →1,801–1,900 of 8,667, ranked by callers