MCPcopy Create free account

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

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

↓ 1 callersMethodcreate
------------------------------------------------------------------------------
sg_agent/thrid_party/thrift/include/windows/TWinsockSingleton.cpp:52
↓ 1 callersMethodcreateSSL
sg_agent/thrid_party/thrift/include/transport/TSSLSocket.cpp:76
↓ 1 callersMethoddecodeXMDHeader
(byte[] headerBytes)
scanner/src/main/java/com/meituan/octo/mns/scanner/util/heartbeat/HeartbeatCodec.java:93
↓ 1 callersMethoddecrementNumConnections
Decrement our count of the number of connected sockets.
sg_agent/thrid_party/thrift/include/server/TNonblockingServer.h:431
↓ 1 callersMethoddeleteProviders
(@RequestBody List<SGService> providers)
nsc/src/main/java/com/meituan/octo/mnsc/web/api/ProvidersController.java:83
↓ 1 callersMethoddetect
(long round, Provider provider)
scanner/src/main/java/com/meituan/octo/mns/scanner/service/ProviderDetectService.java:54
↓ 1 callersMethoddetect
(String ip, int port)
scanner/src/main/java/com/meituan/octo/mns/scanner/util/SocketDetector.java:31
↓ 1 callersMethoddetect
(String ip, int port)
scanner/src/main/java/com/meituan/octo/mns/scanner/util/heartbeat/HeartbeatClient.java:59
↓ 1 callersMethoddetect
(String ip, int port)
scanner/src/main/java/com/meituan/octo/mns/scanner/util/heartbeat/HeartbeatDetector.java:20
↓ 1 callersMethoddetectAgain
(String ip, int port)
scanner/src/main/java/com/meituan/octo/mns/scanner/util/SocketDetector.java:51
↓ 1 callersMethodfinish
sg_agent/thrid_party/thrift/include/async/TEvhttpClientChannel.cpp:117
↓ 1 callersMethodfloodNTest
sg_agent/thrid_party/thrift/include/concurrency/test/ThreadFactoryTests.h:314
↓ 1 callersMethodflush
sg_agent/thrid_party/thrift/include/transport/TZlibTransport.cpp:250
↓ 1 callersMethodfreeContext
* Expected to free resources associated with a context. */
sg_agent/thrid_party/thrift/include/TProcessor.h:56
↓ 1 callersMethodgetAllAppkeys
()
scanner/src/main/java/com/meituan/octo/mns/scanner/service/ProviderScanService.java:82
↓ 1 callersMethodgetAppkeyListByIP
common/gen-cpp/MNSCacheService.cpp:1352
↓ 1 callersMethodgetConfig
()
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/util/ProcessConfig.java:123
↓ 1 callersMethodgetConnectionContext
return the Thrift connection context if any
sg_agent/thrid_party/thrift/include/server/TNonblockingServer.cpp:338
↓ 1 callersMethodgetCurrentThreadId
sg_agent/thrid_party/thrift/include/concurrency/PosixThreadFactory.cpp:331
↓ 1 callersMethodgetDepth
sg_agent/thrid_party/thrift/include/VirtualProfiling.cpp:112
↓ 1 callersMethodgetEventBase
sg_agent/thrid_party/thrift/include/server/TNonblockingServer.h:397
↓ 1 callersMethodgetFrame
sg_agent/thrid_party/thrift/include/VirtualProfiling.cpp:116
↓ 1 callersMethodgetHeaderBodyBuff
(byte[] buffer)
scanner/src/main/java/com/meituan/octo/mns/scanner/util/heartbeat/HeartbeatCodec.java:105
↓ 1 callersFunctiongetHostInfo
sg_agent/src/comm/inc_comm.h:482
↓ 1 callersMethodgetIdcName
()
sdk/mns-invoker/src/test/java/com/meituan/octo/mns/util/ProcessInfoUtilTests.java:180
↓ 1 callersMethodgetIdcPath
()
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/util/ProcessConfig.java:155
↓ 1 callersMethodgetIdleReadBufferLimit
* Get the maximum size of read buffer allocated to idle TConnection objects. * * @return # bytes beyond which we will dealloc idle buffer. */
sg_agent/thrid_party/thrift/include/server/TNonblockingServer.h:610
↓ 1 callersMethodgetIdleWriteBufferLimit
* Get the maximum size of write buffer allocated to idle TConnection objects. * * @return # bytes beyond which we will reallocate buffers when c
sg_agent/thrid_party/thrift/include/server/TNonblockingServer.h:658
↓ 1 callersMethodgetIface
()
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/model/SGAgentClient.java:59
↓ 1 callersMethodgetInputProtocolFactory
sg_agent/thrid_party/thrift/include/server/TServer.h:134
↓ 1 callersMethodgetInputTransportFactory
sg_agent/thrid_party/thrift/include/server/TServer.h:126
↓ 1 callersMethodgetIpMaskValue
()
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/model/IDC.java:85
↓ 1 callersMethodgetIpV4
()
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/util/ProcessInfoUtil.java:81
↓ 1 callersMethodgetJson
(String appkey, String protocol, String ip, String port, int env)
sdk/mns-invoker/src/test/java/com/meituan/octo/mns/util/HttpUtilTests.java:57
↓ 1 callersMethodgetMNSCache
common/gen-cpp/MNSCacheService.cpp:1057
↓ 1 callersMethodgetMNSCacheByAppkeys
common/gen-cpp/MNSCacheService.cpp:1235
↓ 1 callersMethodgetMNSCacheHttp
common/gen-cpp/MNSCacheService.cpp:1117
↓ 1 callersMethodgetMNSCacheWithVersionCheck
common/gen-cpp/MNSCacheService.cpp:1177
↓ 1 callersMethodgetMnsUrl
()
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/util/ProcessConfig.java:151
↓ 1 callersMethodgetMnsZKUrl
()
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/util/ProcessInfoUtil.java:155
↓ 1 callersMethodgetMnsZkUrl
()
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/util/ProcessConfig.java:147
↓ 1 callersMethodgetNext
sg_agent/thrid_party/thrift/include/transport/TFileTransport.cpp:993
↓ 1 callersMethodgetNotificationSendFD
* Get notification pipe send descriptor. * * @return write fd for pipe. */
sg_agent/thrid_party/thrift/include/server/TNonblockingServer.h:759
↓ 1 callersMethodgetOctoEnv
()
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/util/ProcessInfoUtil.java:49
↓ 1 callersMethodgetOriginServiceList
(ProtocolRequest req)
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/MnsInvoker.java:59
↓ 1 callersMethodgetOriginServiceList
(ProtocolRequest req)
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/cache/MnsCacheManager.java:98
↓ 1 callersMethodgetOriginServiceList
common/gen-cpp/ServiceAgent.cpp:873
↓ 1 callersMethodgetOutputProtocolFactory
sg_agent/thrid_party/thrift/include/server/TServer.h:138
↓ 1 callersMethodgetOutputTransportFactory
sg_agent/thrid_party/thrift/include/server/TServer.h:130
↓ 1 callersMethodgetPassword
* Override this method for custom password callback. It may be called * multiple times at any time during a session as necessary. * * @param
sg_agent/thrid_party/thrift/include/transport/TSSLSocket.h:204
↓ 1 callersMethodgetPriority
sg_agent/thrid_party/thrift/include/concurrency/PosixThreadFactory.cpp:323
↓ 1 callersMethodgetProcessor
* Get a TProcessor to handle calls on a particular connection. * * This method should only be called once per connection (never once per * ca
sg_agent/thrid_party/thrift/include/server/TServer.h:262
↓ 1 callersMethodgetProviderJson
(Provider provider)
scanner/src/main/java/com/meituan/octo/mns/scanner/service/ProviderDetectService.java:97
↓ 1 callersMethodgetProviders
(String appkey)
scanner/src/main/java/com/meituan/octo/mns/scanner/service/ProviderScanService.java:92
↓ 1 callersMethodgetProvidersByIP
common/gen-cpp/MNSCacheService.cpp:1294
↓ 1 callersMethodgetReadTimeout
sg_agent/thrid_party/thrift/include/transport/TTransportUtils.cpp:154
↓ 1 callersMethodgetServerEventHandler
return the server event handler if any
sg_agent/thrid_party/thrift/include/server/TNonblockingServer.cpp:333
↓ 1 callersMethodgetServiceFromAgent
(ServiceAgent.Iface client, ProtocolRequest req)
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/cache/ServiceCache.java:187
↓ 1 callersMethodgetServiceFromAgentAndSave
(ProtocolRequest req)
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/cache/ServiceCache.java:88
↓ 1 callersMethodgetServiceList
(@RequestParam("appkey") String appkey, @RequestParam("env") String env,
nsc/src/main/java/com/meituan/octo/mnsc/web/api/ApiController.java:55
↓ 1 callersMethodgetServiceListByProtocol
common/gen-cpp/ServiceAgent.cpp:815
↓ 1 callersMethodgetSgagentAppkey
()
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/util/ProcessConfig.java:163
↓ 1 callersMethodgetSgagentPort
()
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/util/ProcessConfig.java:159
↓ 1 callersMethodgetSgsentinelAppkey
()
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/util/ProcessConfig.java:167
↓ 1 callersMethodgetTargetTransport
sg_agent/thrid_party/thrift/include/transport/TTransportUtils.h:183
↓ 1 callersMethodgetTypeName2
sg_agent/thrid_party/thrift/include/VirtualProfiling.cpp:194
↓ 1 callersMethodgetWritePtr
Returns a pointer to where the client can write data to append to the TMemoryBuffer, and ensures the buffer is big enough to accomodate a write of the
sg_agent/thrid_party/thrift/include/transport/TBufferTransports.h:675
↓ 1 callersMethodhandleAgentIpPort
(String ipPortStr, List<String> errorList)
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/sentinel/CustomizedManager.java:64
↓ 1 callersMethodhandleEvent
* Server socket had something happen. We accept all waiting client * connections on fd and assign TConnection objects to handle those requests. */
sg_agent/thrid_party/thrift/include/server/TNonblockingServer.cpp:920
↓ 1 callersMethodhandleHostEnv
()
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/util/ProcessConfig.java:102
↓ 1 callersMethodhandleIdcInfoFromLocal
(String ip)
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/util/IpUtil.java:186
↓ 1 callersMethodhandleLocalAppkey
(String localAppkey)
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/cache/MnsCacheManager.java:77
↓ 1 callersMethodhandleServiceName
(ProtocolRequest req)
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/cache/ServiceCache.java:151
↓ 1 callersMethodhash
sg_agent/thrid_party/thrift/include/VirtualProfiling.cpp:240
↓ 1 callersMethodhexdigest
return hex representation of digest as string
sg_agent/src/comm/md5.cc:334
↓ 1 callersMethodincrementActiveProcessors
Increment the count of connections currently processing.
sg_agent/thrid_party/thrift/include/server/TNonblockingServer.h:466
↓ 1 callersMethodincrementNumConnections
Increment our count of the number of connected sockets.
sg_agent/thrid_party/thrift/include/server/TNonblockingServer.h:426
↓ 1 callersMethodincrementSgagentHandlers
sg_agent/thrid_party/thrift/include/server/TNonblockingServer.h:417
↓ 1 callersMethodinit
sdk/mns-sdk/src/thrift_client.cc:42
↓ 1 callersMethodinit
()
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/model/IDC.java:36
↓ 1 callersMethodinit
sg_agent/thrid_party/thrift/include/server/TNonblockingServer.cpp:398
↓ 1 callersMethodinitKeyListener
(ProtocolRequest req)
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/cache/ServiceCache.java:241
↓ 1 callersMethodinitSentinels
()
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/sentinel/SentinelManager.java:46
↓ 1 callersMethodinitValueMapHostEnv
()
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/util/ProcessConfig.java:63
↓ 1 callersMethodinitializeTargetTransport
sg_agent/thrid_party/thrift/include/transport/TTransportUtils.h:236
↓ 1 callersMethodinvoke
(Object proxy, Method method, Object[] args)
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/InvokeProxy.java:64
↓ 1 callersMethodisActive
sg_agent/thrid_party/thrift/include/concurrency/ThreadManager.cpp:221
↓ 1 callersMethodisExist
()
sdk/mns-invoker/src/test/java/com/meituan/octo/mns/util/ProcessInfoUtilTests.java:188
↓ 1 callersMethodisFull
sg_agent/thrid_party/thrift/include/transport/TFileTransport.cpp:1018
↓ 1 callersFunctionisJSONNumeric
Return true if the character ch is in [-+0-9.Ee]; false otherwise
sg_agent/thrid_party/thrift/include/protocol/TJSONProtocol.cpp:219
↓ 1 callersMethodisLocal
()
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/model/SGAgentClient.java:76
↓ 1 callersMethodisLocalHostOnline
()
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/util/ProcessInfoUtil.java:134
↓ 1 callersMethodisOpen
sg_agent/thrid_party/thrift/include/transport/TTransportUtils.h:47
↓ 1 callersMethodisServiceDetailEqual
(ServiceDetail detailA, ServiceDetail detailB)
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/cache/ServiceCache.java:395
↓ 1 callersMethodisThreadPoolProcessing
sg_agent/thrid_party/thrift/include/server/TNonblockingServer.h:389
↓ 1 callersMethodisXMDProtocol
(byte[] buffer)
scanner/src/main/java/com/meituan/octo/mns/scanner/util/heartbeat/HeartbeatCodec.java:100
↓ 1 callersMethodlistToString
(List<String> stringList)
sdk/mns-invoker/src/test/java/com/meituan/octo/mns/util/HttpUtilTests.java:69
↓ 1 callersMethodloadConfigFromFile
()
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/util/ProcessConfig.java:74
↓ 1 callersMethodloadIdcTask
()
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/util/IpUtil.java:72
↓ 1 callersMethodlock
sg_agent/thrid_party/logs/log4cplus/include/log4cplus/thread/syncprims.h:262
← previousnext →601–700 of 3,969, ranked by callers