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
↓ 2 callers
Method
getIdcs
()
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/util/ProcessInfoUtil.java:138
↓ 2 callers
Method
getIntMask
()
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/model/IDC.java:81
↓ 2 callers
Function
getIntranet
sg_agent/src/comm/inc_comm.h:216
↓ 2 callers
Method
getIp
()
sdk/mns-invoker/src/test/java/com/meituan/octo/mns/util/ProcessInfoUtilTests.java:75
↓ 2 callers
Method
getIp
()
scanner/src/main/java/com/meituan/octo/mns/scanner/model/Provider.java:29
↓ 2 callers
Method
getIpv4Value
(String ip)
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/util/IpUtil.java:153
↓ 2 callers
Function
getLocalIp
* 获取本机IP * @return 0: success; -1:error */
sg_agent/src/comm/inc_comm.h:186
↓ 2 callers
Method
getMNSCache
common/gen-cpp/MNSCacheService.h:53
↓ 2 callers
Method
getMNSCacheByAppkeys
sg_agent/thrid_party/thrid/include/octoidl/MNSCacheService.h:62
↓ 2 callers
Method
getMNSCacheByAppkeys
common/gen-cpp/MNSCacheService.h:62
↓ 2 callers
Method
getMNSCacheHttp
common/gen-cpp/MNSCacheService.h:56
↓ 2 callers
Method
getMNSCacheWithVersionCheck
sg_agent/thrid_party/thrid/include/octoidl/MNSCacheService.h:59
↓ 2 callers
Method
getMNSCacheWithVersionCheck
common/gen-cpp/MNSCacheService.h:59
↓ 2 callers
Method
getOriginServiceList
sg_agent/thrid_party/thrid/include/octoidl/ServiceAgent.h:55
↓ 2 callers
Method
getOriginServiceList
common/gen-cpp/ServiceAgent.h:55
↓ 2 callers
Method
getPort
()
scanner/src/main/java/com/meituan/octo/mns/scanner/model/Provider.java:37
↓ 2 callers
Method
getProtocol
sg_agent/thrid_party/cthrift/include/cthrift/cthrift_tbinary_protocol.h:281
↓ 2 callers
Method
getProvidersByIP
sg_agent/thrid_party/thrid/include/octoidl/MNSCacheService.h:65
↓ 2 callers
Method
getProvidersByIP
common/gen-cpp/MNSCacheService.h:65
↓ 2 callers
Method
getResizeBufferEveryN
* Get # of calls made between buffer size checks. 0 means disabled. * * @return # of calls between buffer size checks. */
sg_agent/thrid_party/thrift/include/server/TNonblockingServer.h:680
↓ 2 callers
Method
getRunnable
sg_agent/thrid_party/thrift/include/concurrency/ThreadManager.cpp:188
↓ 2 callers
Method
getSGService
()
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/http/HttpServerPublisher.java:103
↓ 2 callers
Method
getSentinelAgentList
()
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/sentinel/SentinelManager.java:77
↓ 2 callers
Method
getServer
return the server this connection was initialized for.
sg_agent/thrid_party/thrift/include/server/TNonblockingServer.cpp:318
↓ 2 callers
Method
getServiceListByProtocol
sg_agent/thrid_party/thrid/include/octoidl/ServiceAgent.h:52
↓ 2 callers
Method
getServiceListByProtocol
common/gen-cpp/ServiceAgent.h:52
↓ 2 callers
Method
getServiceListByType
(ProtocolRequest req, ServiceCacheType type)
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/cache/MnsCacheManager.java:102
↓ 2 callers
Method
getSgagentAppkey
()
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/util/ProcessInfoUtil.java:171
↓ 2 callers
Method
getSgagentPort
()
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/util/ProcessInfoUtil.java:167
↓ 2 callers
Method
getSocketFD
* Returns the underlying socket file descriptor. */
sg_agent/thrid_party/thrift/include/transport/TSocket.h:200
↓ 2 callers
Method
getState
get state of connection.
sg_agent/thrid_party/thrift/include/server/TNonblockingServer.cpp:323
↓ 2 callers
Method
getTConnection
sg_agent/thrid_party/thrift/include/server/TNonblockingServer.cpp:385
↓ 2 callers
Method
getTSocket
return the TSocket transport wrapping this network connection
sg_agent/thrid_party/thrift/include/server/TNonblockingServer.cpp:328
↓ 2 callers
Method
getWriteBufferDefaultSize
* Get the starting size of a TConnection object's write buffer. * * @return # bytes we initialize a TConnection object's write buffer to. */
sg_agent/thrid_party/thrift/include/server/TNonblockingServer.h:592
↓ 2 callers
Function
hexChar
Return the hex character representing the integer val. The value is masked to make sure it is in the correct range.
sg_agent/thrid_party/thrift/include/protocol/TJSONProtocol.cpp:208
↓ 2 callers
Function
hexVal
Return the integer value of a hex character ch. Throw a protocol exception if the character is not [0-9a-f].
sg_agent/thrid_party/thrift/include/protocol/TJSONProtocol.cpp:192
↓ 2 callers
Method
initSocket
(Socket socket)
scanner/src/main/java/com/meituan/octo/mns/scanner/util/SocketDetector.java:69
↓ 2 callers
Function
init_with_kind
sg_agent/thrid_party/thrift/include/concurrency/Mutex.cpp:198
↓ 2 callers
Method
isEnvValid
(String envStr)
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/util/ProcessConfig.java:135
↓ 2 callers
Method
isModified
(SGService a, SGService b)
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/cache/ServiceCache.java:363
↓ 2 callers
Method
isOpen
sg_agent/thrid_party/thrift/include/transport/TBufferTransports.h:560
↓ 2 callers
Method
isSGServiceValid
(SGService service)
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/RegistryManager.java:81
↓ 2 callers
Method
isSameNode
(SGService a, SGService b)
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/cache/ServiceCache.java:357
↓ 2 callers
Method
isValid
()
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/http/HttpServerPublisher.java:65
↓ 2 callers
Method
isValidConfig
()
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/util/ProcessConfig.java:131
↓ 2 callers
Function
join
sg_agent/thrid_party/thrift/include/concurrency/PosixThreadFactory.cpp:149
↓ 2 callers
Method
loadTest
* Dispatch count tasks, each of which blocks for timeout milliseconds then * completes. Verify that all tasks completed and that thread manager cle
sg_agent/thrid_party/thrift/include/concurrency/test/ThreadManagerTests.h:105
↓ 2 callers
Function
mkCommonDirs
sg_agent/src/comm/inc_comm.h:352
↓ 2 callers
Method
open
sg_agent/thrid_party/thrift/include/transport/TBufferTransports.h:568
↓ 2 callers
Method
openConnection
sg_agent/thrid_party/thrift/include/transport/TSocket.cpp:182
↓ 2 callers
Function
parse_hex4
sg_agent/src/comm/cJSON.c:140
↓ 2 callers
Method
pendingTaskCount
sg_agent/thrid_party/thrift/include/concurrency/ThreadManager.cpp:98
↓ 2 callers
Function
poll
sg_agent/thrid_party/thrift/include/windows/config.h:98
↓ 2 callers
Method
pretreatServiceListRequest
(ProtocolRequest req)
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/cache/MnsCacheManager.java:85
↓ 2 callers
Method
print
(String msg, List<SGService> list)
sdk/mns-invoker/src/test/java/com/meituan/octo/mns/listener/ServiceListListenerTest.java:69
↓ 2 callers
Method
print
sg_agent/thrid_party/thrift/include/VirtualProfiling.cpp:96
↓ 2 callers
Function
print_string_ptr
Render the cstring provided to an escaped version that can be printed. */
sg_agent/src/comm/cJSON.c:215
↓ 2 callers
Function
profile_write_pprof_file
* Write a BacktraceMap as Google CPU profiler binary data. */
sg_agent/thrid_party/thrift/include/VirtualProfiling.cpp:381
↓ 2 callers
Method
readBool
* Provide a default readBool() implementation for use with * std::vector<bool>, that behaves the same as reading into a normal bool. * * Subc
sg_agent/thrid_party/thrift/include/protocol/TVirtualProtocol.h:548
↓ 2 callers
Method
readI16
sg_agent/thrid_party/thrift/include/protocol/TJSONProtocol.cpp:981
↓ 2 callers
Method
readLine
sg_agent/thrid_party/thrift/include/transport/THttpTransport.cpp:159
↓ 2 callers
Method
refreshIdcData
(List<IDC> idcs)
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/util/IpUtil.java:96
↓ 2 callers
Method
registService
sg_agent/thrid_party/thrid/include/octoidl/ServiceAgent.h:58
↓ 2 callers
Method
registService
common/gen-cpp/ServiceAgent.h:58
↓ 2 callers
Method
registServicewithCmd
sg_agent/thrid_party/thrid/include/octoidl/ServiceAgent.h:62
↓ 2 callers
Method
registServicewithCmd
common/gen-cpp/ServiceAgent.h:62
↓ 2 callers
Method
register
()
sdk/mns-invoker/src/test/java/com/meituan/octo/mns/listener/ServiceListListenerTest.java:147
↓ 2 callers
Method
remove
(final ProtocolRequest req, final IServiceListChangeListener listener)
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/cache/ServiceCache.java:258
↓ 2 callers
Method
removeOriginServiceListener
(ProtocolRequest req, IServiceListChangeListener listener)
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/MnsInvoker.java:67
↓ 2 callers
Method
removeServiceListener
(ProtocolRequest req, IServiceListChangeListener listener)
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/MnsInvoker.java:51
↓ 2 callers
Method
returnClient
(SGAgentClient client)
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/sentinel/AgentClientFactory.java:66
↓ 2 callers
Method
run
Allows running the server as a Runnable thread
sg_agent/thrid_party/thrift/include/server/TServer.h:113
↓ 2 callers
Method
run
sg_agent/thrid_party/thrift/include/concurrency/FunctionRunner.h:84
↓ 2 callers
Function
runnable
sg_agent/thrid_party/thrift/include/concurrency/PosixThreadFactory.cpp:172
↓ 2 callers
Method
runnable
* Gets the runnable object this thread is hosting */
sg_agent/thrid_party/thrift/include/concurrency/Thread.h:104
↓ 2 callers
Method
setCachedAddress
sg_agent/thrid_party/thrift/include/transport/TSocket.cpp:780
↓ 2 callers
Method
setPort
(int port)
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/http/HttpServerPublisher.java:61
↓ 2 callers
Method
setPort
(int port)
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/model/AgentInfo.java:57
↓ 2 callers
Method
swap
sg_agent/thrid_party/logs/include/helpers/pointer.h:159
↓ 2 callers
Method
swap
sg_agent/thrid_party/logs/log4cplus/include/log4cplus/helpers/pointer.h:159
↓ 2 callers
Method
swap
sg_agent/thrid_party/thrift/include/transport/TBufferTransports.h:693
↓ 2 callers
Method
testListener
(ServiceType type)
sdk/mns-invoker/src/test/java/com/meituan/octo/mns/listener/ServiceListListenerTest.java:83
↓ 2 callers
Method
toString
()
scanner/src/main/java/com/meituan/octo/mns/scanner/model/Provider.java:61
↓ 2 callers
Method
totalTaskCount
sg_agent/thrid_party/thrift/include/concurrency/ThreadManager.cpp:103
↓ 2 callers
Method
transition
* This is called when the application transitions from one state into * another. This means that it has finished writing the data that it needed * t
sg_agent/thrid_party/thrift/include/server/TNonblockingServer.cpp:570
↓ 2 callers
Method
unRegistService
sg_agent/thrid_party/thrid/include/octoidl/ServiceAgent.h:66
↓ 2 callers
Method
unRegistService
common/gen-cpp/ServiceAgent.h:66
↓ 2 callers
Method
unlock
sg_agent/thrid_party/logs/include/thread/impl/syncprims-pthreads.h:126
↓ 2 callers
Method
unlock
sg_agent/thrid_party/logs/log4cplus/include/log4cplus/thread/impl/syncprims-pthreads.h:126
↓ 2 callers
Function
uppercase
This is to work around the Turkish locale issue, i.e., toupper('i') != toupper('I') if locale is "tr_TR"
sg_agent/thrid_party/thrift/include/transport/TSSLSocket.cpp:663
↓ 2 callers
Method
weakRef
sg_agent/thrid_party/thrift/include/concurrency/BoostThreadFactory.cpp:109
↓ 2 callers
Method
write
sg_agent/thrid_party/thrift/include/transport/TZlibTransport.cpp:228
↓ 2 callers
Method
write
* Fast-path write. * * When we have enough empty space in our buffer to accomodate the write, we * can satisfy it with a single memcpy, then
sg_agent/thrid_party/thrift/include/transport/TBufferTransports.h:94
↓ 2 callers
Method
write
sg_agent/thrid_party/thrift/include/transport/TTransportUtils.cpp:64
↓ 2 callers
Method
writeI16
sg_agent/thrid_party/thrift/include/protocol/TJSONProtocol.cpp:641
↓ 1 callers
Method
Accept
sg_agent/src/comm/tinyxml2.cc:612
↓ 1 callers
Method
CheckHandler
sg_agent/src/util/thrift_connection.cc:33
↓ 1 callers
Method
CheckZkConn
sg_agent/src/mns/zk_client.cc:116
↓ 1 callers
Method
Clear
sg_agent/src/comm/tinyxml2.h:230
↓ 1 callers
Method
CreateThriftClient
sg_agent/src/util/thrift_client.h:45
← previous
next →
401–500 of 3,969, ranked by callers