Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/Meituan-Dianping/octo-ns
/ functions
Functions
3,969 in github.com/Meituan-Dianping/octo-ns
⨍
Functions
3,969
◇
Types & classes
1,259
↓ 1 callers
Method
create
------------------------------------------------------------------------------
sg_agent/thrid_party/thrift/include/windows/TWinsockSingleton.cpp:52
↓ 1 callers
Method
createSSL
sg_agent/thrid_party/thrift/include/transport/TSSLSocket.cpp:76
↓ 1 callers
Method
decodeXMDHeader
(byte[] headerBytes)
scanner/src/main/java/com/meituan/octo/mns/scanner/util/heartbeat/HeartbeatCodec.java:93
↓ 1 callers
Method
decrementNumConnections
Decrement our count of the number of connected sockets.
sg_agent/thrid_party/thrift/include/server/TNonblockingServer.h:431
↓ 1 callers
Method
deleteProviders
(@RequestBody List<SGService> providers)
nsc/src/main/java/com/meituan/octo/mnsc/web/api/ProvidersController.java:83
↓ 1 callers
Method
detect
(long round, Provider provider)
scanner/src/main/java/com/meituan/octo/mns/scanner/service/ProviderDetectService.java:54
↓ 1 callers
Method
detect
(String ip, int port)
scanner/src/main/java/com/meituan/octo/mns/scanner/util/SocketDetector.java:31
↓ 1 callers
Method
detect
(String ip, int port)
scanner/src/main/java/com/meituan/octo/mns/scanner/util/heartbeat/HeartbeatClient.java:59
↓ 1 callers
Method
detect
(String ip, int port)
scanner/src/main/java/com/meituan/octo/mns/scanner/util/heartbeat/HeartbeatDetector.java:20
↓ 1 callers
Method
detectAgain
(String ip, int port)
scanner/src/main/java/com/meituan/octo/mns/scanner/util/SocketDetector.java:51
↓ 1 callers
Method
finish
sg_agent/thrid_party/thrift/include/async/TEvhttpClientChannel.cpp:117
↓ 1 callers
Method
floodNTest
sg_agent/thrid_party/thrift/include/concurrency/test/ThreadFactoryTests.h:314
↓ 1 callers
Method
flush
sg_agent/thrid_party/thrift/include/transport/TZlibTransport.cpp:250
↓ 1 callers
Method
freeContext
* Expected to free resources associated with a context. */
sg_agent/thrid_party/thrift/include/TProcessor.h:56
↓ 1 callers
Method
getAllAppkeys
()
scanner/src/main/java/com/meituan/octo/mns/scanner/service/ProviderScanService.java:82
↓ 1 callers
Method
getAppkeyListByIP
common/gen-cpp/MNSCacheService.cpp:1352
↓ 1 callers
Method
getConfig
()
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/util/ProcessConfig.java:123
↓ 1 callers
Method
getConnectionContext
return the Thrift connection context if any
sg_agent/thrid_party/thrift/include/server/TNonblockingServer.cpp:338
↓ 1 callers
Method
getCurrentThreadId
sg_agent/thrid_party/thrift/include/concurrency/PosixThreadFactory.cpp:331
↓ 1 callers
Method
getDepth
sg_agent/thrid_party/thrift/include/VirtualProfiling.cpp:112
↓ 1 callers
Method
getEventBase
sg_agent/thrid_party/thrift/include/server/TNonblockingServer.h:397
↓ 1 callers
Method
getFrame
sg_agent/thrid_party/thrift/include/VirtualProfiling.cpp:116
↓ 1 callers
Method
getHeaderBodyBuff
(byte[] buffer)
scanner/src/main/java/com/meituan/octo/mns/scanner/util/heartbeat/HeartbeatCodec.java:105
↓ 1 callers
Function
getHostInfo
sg_agent/src/comm/inc_comm.h:482
↓ 1 callers
Method
getIdcName
()
sdk/mns-invoker/src/test/java/com/meituan/octo/mns/util/ProcessInfoUtilTests.java:180
↓ 1 callers
Method
getIdcPath
()
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/util/ProcessConfig.java:155
↓ 1 callers
Method
getIdleReadBufferLimit
* 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 callers
Method
getIdleWriteBufferLimit
* 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 callers
Method
getIface
()
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/model/SGAgentClient.java:59
↓ 1 callers
Method
getInputProtocolFactory
sg_agent/thrid_party/thrift/include/server/TServer.h:134
↓ 1 callers
Method
getInputTransportFactory
sg_agent/thrid_party/thrift/include/server/TServer.h:126
↓ 1 callers
Method
getIpMaskValue
()
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/model/IDC.java:85
↓ 1 callers
Method
getIpV4
()
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/util/ProcessInfoUtil.java:81
↓ 1 callers
Method
getJson
(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 callers
Method
getMNSCache
common/gen-cpp/MNSCacheService.cpp:1057
↓ 1 callers
Method
getMNSCacheByAppkeys
common/gen-cpp/MNSCacheService.cpp:1235
↓ 1 callers
Method
getMNSCacheHttp
common/gen-cpp/MNSCacheService.cpp:1117
↓ 1 callers
Method
getMNSCacheWithVersionCheck
common/gen-cpp/MNSCacheService.cpp:1177
↓ 1 callers
Method
getMnsUrl
()
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/util/ProcessConfig.java:151
↓ 1 callers
Method
getMnsZKUrl
()
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/util/ProcessInfoUtil.java:155
↓ 1 callers
Method
getMnsZkUrl
()
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/util/ProcessConfig.java:147
↓ 1 callers
Method
getNext
sg_agent/thrid_party/thrift/include/transport/TFileTransport.cpp:993
↓ 1 callers
Method
getNotificationSendFD
* Get notification pipe send descriptor. * * @return write fd for pipe. */
sg_agent/thrid_party/thrift/include/server/TNonblockingServer.h:759
↓ 1 callers
Method
getOctoEnv
()
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/util/ProcessInfoUtil.java:49
↓ 1 callers
Method
getOriginServiceList
(ProtocolRequest req)
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/MnsInvoker.java:59
↓ 1 callers
Method
getOriginServiceList
(ProtocolRequest req)
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/cache/MnsCacheManager.java:98
↓ 1 callers
Method
getOriginServiceList
common/gen-cpp/ServiceAgent.cpp:873
↓ 1 callers
Method
getOutputProtocolFactory
sg_agent/thrid_party/thrift/include/server/TServer.h:138
↓ 1 callers
Method
getOutputTransportFactory
sg_agent/thrid_party/thrift/include/server/TServer.h:130
↓ 1 callers
Method
getPassword
* 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 callers
Method
getPriority
sg_agent/thrid_party/thrift/include/concurrency/PosixThreadFactory.cpp:323
↓ 1 callers
Method
getProcessor
* 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 callers
Method
getProviderJson
(Provider provider)
scanner/src/main/java/com/meituan/octo/mns/scanner/service/ProviderDetectService.java:97
↓ 1 callers
Method
getProviders
(String appkey)
scanner/src/main/java/com/meituan/octo/mns/scanner/service/ProviderScanService.java:92
↓ 1 callers
Method
getProvidersByIP
common/gen-cpp/MNSCacheService.cpp:1294
↓ 1 callers
Method
getReadTimeout
sg_agent/thrid_party/thrift/include/transport/TTransportUtils.cpp:154
↓ 1 callers
Method
getServerEventHandler
return the server event handler if any
sg_agent/thrid_party/thrift/include/server/TNonblockingServer.cpp:333
↓ 1 callers
Method
getServiceFromAgent
(ServiceAgent.Iface client, ProtocolRequest req)
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/cache/ServiceCache.java:187
↓ 1 callers
Method
getServiceFromAgentAndSave
(ProtocolRequest req)
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/cache/ServiceCache.java:88
↓ 1 callers
Method
getServiceList
(@RequestParam("appkey") String appkey, @RequestParam("env") String env,
nsc/src/main/java/com/meituan/octo/mnsc/web/api/ApiController.java:55
↓ 1 callers
Method
getServiceListByProtocol
common/gen-cpp/ServiceAgent.cpp:815
↓ 1 callers
Method
getSgagentAppkey
()
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/util/ProcessConfig.java:163
↓ 1 callers
Method
getSgagentPort
()
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/util/ProcessConfig.java:159
↓ 1 callers
Method
getSgsentinelAppkey
()
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/util/ProcessConfig.java:167
↓ 1 callers
Method
getTargetTransport
sg_agent/thrid_party/thrift/include/transport/TTransportUtils.h:183
↓ 1 callers
Method
getTypeName2
sg_agent/thrid_party/thrift/include/VirtualProfiling.cpp:194
↓ 1 callers
Method
getWritePtr
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 callers
Method
handleAgentIpPort
(String ipPortStr, List<String> errorList)
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/sentinel/CustomizedManager.java:64
↓ 1 callers
Method
handleEvent
* 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 callers
Method
handleHostEnv
()
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/util/ProcessConfig.java:102
↓ 1 callers
Method
handleIdcInfoFromLocal
(String ip)
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/util/IpUtil.java:186
↓ 1 callers
Method
handleLocalAppkey
(String localAppkey)
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/cache/MnsCacheManager.java:77
↓ 1 callers
Method
handleServiceName
(ProtocolRequest req)
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/cache/ServiceCache.java:151
↓ 1 callers
Method
hash
sg_agent/thrid_party/thrift/include/VirtualProfiling.cpp:240
↓ 1 callers
Method
hexdigest
return hex representation of digest as string
sg_agent/src/comm/md5.cc:334
↓ 1 callers
Method
incrementActiveProcessors
Increment the count of connections currently processing.
sg_agent/thrid_party/thrift/include/server/TNonblockingServer.h:466
↓ 1 callers
Method
incrementNumConnections
Increment our count of the number of connected sockets.
sg_agent/thrid_party/thrift/include/server/TNonblockingServer.h:426
↓ 1 callers
Method
incrementSgagentHandlers
sg_agent/thrid_party/thrift/include/server/TNonblockingServer.h:417
↓ 1 callers
Method
init
sdk/mns-sdk/src/thrift_client.cc:42
↓ 1 callers
Method
init
()
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/model/IDC.java:36
↓ 1 callers
Method
init
sg_agent/thrid_party/thrift/include/server/TNonblockingServer.cpp:398
↓ 1 callers
Method
initKeyListener
(ProtocolRequest req)
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/cache/ServiceCache.java:241
↓ 1 callers
Method
initSentinels
()
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/sentinel/SentinelManager.java:46
↓ 1 callers
Method
initValueMapHostEnv
()
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/util/ProcessConfig.java:63
↓ 1 callers
Method
initializeTargetTransport
sg_agent/thrid_party/thrift/include/transport/TTransportUtils.h:236
↓ 1 callers
Method
invoke
(Object proxy, Method method, Object[] args)
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/InvokeProxy.java:64
↓ 1 callers
Method
isActive
sg_agent/thrid_party/thrift/include/concurrency/ThreadManager.cpp:221
↓ 1 callers
Method
isExist
()
sdk/mns-invoker/src/test/java/com/meituan/octo/mns/util/ProcessInfoUtilTests.java:188
↓ 1 callers
Method
isFull
sg_agent/thrid_party/thrift/include/transport/TFileTransport.cpp:1018
↓ 1 callers
Function
isJSONNumeric
Return true if the character ch is in [-+0-9.Ee]; false otherwise
sg_agent/thrid_party/thrift/include/protocol/TJSONProtocol.cpp:219
↓ 1 callers
Method
isLocal
()
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/model/SGAgentClient.java:76
↓ 1 callers
Method
isLocalHostOnline
()
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/util/ProcessInfoUtil.java:134
↓ 1 callers
Method
isOpen
sg_agent/thrid_party/thrift/include/transport/TTransportUtils.h:47
↓ 1 callers
Method
isServiceDetailEqual
(ServiceDetail detailA, ServiceDetail detailB)
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/cache/ServiceCache.java:395
↓ 1 callers
Method
isThreadPoolProcessing
sg_agent/thrid_party/thrift/include/server/TNonblockingServer.h:389
↓ 1 callers
Method
isXMDProtocol
(byte[] buffer)
scanner/src/main/java/com/meituan/octo/mns/scanner/util/heartbeat/HeartbeatCodec.java:100
↓ 1 callers
Method
listToString
(List<String> stringList)
sdk/mns-invoker/src/test/java/com/meituan/octo/mns/util/HttpUtilTests.java:69
↓ 1 callers
Method
loadConfigFromFile
()
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/util/ProcessConfig.java:74
↓ 1 callers
Method
loadIdcTask
()
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/util/IpUtil.java:72
↓ 1 callers
Method
lock
sg_agent/thrid_party/logs/log4cplus/include/log4cplus/thread/syncprims.h:262
← previous
next →
601–700 of 3,969, ranked by callers