MCPcopy Create free account

hub / github.com/Meituan-Dianping/octo-ns / functions

Functions3,969 in github.com/Meituan-Dianping/octo-ns

MethoddrainPendingTask
sg_agent/thrid_party/thrift/include/server/TNonblockingServer.cpp:1184
Functiondyn_create
sg_agent/thrid_party/thrift/include/transport/TSSLSocket.cpp:507
Functiondyn_destroy
sg_agent/thrid_party/thrift/include/transport/TSSLSocket.cpp:523
Functiondyn_lock
sg_agent/thrid_party/thrift/include/transport/TSSLSocket.cpp:511
Methodecho
sg_agent/thrid_party/cthrift/include/cthrift/Echo.h:247
Methodecho
sg_agent/thrid_party/cthrift/include/cthrift/Echo.h:302
FunctionenableMutexProfiling
sg_agent/thrid_party/thrift/include/concurrency/Mutex.cpp:43
Methodencode
(ChannelHandlerContext channelHandlerContext, Header header, ByteBuf byteBuf)
scanner/src/main/java/com/meituan/octo/mns/scanner/util/heartbeat/HeartbeatCodec.java:40
Methodencode
encodes input (uint4) into output (unsigned char). Assumes len is a multiple of 4.
sg_agent/src/comm/md5.cc:147
MethodendItem
sg_agent/thrid_party/thrift/include/protocol/TDebugProtocol.cpp:114
MethodenqueueEvent
sg_agent/thrid_party/thrift/include/transport/TFileTransport.cpp:233
MethodensureCanWrite
sg_agent/thrid_party/thrift/include/transport/TBufferTransports.cpp:321
MethoderrorMessage
sg_agent/thrid_party/thrift/include/transport/TZlibTransport.h:44
MethoderrorTimeWrapper
sg_agent/thrid_party/thrift/include/Thrift.h:128
MethodescapeNum
Numbers must be turned into strings if they are the key part of a pair
sg_agent/thrid_party/thrift/include/protocol/TJSONProtocol.cpp:316
MethodeventHandler
* C-callable event handler for connection events. Provides a callback * that libevent can understand which invokes connection_->workSocket(). *
sg_agent/thrid_party/thrift/include/server/TNonblockingServer.cpp:264
MethodeventHandler
* C-callable event handler for listener events. Provides a callback * that libevent can understand which invokes server->handleEvent(). * *
sg_agent/thrid_party/thrift/include/server/TNonblockingServer.h:736
MethodeventInfo
sg_agent/thrid_party/thrift/include/transport/TFileTransport.h:57
MethodexceptionCaught
(ChannelHandlerContext ctx, Throwable cause)
scanner/src/main/java/com/meituan/octo/mns/scanner/util/heartbeat/HeartbeatHandler.java:39
MethodexpireClose
sg_agent/thrid_party/thrift/include/server/TNonblockingServer.cpp:1199
MethodexpiredTaskCount
sg_agent/thrid_party/thrift/include/concurrency/ThreadManager.cpp:113
MethodfieldTypeName
sg_agent/thrid_party/thrift/include/protocol/TDebugProtocol.cpp:43
Methodfinish
sg_agent/thrid_party/thrift/include/transport/TZlibTransport.cpp:259
Methodfinish
static */
sg_agent/thrid_party/thrift/include/async/TAsyncProtocolProcessor.cpp:42
Methodflush
sg_agent/thrid_party/thrift/include/transport/THttpClient.cpp:86
Methodflush
sg_agent/thrid_party/thrift/include/transport/TShortReadTransport.h:74
Methodflush
sg_agent/thrid_party/thrift/include/transport/TTransportUtils.cpp:84
Methodflush
sg_agent/thrid_party/thrift/include/transport/TFileTransport.cpp:560
Methodflush
sg_agent/thrid_party/thrift/include/transport/THttpServer.cpp:79
Methodflush
* Flushes any pending data to be written. Typically used with buffered * transport mechanisms. * * @throws TTransportException if an error oc
sg_agent/thrid_party/thrift/include/transport/TTransport.h:183
Methodflush
sg_agent/thrid_party/thrift/include/transport/TBufferTransports.cpp:119
MethodflushToTransport
sg_agent/thrid_party/thrift/include/transport/TZlibTransport.cpp:268
MethodflushToZlib
sg_agent/thrid_party/thrift/include/transport/TZlibTransport.cpp:282
Methodfoo
sg_agent/thrid_party/thrift/include/concurrency/test/ThreadFactoryTests.h:310
Functionget
* Used to retrieve an object from the registry. (The registry * owns the returned pointer.) */
sg_agent/thrid_party/logs/include/spi/factory.h:172
Functionget
* Used to retrieve an object from the registry. (The registry * owns the returned pointer.) */
sg_agent/thrid_party/logs/log4cplus/include/log4cplus/spi/factory.h:172
MethodgetAllAppkeys
()
nsc/src/test/java/com/meituan/octo/mnsc/MNSCacheApiTest.java:41
MethodgetAppKey
()
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/http/HttpServerPublisher.java:49
MethodgetAppKeyByIP
()
nsc/src/test/java/com/meituan/octo/mnsc/MNSCacheServiceTest.java:39
MethodgetAppkeyList
(@PathVariable("ip") String ip)
nsc/src/main/java/com/meituan/octo/mnsc/web/api/ApiController.java:81
MethodgetAppkeyListByIP
sg_agent/thrid_party/thrid/include/octoidl/MNSCacheService.h:921
MethodgetAppkeyListByIP
common/gen-cpp/MNSCacheService.h:921
MethodgetAppkeys
()
nsc/src/main/java/com/meituan/octo/mnsc/web/api/ApiController.java:95
MethodgetAsyncServer
sg_agent/thrid_party/thrift/include/async/TAsyncProcessor.h:58
MethodgetAtomic_avaliable_conn_num_
sdk/mns-sdk/src/mns_worker.h:285
MethodgetAtomic_avaliable_conn_num_
sg_agent/thrid_party/thrid/include/mns_sdk/mns_worker.h:285
FunctiongetBuffer
sg_agent/thrid_party/logs/log4cplus/include/log4cplus/helpers/socketbuffer.h:48
MethodgetBufferAsString
sg_agent/thrid_party/thrift/include/transport/TBufferTransports.h:578
MethodgetCachedAddress
sg_agent/thrid_party/thrift/include/transport/TSocket.cpp:800
MethodgetChannel
sg_agent/thrid_party/cthrift/include/cthrift/Echo.h:319
MethodgetChunkSize
sg_agent/thrid_party/thrift/include/transport/TFileTransport.h:230
MethodgetClient
sg_agent/thrid_party/thrid/include/mns_sdk/thrift_client.h:44
MethodgetConnectionStackLimit
* Get the maximum number of unused TConnection we will hold in reserve. * * @return the current limit on TConnection pool size. */
sg_agent/thrid_party/thrift/include/server/TNonblockingServer.h:376
MethodgetCurChunk
sg_agent/thrid_party/thrift/include/transport/TTransportUtils.cpp:166
FunctiongetCurrentThreadId
sg_agent/thrid_party/logs/include/thread/impl/threads-impl.h:54
FunctiongetCurrentThreadId
sg_agent/thrid_party/logs/log4cplus/include/log4cplus/thread/impl/threads-impl.h:54
MethodgetCurrentThreadId
sg_agent/thrid_party/thrift/include/concurrency/PosixThreadFactory.cpp:302
MethodgetCurrentThreadId
sg_agent/thrid_party/thrift/include/concurrency/BoostThreadFactory.cpp:165
MethodgetCurrentThreadId
sg_agent/thrid_party/thrift/include/concurrency/BoostThreadFactory.cpp:180
MethodgetEnv
()
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/model/AgentInfo.java:37
MethodgetEofSleepTimeUs
sg_agent/thrid_party/thrift/include/transport/TFileTransport.h:283
MethodgetEventBase
sg_agent/thrid_party/thrift/include/async/TEvhttpServer.cpp:164
MethodgetEventBufferSize
sg_agent/thrid_party/thrift/include/transport/TFileTransport.h:242
MethodgetEventHandler
sg_agent/thrid_party/thrift/include/TProcessor.h:150
MethodgetEventHandler
sg_agent/thrid_party/thrift/include/async/TAsyncProcessor.h:50
MethodgetFD
sg_agent/thrid_party/thrift/include/transport/TFDTransport.h:66
MethodgetFileReaderTransport
sg_agent/thrid_party/thrift/include/transport/TTransportUtils.h:323
FunctiongetFilter
* Get the filter chain on this Appender. */
sg_agent/thrid_party/logs/include/appender.h:216
FunctiongetFilter
* Get the filter chain on this Appender. */
sg_agent/thrid_party/logs/log4cplus/include/log4cplus/appender.h:216
MethodgetFlushMaxBytes
sg_agent/thrid_party/thrift/include/transport/TFileTransport.h:260
MethodgetFlushMaxUs
sg_agent/thrid_party/thrift/include/transport/TFileTransport.h:251
MethodgetHandler
sg_agent/thrid_party/thrid/include/octoidl/MNSCacheService.h:41
MethodgetHandler
sg_agent/thrid_party/thrid/include/octoidl/ServiceAgent.h:40
MethodgetHandler
sg_agent/thrid_party/cthrift/include/cthrift/Echo.h:42
MethodgetHandler
sg_agent/thrid_party/cthrift/include/cthrift/Echo.h:290
MethodgetHandler
common/gen-cpp/MNSCacheService.h:41
MethodgetHost
sg_agent/thrid_party/thrift/include/transport/TSocket.cpp:593
MethodgetHostInfo
()
sdk/mns-invoker/src/test/java/com/meituan/octo/mns/util/ProcessInfoUtilTests.java:80
FunctiongetId
sg_agent/thrid_party/thrift/include/concurrency/PosixThreadFactory.cpp:163
MethodgetIdcs
()
sdk/mns-invoker/src/test/java/com/meituan/octo/mns/util/ProcessInfoUtilTests.java:40
MethodgetIdleBufferMemLimit
* [NOTE: This is for backwards compatibility, use getIdleReadBufferLimit().] * Get the maximum size of read buffer allocated to idle TConnection ob
sg_agent/thrid_party/thrift/include/server/TNonblockingServer.h:620
MethodgetInputProtocol
sg_agent/thrid_party/thrid/include/octoidl/MNSCacheService.h:780
MethodgetInputProtocol
sg_agent/thrid_party/thrid/include/octoidl/ServiceAgent.h:635
MethodgetInputProtocol
sg_agent/thrid_party/cthrift/include/cthrift/Echo.h:191
MethodgetInputProtocol
common/gen-cpp/MNSCacheService.h:780
MethodgetInputProtocol
common/gen-cpp/ServiceAgent.h:635
MethodgetInputTransport
TODO: remove these two calls, they are for backwards compatibility
sg_agent/thrid_party/thrift/include/protocol/TProtocol.h:653
MethodgetIp
()
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/model/AgentInfo.java:45
FunctiongetLine
The is the line where this log statement was written */
sg_agent/thrid_party/logs/include/spi/loggingevent.h:185
FunctiongetLine
The is the line where this log statement was written */
sg_agent/thrid_party/logs/log4cplus/include/log4cplus/spi/loggingevent.h:185
FunctiongetLogLevel
* Returns the assigned LogLevel, if any, for this Logger. * * @return LogLevel - the assigned LogLevel.
sg_agent/thrid_party/logs/include/spi/loggerimpl.h:113
FunctiongetLogLevel
LogLevel of logging event. */
sg_agent/thrid_party/logs/include/spi/loggingevent.h:119
FunctiongetLogLevel
* Returns the assigned LogLevel, if any, for this Logger. * * @return LogLevel - the assigned LogLevel.
sg_agent/thrid_party/logs/log4cplus/include/log4cplus/spi/loggerimpl.h:113
FunctiongetLogLevel
LogLevel of logging event. */
sg_agent/thrid_party/logs/log4cplus/include/log4cplus/spi/loggingevent.h:119
MethodgetMNSCache
()
nsc/src/test/java/com/meituan/octo/mnsc/MNSCacheServiceTest.java:83
MethodgetMNSCache
(String appkey, String version, String env)
nsc/src/main/java/com/meituan/octo/mnsc/thrift/service/impl/MNSCacheServiceImpl.java:35
MethodgetMNSCache
sg_agent/thrid_party/thrid/include/octoidl/MNSCacheService.h:861
MethodgetMNSCache
common/gen-cpp/MNSCacheService.h:861
MethodgetMNSCacheByAppkeys
()
nsc/src/test/java/com/meituan/octo/mnsc/MNSCacheServiceTest.java:70
MethodgetMNSCacheByAppkeys
(List<String> appkeys, String protocol)
nsc/src/main/java/com/meituan/octo/mnsc/thrift/service/impl/MNSCacheServiceImpl.java:55
← previousnext →2,301–2,400 of 3,969, ranked by callers