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
Method
attemptWrite
sg_agent/thrid_party/thrift/include/concurrency/Mutex.cpp:298
Method
authenticate
sg_agent/thrid_party/thrift/include/transport/TSSLSocket.cpp:412
Method
authorize
sg_agent/thrid_party/thrift/include/transport/TSSLSocket.cpp:241
Method
available_write
sg_agent/thrid_party/thrift/include/transport/TBufferTransports.h:666
Function
bitwise_cast
sg_agent/thrid_party/thrift/include/protocol/TProtocol.h:46
Method
borrow
sg_agent/thrid_party/thrift/include/transport/TShortReadTransport.h:78
Method
borrow
* Fast-path borrow. A lot like the fast-path read. */
sg_agent/thrid_party/thrift/include/transport/TBufferTransports.h:107
Method
borrow
* Attempts to return a pointer to \c len bytes, possibly copied into \c buf. * Does not consume the bytes read (i.e.: a later read will return the
sg_agent/thrid_party/thrift/include/transport/TTransport.h:214
Method
borrowSlow
sg_agent/thrid_party/thrift/include/transport/TBufferTransports.cpp:111
Method
borrow_virt
sg_agent/thrid_party/thrift/include/transport/TVirtualTransport.h:106
Method
borrow_virt
sg_agent/thrid_party/thrift/include/transport/TTransport.h:218
Function
cJSON_AddItemReferenceToArray
sg_agent/src/comm/cJSON.c:522
Function
cJSON_AddItemReferenceToObject
sg_agent/src/comm/cJSON.c:523
Function
cJSON_CreateBool
sg_agent/src/comm/cJSON.c:541
Function
cJSON_CreateDoubleArray
sg_agent/src/comm/cJSON.c:550
Function
cJSON_CreateFalse
sg_agent/src/comm/cJSON.c:540
Function
cJSON_CreateFloatArray
sg_agent/src/comm/cJSON.c:549
Function
cJSON_CreateIntArray
Create Arrays: */
sg_agent/src/comm/cJSON.c:548
Function
cJSON_CreateNull
Create basic types: */
sg_agent/src/comm/cJSON.c:538
Function
cJSON_CreateStringArray
sg_agent/src/comm/cJSON.c:551
Function
cJSON_CreateTrue
sg_agent/src/comm/cJSON.c:539
Function
cJSON_DeleteItemFromArray
sg_agent/src/comm/cJSON.c:527
Function
cJSON_DeleteItemFromObject
sg_agent/src/comm/cJSON.c:529
Function
cJSON_Duplicate
Duplication */
sg_agent/src/comm/cJSON.c:554
Function
cJSON_GetErrorPtr
sg_agent/src/comm/cJSON.c:37
Function
cJSON_InitHooks
sg_agent/src/comm/cJSON.c:60
Function
cJSON_Minify
sg_agent/src/comm/cJSON.c:581
Function
cJSON_PrintUnformatted
sg_agent/src/comm/cJSON.c:284
Function
cJSON_ReplaceItemInObject
sg_agent/src/comm/cJSON.c:535
Method
cJson_AddServiceObject
sg_agent/src/util/json_data_tools.cc:460
Method
cJson_AddStringArray
sg_agent/src/util/json_data_tools.cc:443
Function
callbackLocking
sg_agent/thrid_party/thrift/include/transport/TSSLSocket.cpp:493
Function
callbackThreadID
sg_agent/thrid_party/thrift/include/transport/TSSLSocket.cpp:502
Method
canSleep
sg_agent/thrid_party/thrift/include/concurrency/ThreadManager.cpp:455
Method
changed
(ProtocolRequest req, List<SGService> oldList, List<SGService> newList, List<SGService> addList, List<SGServic
sdk/mns-invoker/src/test/java/com/meituan/octo/mns/listener/ServiceListListenerTest.java:54
Method
channelRead0
(ChannelHandlerContext channelHandlerContext, Header header)
scanner/src/main/java/com/meituan/octo/mns/scanner/util/heartbeat/HeartbeatHandler.java:34
Method
checkConnection
check连接
sdk/mns-sdk/src/thrift_client.cc:97
Method
checkEnv
()
sdk/mns-invoker/src/test/java/com/meituan/octo/mns/util/ProcessConfigTests.java:56
Method
checkHandler
check handler对应的连接是否可用
sdk/mns-sdk/src/thrift_client.cc:156
Method
checkHandshake
sg_agent/thrid_party/thrift/include/transport/TSSLSocket.cpp:216
Method
checkTType
* Checks that @c ttype is indeed the ttype that we should be writing, * according to our typespec. Aborts if the test fails and debugging in on. */
sg_agent/thrid_party/thrift/include/protocol/TDenseProtocol.cpp:142
Method
checkZlibRv
sg_agent/thrid_party/thrift/include/transport/TZlibTransport.cpp:75
Method
checkZlibRvNothrow
sg_agent/thrid_party/thrift/include/transport/TZlibTransport.cpp:81
Method
ciphers
sg_agent/thrid_party/thrift/include/transport/TSSLSocket.cpp:400
Method
cleanup
* Clean up memory allocated by makePersistent() * * Should only be invoked if makePersistent() has previously been called. * The Key should n
sg_agent/thrid_party/thrift/include/VirtualProfiling.cpp:214
Method
cleanup
sg_agent/thrid_party/thrift/include/concurrency/Monitor.cpp:163
Method
cleanupOpenSSL
sg_agent/thrid_party/thrift/include/transport/TSSLSocket.cpp:551
Method
clearCache
()
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/cache/ServiceCache.java:134
Method
clearCache
()
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/cache/MnsCacheManager.java:138
Method
clientPortConfig
()
sdk/mns-invoker/src/test/java/com/meituan/octo/mns/SocketClientPortTests.java:35
Method
close
sg_agent/thrid_party/thrift/include/transport/THttpTransport.h:53
Method
close
sg_agent/thrid_party/thrift/include/transport/TFDTransport.cpp:37
Method
close
sg_agent/thrid_party/thrift/include/transport/TZlibTransport.h:152
Method
close
sg_agent/thrid_party/thrift/include/transport/TShortReadTransport.h:55
Method
close
sg_agent/thrid_party/thrift/include/transport/TTransportUtils.h:137
Method
close
sg_agent/thrid_party/thrift/include/transport/TSocketPool.cpp:245
Method
close
sg_agent/thrid_party/thrift/include/transport/TBufferTransports.h:245
Method
close
sg_agent/thrid_party/thrift/include/transport/TBufferTransports.h:364
Method
close
sg_agent/thrid_party/thrift/include/transport/TTransportUtils.cpp:115
Method
close
sg_agent/thrid_party/thrift/include/transport/TSSLSocket.cpp:143
Method
close
sg_agent/thrid_party/thrift/include/transport/TServerSocket.cpp:466
Method
close
* Closes the transport. */
sg_agent/thrid_party/thrift/include/transport/TTransport.h:95
Method
cmp
sg_agent/thrid_party/thrift/include/VirtualProfiling.cpp:79
Method
cmp
sg_agent/thrid_party/thrift/include/VirtualProfiling.cpp:219
Method
complete
sg_agent/thrid_party/thrift/include/async/TEvhttpServer.cpp:129
Method
completed__
sg_agent/thrid_party/cthrift/include/cthrift/Echo.h:322
Method
computeRead
sg_agent/thrid_party/thrift/include/transport/TBufferTransports.cpp:280
Function
const_cast_sockopt
sg_agent/thrid_party/thrift/include/transport/TServerSocket.cpp:64
Method
consume
sg_agent/thrid_party/thrift/include/transport/TShortReadTransport.h:82
Method
consume
* Consume doesn't require a slow path. */
sg_agent/thrid_party/thrift/include/transport/TBufferTransports.h:120
Method
consume
* Remove len bytes from the transport. This should always follow a borrow * of at least len bytes, and should always succeed. * TODO(dreiss): I
sg_agent/thrid_party/thrift/include/transport/TTransport.h:231
Method
consume_virt
sg_agent/thrid_party/thrift/include/transport/TVirtualTransport.h:110
Method
consume_virt
sg_agent/thrid_party/thrift/include/transport/TTransport.h:235
Method
contains
(R row, C column)
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/cache/MultiMap.java:87
Function
convertIntegerToString
sg_agent/thrid_party/logs/include/helpers/stringhelper.h:155
Function
convertIntegerToString
sg_agent/thrid_party/logs/log4cplus/include/log4cplus/helpers/stringhelper.h:155
Method
cpu_util
sg_agent/src/remote/monitor/monitor_collector.h:41
Method
create
()
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/cache/MnsCache.java:34
Method
createConnection
创建连接
sdk/mns-sdk/src/thrift_client.cc:104
Method
createConnection
* Creates a new connection either by reusing an object off the stack or * by allocating a new one entirely */
sg_agent/thrid_party/thrift/include/server/TNonblockingServer.cpp:888
Method
createNotificationPipe
sg_agent/thrid_party/thrift/include/server/TNonblockingServer.cpp:1095
Method
createObject
sg_agent/thrid_party/logs/include/spi/factory.h:240
Method
createObject
sg_agent/thrid_party/logs/log4cplus/include/log4cplus/spi/factory.h:240
Method
createSocket
sg_agent/thrid_party/thrift/include/transport/TSSLSocket.cpp:371
Method
createSocket
sg_agent/thrid_party/thrift/include/transport/TSSLServerSocket.cpp:43
Method
createSocket
sg_agent/thrid_party/thrift/include/transport/TServerSocket.cpp:453
Method
curatorFramework
(@Value("${zookeeper.url}") String zkUrl)
scanner/src/main/java/com/meituan/octo/mns/scanner/configuration/CuratorConfiguration.java:28
Method
currentTime
* Get current time as milliseconds from epoch */
sg_agent/thrid_party/thrift/include/concurrency/Util.h:140
Method
currentTimeTicks
sg_agent/thrid_party/thrift/include/concurrency/Util.cpp:34
Method
currentTimeUsec
* Get current time as micros from epoch */
sg_agent/thrid_party/thrift/include/concurrency/Util.h:145
Method
deadCheckExecutor
(@Value("${executor.dead.threadCount}") int threadCount)
scanner/src/main/java/com/meituan/octo/mns/scanner/configuration/ExecutorConfiguration.java:34
Method
decode
(ChannelHandlerContext channelHandlerContext, ByteBuf byteBuf, List<Object> list)
scanner/src/main/java/com/meituan/octo/mns/scanner/util/heartbeat/HeartbeatCodec.java:61
Method
decode
decodes input (unsigned char) into output (uint4). Assumes len is a multiple of 4.
sg_agent/src/comm/md5.cc:136
Method
del
sg_agent/src/comm/buffer_mgr.h:162
Method
delayException
sg_agent/thrid_party/thrift/include/Thrift.h:195
Method
delete
(String remoteAppkey, String protocol, String ipPort)
sdk/mns-invoker/src/test/java/com/meituan/octo/mns/cache/getServerTests.java:95
Method
deletePostProviders
(@RequestBody List<SGService> providers)
nsc/src/main/java/com/meituan/octo/mnsc/web/api/ProvidersController.java:89
Method
destroy
()
sdk/mns-invoker/src/test/java/com/meituan/octo/mns/listener/ServiceListListenerTest.java:166
Method
destroy
()
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/http/HttpServerPublisher.java:89
Method
doGetServiceList
(ServiceAgent.Iface client, ProtocolRequest req)
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/cache/OriginServiceCache.java:32
← previous
next →
2,201–2,300 of 3,969, ranked by callers