Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/Tencent/flare
/ functions
Functions
4,521 in github.com/Tencent/flare
⨍
Functions
4,521
◇
Types & classes
1,233
↓ 1 callers
Method
GetResponseAttachmentPrecompressed
flare/rpc/protocol/protobuf/rpc_server_controller.cc:154
↓ 1 callers
Method
GetSchedulingGroup
flare/fiber/detail/timer_worker.cc:178
↓ 1 callers
Function
GetSchedulingParametersForCompute
flare/fiber/detail/scheduling_parameters.cc:35
↓ 1 callers
Function
GetSchedulingProfile
flare/fiber/runtime.cc:401
↓ 1 callers
Function
GetSleepTimeout
Load time point from `expected`, but if it's infinite, return a large timeout instead (otherwise overflow can occur in libstdc++, which results in no
flare/fiber/detail/timer_worker.cc:58
↓ 1 callers
Function
GetSockOpt
flare/io/util/socket.cc:83
↓ 1 callers
Function
GetSocketError
flare/io/util/socket.cc:211
↓ 1 callers
Method
GetSpanContext
You'll need this to derive your own client-side span. `opentelemetry::trace::SpanContext` is a value type. An invalid context (`SpanContext::GetInval
flare/rpc/tracing/tracing_ops.h:116
↓ 1 callers
Method
GetStackLimit
Get stack size.
flare/fiber/detail/fiber_entity.h:196
↓ 1 callers
Method
GetStreamTimeout
flare/rpc/protocol/protobuf/rpc_controller_common.cc:125
↓ 1 callers
Function
GetTracingOps
flare/rpc/tracing/tracing_ops.cc:170
↓ 1 callers
Method
GetTrivialFls
Get trivial FLS by its index. Trivial FLSes are always zero-initialized.
flare/fiber/detail/fiber_entity.h:221
↓ 1 callers
Method
GetType
flare/example/custom_protocol/naive_message.cc:32
↓ 1 callers
Function
GetUriPath
flare/rpc/protocol/http/service.cc:118
↓ 1 callers
Function
GetVersionInfo
Copied from `common/base/binary_version.cc`.
flare/rpc/protocol/http/builtin/misc_handler.cc:63
↓ 1 callers
Function
HandleCosOpDispatch
flare/testing/cos_mock.h:134
↓ 1 callers
Function
HandleRpc
flare/testing/rpc_mock.h:219
↓ 1 callers
Method
Handshake
flare/io/util/ssl_stream_io.cc:44
↓ 1 callers
Function
HashFd
Shamelessly copied from https://stackoverflow.com/a/57556517
flare/io/event_loop.cc:76
↓ 1 callers
Function
HashRange
flare/base/internal/hash_map.h:226
↓ 1 callers
Function
HomemadeMembarrier
`membarrier()` is not usable until Linux 4.3, which is not available until tlinux 3 is deployed. Here Folly provides a workaround by mutating our pag
flare/base/internal/memory_barrier.cc:44
↓ 1 callers
Function
HttpGet
flare/base/internal/curl.cc:140
↓ 1 callers
Method
Increment
flare/base/monitoring.cc:311
↓ 1 callers
Method
Initialize
flare/base/internal/circular_buffer.h:90
↓ 1 callers
Function
InitializeBinlog
flare/rpc/binlog/init.cc:27
↓ 1 callers
Function
InitializeBuiltinKeyMapping
flare/base/monitoring/init.cc:149
↓ 1 callers
Function
InitializeDpcOnce
flare/base/internal/dpc.cc:222
↓ 1 callers
Method
InitializeLocalQueue
flare/fiber/detail/timer_worker.cc:180
↓ 1 callers
Function
InitializeMonitorTimerOnce
Initialization of timer is delayed until first call to `Report()` to avoid static initialization order fiasco.
flare/base/monitoring.cc:173
↓ 1 callers
Function
InitializeMonitoringSystem
flare/base/monitoring/init.cc:195
↓ 1 callers
Function
InitializeObjectPoolForCurrentThread
flare/base/object_pool.cc:21
↓ 1 callers
Function
InitializeProcessorInfoOnce
Initialize those global variables.
flare/base/internal/cpu.cc:154
↓ 1 callers
Function
InitializeSchedulingParametersFromFlags
flare/fiber/runtime.cc:438
↓ 1 callers
Method
InitializeStreamingRpcContext
flare/rpc/protocol/protobuf/rpc_client_controller.cc:125
↓ 1 callers
Method
Inject
flare/rpc/tracing/integration_test.cc:169
↓ 1 callers
Method
Insert
Insert a new correlation. Were duplicate found, we crash. (TODO(luobogao): Maybe we can fail more gracefully.)
flare/rpc/internal/sharded_call_map.h:42
↓ 1 callers
Function
InspectUri
Returns: scheme, address.
flare/rpc/protocol/protobuf/rpc_channel.cc:138
↓ 1 callers
Method
Invoke
flare/base/function.h:163
↓ 1 callers
Function
IsContentTypeApplicationJsonSlow
Per spec, `charset` is allowed for `application/json`. This method tests if the given type string represents `application/json` with UTF-8 `charset`.
flare/rpc/protocol/protobuf/proto_over_http_protocol.cc:217
↓ 1 callers
Method
IsDumped
flare/net/http/binlog_dumper_integration_test.cc:94
↓ 1 callers
Method
IsDumped
flare/rpc/protocol/http/binlog_dumper_integration_test.cc:106
↓ 1 callers
Function
IsExecutionContextPresent
flare/fiber/logging.cc:57
↓ 1 callers
Function
IsFlagHidden
flare/rpc/protocol/http/builtin/gflags_handler.cc:31
↓ 1 callers
Function
IsMessageClobbered
flare/rpc/protocol/http/http11_protocol.cc:58
↓ 1 callers
Function
IsMockAddress
flare/net/http/http_client.cc:451
↓ 1 callers
Function
IsMockAddress
flare/rpc/protocol/protobuf/rpc_channel.cc:84
↓ 1 callers
Function
IsPortAvaliable
flare/testing/endpoint.cc:25
↓ 1 callers
Function
IsPortUnsafeForServingV4
Tests if `port` is unsafe to be used as a serving port.
flare/rpc/server.cc:81
↓ 1 callers
Function
IsProcessorAccessible
flare/base/internal/cpu.cc:286
↓ 1 callers
Method
IsSampled
flare/rpc/tracing/integration_test.cc:178
↓ 1 callers
Method
IsStreaming
flare/rpc/protocol/protobuf/rpc_controller_common.h:133
↓ 1 callers
Method
IsTimerReported
flare/base/monitoring_test.cc:140
↓ 1 callers
Function
IsValgrindPresent
flare/base/internal/cpu.cc:55
↓ 1 callers
Function
IsValidDomain
flare/rpc/name_resolver/util/domain_name_resolver.cc:82
↓ 1 callers
Function
IsValidLastSegment
flare/rpc/name_resolver/util/domain_name_resolver.cc:72
↓ 1 callers
Function
IsValidSegment
flare/rpc/name_resolver/util/domain_name_resolver.cc:56
↓ 1 callers
Method
Join
flare/fiber/runtime.cc:127
↓ 1 callers
Method
Join
flare/io/detail/watchdog.cc:57
↓ 1 callers
Method
Join
flare/base/monitoring/dispatcher.cc:198
↓ 1 callers
Method
Join
flare/net/hbase/hbase_service.cc:136
↓ 1 callers
Function
JoinAllEventLoops
flare/io/event_loop.cc:342
↓ 1 callers
Function
JoinAllGlobalStreamCallGatePools
flare/rpc/internal/stream_call_gate_pool.cc:589
↓ 1 callers
Function
JsonValueToProtoMessage
flare/rpc/protocol/protobuf/gdt_json_proto_conversion.cc:258
↓ 1 callers
Method
Kill
flare/io/descriptor.cc:124
↓ 1 callers
Method
Leak
flare/base/thread/thread_local/detail/atomic_ptr.h:62
↓ 1 callers
Method
ListenOn
flare/testing/naked_server.cc:61
↓ 1 callers
Function
LoadSystem
Slow but works.
flare/base/monitoring/init.cc:100
↓ 1 callers
Method
Log
flare/rpc/tracing/tracing_ops.h:348
↓ 1 callers
Function
MakeKeyTime
flare/net/cos/signature.cc:37
↓ 1 callers
Function
MakeTracingOps
flare/rpc/tracing/tracing_ops.cc:50
↓ 1 callers
Function
MakeTracingOpsProvider
flare/rpc/tracing/tracing_ops_provider.cc:27
↓ 1 callers
Function
MaximumBacklog
flare/io/util/socket.cc:40
↓ 1 callers
Method
MergeFrom
flare/base/experimental/bloom_filter.h:264
↓ 1 callers
Function
MergeGlobal
flare/rpc/internal/rpc_metrics.cc:73
↓ 1 callers
Method
Modify
flare/io/detail/epoll_poller.cc:54
↓ 1 callers
Method
MutableUserTracingLogs
flare/rpc/protocol/protobuf/rpc_server_controller.h:277
↓ 1 callers
Method
MutableUserTracingTags
flare/rpc/protocol/protobuf/rpc_server_controller.h:276
↓ 1 callers
Function
NearestSchedulingGroupSlow
flare/fiber/runtime.cc:532
↓ 1 callers
Function
NewConnectionCorrelationId
Allocate new ID for connection. Each connection has a dedicated ID. This is necessary to distinguish ID duplicates on different connections.
flare/rpc/internal/correlation_id.h:54
↓ 1 callers
Function
NewCorrelationId
flare/rpc/binlog/dumper.cc:97
↓ 1 callers
Function
NewMessageDispatcherFromName
flare/rpc/protocol/protobuf/rpc_channel.cc:155
↓ 1 callers
Function
Next
flare/base/id_alloc.h:54
↓ 1 callers
Method
Next
flare/base/buffer/zero_copy_stream.cc:29
↓ 1 callers
Function
NormalizeDomain
flare/rpc/name_resolver/util/domain_name_resolver.cc:35
↓ 1 callers
Function
NormalizePath
'.' / '..' is not handled by this method. They're valid node name in `ExposedVarGroup`.
flare/rpc/protocol/http/builtin/exposed_vars_handler.cc:39
↓ 1 callers
Function
NormalizeUriScheme
Handle the difference between URI scheme difference between our old framework and Flare. This method is only used by `RpcChannel`, so we can assume P
flare/rpc/protocol/protobuf/rpc_channel.cc:120
↓ 1 callers
Method
Notify
flare/io/detail/event_loop_notifier.cc:69
↓ 1 callers
Method
Notify
flare/net/internal/http_engine.cc:103
↓ 1 callers
Method
NotifyStreamCompletion
flare/rpc/protocol/protobuf/rpc_client_controller.cc:154
↓ 1 callers
Method
NotifyStreamProgress
flare/rpc/protocol/protobuf/rpc_client_controller.cc:148
↓ 1 callers
Function
Oc
(a,b,c)
flare/rpc/protocol/http/builtin/resources/static/jquery-1.11.2.min.js:4
↓ 1 callers
Method
OnCallCompletion
flare/rpc/internal/normal_connection_handler.cc:746
↓ 1 callers
Method
OnClose
flare/io/native/stream_connection_test.cc:57
↓ 1 callers
Method
OnDataArrival
flare/io/native/stream_connection_test.cc:53
↓ 1 callers
Method
OnDataWritten
flare/io/native/stream_connection_test.cc:51
↓ 1 callers
Method
OnDatagramArrival
flare/io/native/datagram_transceiver_test.cc:38
↓ 1 callers
Method
OnDatagramWritten
flare/io/native/datagram_transceiver_test.cc:37
↓ 1 callers
Method
OnError
flare/io/native/datagram_transceiver.cc:131
↓ 1 callers
Method
OnError
flare/io/native/stream_connection.cc:310
↓ 1 callers
Method
OnFilter
flare/rpc/protocol/http/http_test.cc:47
← previous
next →
1,601–1,700 of 4,521, ranked by callers