MCPcopy Create free account

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

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

↓ 2 callersMethodgetIdcs
()
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/util/ProcessInfoUtil.java:138
↓ 2 callersMethodgetIntMask
()
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/model/IDC.java:81
↓ 2 callersFunctiongetIntranet
sg_agent/src/comm/inc_comm.h:216
↓ 2 callersMethodgetIp
()
sdk/mns-invoker/src/test/java/com/meituan/octo/mns/util/ProcessInfoUtilTests.java:75
↓ 2 callersMethodgetIp
()
scanner/src/main/java/com/meituan/octo/mns/scanner/model/Provider.java:29
↓ 2 callersMethodgetIpv4Value
(String ip)
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/util/IpUtil.java:153
↓ 2 callersFunctiongetLocalIp
* 获取本机IP * @return 0: success; -1:error */
sg_agent/src/comm/inc_comm.h:186
↓ 2 callersMethodgetMNSCache
common/gen-cpp/MNSCacheService.h:53
↓ 2 callersMethodgetMNSCacheByAppkeys
sg_agent/thrid_party/thrid/include/octoidl/MNSCacheService.h:62
↓ 2 callersMethodgetMNSCacheByAppkeys
common/gen-cpp/MNSCacheService.h:62
↓ 2 callersMethodgetMNSCacheHttp
common/gen-cpp/MNSCacheService.h:56
↓ 2 callersMethodgetMNSCacheWithVersionCheck
sg_agent/thrid_party/thrid/include/octoidl/MNSCacheService.h:59
↓ 2 callersMethodgetMNSCacheWithVersionCheck
common/gen-cpp/MNSCacheService.h:59
↓ 2 callersMethodgetOriginServiceList
sg_agent/thrid_party/thrid/include/octoidl/ServiceAgent.h:55
↓ 2 callersMethodgetOriginServiceList
common/gen-cpp/ServiceAgent.h:55
↓ 2 callersMethodgetPort
()
scanner/src/main/java/com/meituan/octo/mns/scanner/model/Provider.java:37
↓ 2 callersMethodgetProtocol
sg_agent/thrid_party/cthrift/include/cthrift/cthrift_tbinary_protocol.h:281
↓ 2 callersMethodgetProvidersByIP
sg_agent/thrid_party/thrid/include/octoidl/MNSCacheService.h:65
↓ 2 callersMethodgetProvidersByIP
common/gen-cpp/MNSCacheService.h:65
↓ 2 callersMethodgetResizeBufferEveryN
* 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 callersMethodgetRunnable
sg_agent/thrid_party/thrift/include/concurrency/ThreadManager.cpp:188
↓ 2 callersMethodgetSGService
()
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/http/HttpServerPublisher.java:103
↓ 2 callersMethodgetSentinelAgentList
()
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/sentinel/SentinelManager.java:77
↓ 2 callersMethodgetServer
return the server this connection was initialized for.
sg_agent/thrid_party/thrift/include/server/TNonblockingServer.cpp:318
↓ 2 callersMethodgetServiceListByProtocol
sg_agent/thrid_party/thrid/include/octoidl/ServiceAgent.h:52
↓ 2 callersMethodgetServiceListByProtocol
common/gen-cpp/ServiceAgent.h:52
↓ 2 callersMethodgetServiceListByType
(ProtocolRequest req, ServiceCacheType type)
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/cache/MnsCacheManager.java:102
↓ 2 callersMethodgetSgagentAppkey
()
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/util/ProcessInfoUtil.java:171
↓ 2 callersMethodgetSgagentPort
()
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/util/ProcessInfoUtil.java:167
↓ 2 callersMethodgetSocketFD
* Returns the underlying socket file descriptor. */
sg_agent/thrid_party/thrift/include/transport/TSocket.h:200
↓ 2 callersMethodgetState
get state of connection.
sg_agent/thrid_party/thrift/include/server/TNonblockingServer.cpp:323
↓ 2 callersMethodgetTConnection
sg_agent/thrid_party/thrift/include/server/TNonblockingServer.cpp:385
↓ 2 callersMethodgetTSocket
return the TSocket transport wrapping this network connection
sg_agent/thrid_party/thrift/include/server/TNonblockingServer.cpp:328
↓ 2 callersMethodgetWriteBufferDefaultSize
* 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 callersFunctionhexChar
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 callersFunctionhexVal
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 callersMethodinitSocket
(Socket socket)
scanner/src/main/java/com/meituan/octo/mns/scanner/util/SocketDetector.java:69
↓ 2 callersFunctioninit_with_kind
sg_agent/thrid_party/thrift/include/concurrency/Mutex.cpp:198
↓ 2 callersMethodisEnvValid
(String envStr)
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/util/ProcessConfig.java:135
↓ 2 callersMethodisModified
(SGService a, SGService b)
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/cache/ServiceCache.java:363
↓ 2 callersMethodisOpen
sg_agent/thrid_party/thrift/include/transport/TBufferTransports.h:560
↓ 2 callersMethodisSGServiceValid
(SGService service)
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/RegistryManager.java:81
↓ 2 callersMethodisSameNode
(SGService a, SGService b)
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/cache/ServiceCache.java:357
↓ 2 callersMethodisValid
()
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/http/HttpServerPublisher.java:65
↓ 2 callersMethodisValidConfig
()
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/util/ProcessConfig.java:131
↓ 2 callersFunctionjoin
sg_agent/thrid_party/thrift/include/concurrency/PosixThreadFactory.cpp:149
↓ 2 callersMethodloadTest
* 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 callersFunctionmkCommonDirs
sg_agent/src/comm/inc_comm.h:352
↓ 2 callersMethodopen
sg_agent/thrid_party/thrift/include/transport/TBufferTransports.h:568
↓ 2 callersMethodopenConnection
sg_agent/thrid_party/thrift/include/transport/TSocket.cpp:182
↓ 2 callersFunctionparse_hex4
sg_agent/src/comm/cJSON.c:140
↓ 2 callersMethodpendingTaskCount
sg_agent/thrid_party/thrift/include/concurrency/ThreadManager.cpp:98
↓ 2 callersFunctionpoll
sg_agent/thrid_party/thrift/include/windows/config.h:98
↓ 2 callersMethodpretreatServiceListRequest
(ProtocolRequest req)
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/cache/MnsCacheManager.java:85
↓ 2 callersMethodprint
(String msg, List<SGService> list)
sdk/mns-invoker/src/test/java/com/meituan/octo/mns/listener/ServiceListListenerTest.java:69
↓ 2 callersMethodprint
sg_agent/thrid_party/thrift/include/VirtualProfiling.cpp:96
↓ 2 callersFunctionprint_string_ptr
Render the cstring provided to an escaped version that can be printed. */
sg_agent/src/comm/cJSON.c:215
↓ 2 callersFunctionprofile_write_pprof_file
* Write a BacktraceMap as Google CPU profiler binary data. */
sg_agent/thrid_party/thrift/include/VirtualProfiling.cpp:381
↓ 2 callersMethodreadBool
* 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 callersMethodreadI16
sg_agent/thrid_party/thrift/include/protocol/TJSONProtocol.cpp:981
↓ 2 callersMethodreadLine
sg_agent/thrid_party/thrift/include/transport/THttpTransport.cpp:159
↓ 2 callersMethodrefreshIdcData
(List<IDC> idcs)
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/util/IpUtil.java:96
↓ 2 callersMethodregistService
sg_agent/thrid_party/thrid/include/octoidl/ServiceAgent.h:58
↓ 2 callersMethodregistService
common/gen-cpp/ServiceAgent.h:58
↓ 2 callersMethodregistServicewithCmd
sg_agent/thrid_party/thrid/include/octoidl/ServiceAgent.h:62
↓ 2 callersMethodregistServicewithCmd
common/gen-cpp/ServiceAgent.h:62
↓ 2 callersMethodregister
()
sdk/mns-invoker/src/test/java/com/meituan/octo/mns/listener/ServiceListListenerTest.java:147
↓ 2 callersMethodremove
(final ProtocolRequest req, final IServiceListChangeListener listener)
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/cache/ServiceCache.java:258
↓ 2 callersMethodremoveOriginServiceListener
(ProtocolRequest req, IServiceListChangeListener listener)
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/MnsInvoker.java:67
↓ 2 callersMethodremoveServiceListener
(ProtocolRequest req, IServiceListChangeListener listener)
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/MnsInvoker.java:51
↓ 2 callersMethodreturnClient
(SGAgentClient client)
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/sentinel/AgentClientFactory.java:66
↓ 2 callersMethodrun
Allows running the server as a Runnable thread
sg_agent/thrid_party/thrift/include/server/TServer.h:113
↓ 2 callersMethodrun
sg_agent/thrid_party/thrift/include/concurrency/FunctionRunner.h:84
↓ 2 callersFunctionrunnable
sg_agent/thrid_party/thrift/include/concurrency/PosixThreadFactory.cpp:172
↓ 2 callersMethodrunnable
* Gets the runnable object this thread is hosting */
sg_agent/thrid_party/thrift/include/concurrency/Thread.h:104
↓ 2 callersMethodsetCachedAddress
sg_agent/thrid_party/thrift/include/transport/TSocket.cpp:780
↓ 2 callersMethodsetPort
(int port)
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/http/HttpServerPublisher.java:61
↓ 2 callersMethodsetPort
(int port)
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/model/AgentInfo.java:57
↓ 2 callersMethodswap
sg_agent/thrid_party/logs/include/helpers/pointer.h:159
↓ 2 callersMethodswap
sg_agent/thrid_party/logs/log4cplus/include/log4cplus/helpers/pointer.h:159
↓ 2 callersMethodswap
sg_agent/thrid_party/thrift/include/transport/TBufferTransports.h:693
↓ 2 callersMethodtestListener
(ServiceType type)
sdk/mns-invoker/src/test/java/com/meituan/octo/mns/listener/ServiceListListenerTest.java:83
↓ 2 callersMethodtoString
()
scanner/src/main/java/com/meituan/octo/mns/scanner/model/Provider.java:61
↓ 2 callersMethodtotalTaskCount
sg_agent/thrid_party/thrift/include/concurrency/ThreadManager.cpp:103
↓ 2 callersMethodtransition
* 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 callersMethodunRegistService
sg_agent/thrid_party/thrid/include/octoidl/ServiceAgent.h:66
↓ 2 callersMethodunRegistService
common/gen-cpp/ServiceAgent.h:66
↓ 2 callersMethodunlock
sg_agent/thrid_party/logs/include/thread/impl/syncprims-pthreads.h:126
↓ 2 callersMethodunlock
sg_agent/thrid_party/logs/log4cplus/include/log4cplus/thread/impl/syncprims-pthreads.h:126
↓ 2 callersFunctionuppercase
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 callersMethodweakRef
sg_agent/thrid_party/thrift/include/concurrency/BoostThreadFactory.cpp:109
↓ 2 callersMethodwrite
sg_agent/thrid_party/thrift/include/transport/TZlibTransport.cpp:228
↓ 2 callersMethodwrite
* 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 callersMethodwrite
sg_agent/thrid_party/thrift/include/transport/TTransportUtils.cpp:64
↓ 2 callersMethodwriteI16
sg_agent/thrid_party/thrift/include/protocol/TJSONProtocol.cpp:641
↓ 1 callersMethodAccept
sg_agent/src/comm/tinyxml2.cc:612
↓ 1 callersMethodCheckHandler
sg_agent/src/util/thrift_connection.cc:33
↓ 1 callersMethodCheckZkConn
sg_agent/src/mns/zk_client.cc:116
↓ 1 callersMethodClear
sg_agent/src/comm/tinyxml2.h:230
↓ 1 callersMethodCreateThriftClient
sg_agent/src/util/thrift_client.h:45
← previousnext →401–500 of 3,969, ranked by callers