MCPcopy Create free account

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

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

↓ 3 callersMethodon_recv_message
src/runtime/rpc/network.cpp:423
↓ 3 callersMethodon_recv_reply
src/runtime/rpc/network.cpp:557
↓ 3 callersFunctionopen_log_file_map
src/replica/mutation_log_utils.h:47
↓ 3 callersMethodoperate
(client_operator op, int timeoutMs)
java-client/src/main/java/org/apache/pegasus/rpc/async/TableHandler.java:449
↓ 3 callersMethodoperationTimeout
The timeout for failing to finish an operation, must be positive. Defaults to {@literal 1000ms}, see {@link #DEFAULT_OPERATION_TIMEOUT}. @param opera
java-client/src/main/java/org/apache/pegasus/client/ClientOptions.java:293
↓ 3 callersMethodparent_cleanup_split_context
ThreadPool: THREAD_POOL_REPLICATION
src/replica/split/replica_split_manager.cpp:1108
↓ 3 callersFunctionpartition_health_status
src/meta/meta_data.h:517
↓ 3 callersFunctionpegasus_extract_timetag
Extracts timetag from a v1 value.
src/base/pegasus_value_schema.h:87
↓ 3 callersFunctionperf_counter_add
src/perf_counter/test/perf_counter_test.cpp:90
↓ 3 callersFunctionperf_counter_inc_dec
src/perf_counter/test/perf_counter_test.cpp:70
↓ 3 callersMethodpool
src/runtime/task/task_queue.h:83
↓ 3 callersMethodport
src/runtime/rpc/rpc_address.h:132
↓ 3 callersFunctionprint_help
src/shell/main.cpp:541
↓ 3 callersFunctionprocess_fatal_log
src/utils/simple_logger.cpp:102
↓ 3 callersMethodquery_configuration_by_gpid
src/meta/server_state.cpp:993
↓ 3 callersMethodquery_configuration_by_node
run in THREAD_POOL_META_SERVER assert(_state_lock.locked())
src/replica/replica_stub.cpp:1411
↓ 3 callersMethodquery_duplication_info
ThreadPool(READ): THREAD_POOL_META_SERVER
src/meta/duplication/meta_duplication_service.cpp:59
↓ 3 callersMethodquery_partition_split
src/meta/meta_split_service.cpp:322
↓ 3 callersMethodquery_snapshot
src/perf_counter/perf_counters.cpp:423
↓ 3 callersMethodread_file_header
src/replica/log_file.cpp:366
↓ 3 callersMethodread_next
src/runtime/rpc/rpc_message.cpp:439
↓ 3 callersMethodrecord_drop_history
src/meta/meta_data.cpp:364
↓ 3 callersMethodregister_ctrl_commands
src/meta/meta_service.cpp:291
↓ 3 callersFunctionregister_http_service
extern*/
src/http/http_server.cpp:285
↓ 3 callersMethodregister_rpc_handler
src/runtime/serverlet.h:162
↓ 3 callersFunctionremote_command
src/shell/commands/node_management.cpp:511
↓ 3 callersMethodremove
src/http/http_call_registry.h:45
↓ 3 callersMethodremove_my_locknode
src/zookeeper/lock_struct.cpp:730
↓ 3 callersMethodremove_prefix
string_view::remove_prefix() Removes the first `n` characters from the `string_view`. Note that the underlying std::string is not changed, only the v
src/utils/string_view.h:293
↓ 3 callersMethodremove_suffix
string_view::remove_suffix() Removes the last `n` characters from the `string_view`. Note that the underlying std::string is not changed, only the vi
src/utils/string_view.h:304
↓ 3 callersFunctionrename_app
src/shell/commands/table_management.cpp:766
↓ 3 callersMethodreplace_callback
src/runtime/task/task.h:505
↓ 3 callersFunctionreplace_value
src/runtime/fault_injector.cpp:218
↓ 3 callersMethodreport
src/meta/greedy_load_balancer.cpp:228
↓ 3 callersMethodreset
src/test/function_test/throttle_test/test_throttle.cpp:105
↓ 3 callersFunctionresetEncoding
resetEncoding is the generic executor for the encoding-reset commands
pegic/interactive/cmd/encoding.go:84
↓ 3 callersMethodreset_from
src/replica/mutation_log.cpp:925
↓ 3 callersMethodretryQueryMeta
(final MetaRequestRound round, boolean needDelay)
java-client/src/main/java/org/apache/pegasus/rpc/async/MetaSession.java:255
↓ 3 callersMethodrun
src/runtime/nativerun.cpp:116
↓ 3 callersMethodrun
src/runtime/test/pipeline_test.cpp:82
↓ 3 callersMethodrun
()
java-client/src/main/java/org/apache/pegasus/rpc/async/MetaSession.java:161
↓ 3 callersFunctionrun_cmd_no_error
src/test/function_test/utils/utils.h:219
↓ 3 callersFunctionsafelyDowngradeNode
safelyDowngradeNode first migrates all primaries out from this node, then shuts down all replicas. Returns the effected partitions. NOTE: map[base.Gpi
admin-cli/client/migrate_node_test.go:70
↓ 3 callersFunctionsdsReqType
src/shell/sds/sds.c:58
↓ 3 callersFunctionsdscmp
Compare two sds strings s1 and s2 with memcmp(). * * Return value: * * positive if s1 > s2. * negative if s1 < s2. * 0 if s1 and s2
src/shell/sds/sds.c:777
↓ 3 callersFunctionsdsfreesplitres
Free the result returned by sdssplitlen(), or do nothing if 'tokens' is NULL. */
src/shell/sds/sds.c:856
↓ 3 callersFunctionsdstrim
Remove the part of the string from left and from right composed just of * contiguous characters found in 'cset', that is a null terminted C string.
src/shell/sds/sds.c:693
↓ 3 callersMethodselect_node
src/meta/load_balance_policy.cpp:576
↓ 3 callersMethodsend_balancer_proposal
src/client/replication_ddl_client.cpp:878
↓ 3 callersFunctionsend_message
src/runtime/test/rpc.cpp:191
↓ 3 callersMethodsetActualValue
(final byte[] actualValue)
java-client/src/main/java/org/apache/pegasus/client/PegasusTableInterface.java:775
↓ 3 callersMethodsetCheckValue
(final byte[] checkValue)
java-client/src/main/java/org/apache/pegasus/client/PegasusTableInterface.java:617
↓ 3 callersMethodsetCheckValue
(final byte[] checkValue)
java-client/src/main/java/org/apache/pegasus/client/PegasusTableInterface.java:714
↓ 3 callersMethodsetCheckValueExist
(final boolean checkValueExist)
java-client/src/main/java/org/apache/pegasus/client/PegasusTableInterface.java:609
↓ 3 callersMethodsetCheckValueExist
(final boolean checkValueExist)
java-client/src/main/java/org/apache/pegasus/client/PegasusTableInterface.java:706
↓ 3 callersMethodsetHistorgram
(String counterName, long value)
java-client/src/main/java/org/apache/pegasus/metrics/MetricsPool.java:48
↓ 3 callersMethodsetMeter
(String counterName, long count)
java-client/src/main/java/org/apache/pegasus/metrics/MetricsPool.java:44
↓ 3 callersMethodsetState
thread-safe
go-client/rpc/rpc_conn.go:100
↓ 3 callersMethodset_addr
src/meta/meta_data.h:428
↓ 3 callersMethodset_bulk_load_downloading_count
src/replica/test/mock_utils.h:371
↓ 3 callersMethodset_function_level
src/meta/meta_service.h:169
↓ 3 callersMethodset_parent_point_name
src/utils/latency_tracer.h:151
↓ 3 callersMethodset_replica_config
helper functions
src/replica/test/mock_utils.h:170
↓ 3 callersMethodset_sort_key_filter
src/shell/command_helper.h:206
↓ 3 callersMethodset_state_connected
src/replica/test/mock_utils.h:276
↓ 3 callersMethodset_tasks_success
src/runtime/task/task_tracker.h:162
↓ 3 callersMethodset_value
src/common/gpid.h:65
↓ 3 callersMethodset_value_filter
src/shell/command_helper.h:211
↓ 3 callersMethodsignal
src/utils/synchronize.h:122
↓ 3 callersMethodsize
string_view::size() Returns the number of characters in the `string_view`.
src/utils/string_view.h:250
↓ 3 callersMethodstart
src/replica/test/main.cpp:49
↓ 3 callersMethodstart
src/runtime/service_engine.cpp:114
↓ 3 callersMethodstart
src/runtime/security/client_negotiation.cpp:48
↓ 3 callersMethodstart
src/meta/meta_backup_service.cpp:823
↓ 3 callersMethodstart_backup_app
src/meta/meta_backup_service.cpp:1646
↓ 3 callersFunctionstart_http_server
extern*/
src/http/http_server.cpp:279
↓ 3 callersMethodstate
src/runtime/task/task.h:225
↓ 3 callersMethodstatus
get current status.
src/replica/backup/cold_backup_context.h:261
↓ 3 callersMethodsub_tracer
src/utils/latency_tracer.cpp:196
↓ 3 callersMethodsubmit_aio_task
src/aio/native_linux_aio_provider.cpp:142
↓ 3 callersMethodsync_checkpoint
src/replica/storage/simple_kv/simple_kv.server.impl.cpp:212
↓ 3 callersMethodsync_duplication
src/replica/duplication/replica_duplicator_manager.cpp:59
↓ 3 callersFunctiontake_snapshot_and_get_json_string
src/utils/test/metrics_test.cpp:961
↓ 3 callersFunctiontest_func
src/utils/test/fail_point_test.cpp:121
↓ 3 callersMethodthisRoundCompletion
()
java-client/src/main/java/org/apache/pegasus/rpc/async/ClientRequestRound.java:96
↓ 3 callersMethodtoByteArray
()
java-client/src/main/java/org/apache/pegasus/rpc/ThriftHeader.java:30
↓ 3 callersMethodtoString
()
admin-cli/executor/toolkits/nodesmigrator/action.go:89
↓ 3 callersMethodto_duplication_entry
src/meta/duplication/duplication_info.h:146
↓ 3 callersFunctionto_rocksdb_slice
src/base/pegasus_utils.h:111
↓ 3 callersMethodto_string
src/geo/lib/geo_client.h:82
↓ 3 callersMethodtoken_got
src/server/pegasus_server_impl.cpp:1897
↓ 3 callersMethodtryDecompress
try decompress the `src`, return `src` directly if failed @param src the origin sending value @return the decompressed value.
java-client/src/main/java/org/apache/pegasus/tools/ZstdWrapper.java:39
↓ 3 callersMethodtryQueryMeta
(long cachedConfigVersion)
java-client/src/main/java/org/apache/pegasus/rpc/async/TableHandler.java:262
↓ 3 callersMethodtryStartServer
(rpc_address server)
java-client/src/test/java/org/apache/pegasus/tools/Toollet.java:110
↓ 3 callersMethodunlock
src/utils/hpc_locks/benaphore.h:100
↓ 3 callersMethodunlock
static*/
src/zookeeper/lock_struct.cpp:783
↓ 3 callersMethodunlock_read
src/utils/synchronize.h:85
↓ 3 callersMethodunlock_write
src/utils/synchronize.h:89
↓ 3 callersFunctionunmarshall_base
src/common/serialization_helper/thrift_helper.h:655
↓ 3 callersMethodunsigned_right_shift
(cls, val, n)
python-client/pypegasus/pgclient.py:536
← previousnext →1,401–1,500 of 8,667, ranked by callers