MCPcopy Create free account

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

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

MethodattemptWrite
sg_agent/thrid_party/thrift/include/concurrency/Mutex.cpp:298
Methodauthenticate
sg_agent/thrid_party/thrift/include/transport/TSSLSocket.cpp:412
Methodauthorize
sg_agent/thrid_party/thrift/include/transport/TSSLSocket.cpp:241
Methodavailable_write
sg_agent/thrid_party/thrift/include/transport/TBufferTransports.h:666
Functionbitwise_cast
sg_agent/thrid_party/thrift/include/protocol/TProtocol.h:46
Methodborrow
sg_agent/thrid_party/thrift/include/transport/TShortReadTransport.h:78
Methodborrow
* Fast-path borrow. A lot like the fast-path read. */
sg_agent/thrid_party/thrift/include/transport/TBufferTransports.h:107
Methodborrow
* 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
MethodborrowSlow
sg_agent/thrid_party/thrift/include/transport/TBufferTransports.cpp:111
Methodborrow_virt
sg_agent/thrid_party/thrift/include/transport/TVirtualTransport.h:106
Methodborrow_virt
sg_agent/thrid_party/thrift/include/transport/TTransport.h:218
FunctioncJSON_AddItemReferenceToArray
sg_agent/src/comm/cJSON.c:522
FunctioncJSON_AddItemReferenceToObject
sg_agent/src/comm/cJSON.c:523
FunctioncJSON_CreateBool
sg_agent/src/comm/cJSON.c:541
FunctioncJSON_CreateDoubleArray
sg_agent/src/comm/cJSON.c:550
FunctioncJSON_CreateFalse
sg_agent/src/comm/cJSON.c:540
FunctioncJSON_CreateFloatArray
sg_agent/src/comm/cJSON.c:549
FunctioncJSON_CreateIntArray
Create Arrays: */
sg_agent/src/comm/cJSON.c:548
FunctioncJSON_CreateNull
Create basic types: */
sg_agent/src/comm/cJSON.c:538
FunctioncJSON_CreateStringArray
sg_agent/src/comm/cJSON.c:551
FunctioncJSON_CreateTrue
sg_agent/src/comm/cJSON.c:539
FunctioncJSON_DeleteItemFromArray
sg_agent/src/comm/cJSON.c:527
FunctioncJSON_DeleteItemFromObject
sg_agent/src/comm/cJSON.c:529
FunctioncJSON_Duplicate
Duplication */
sg_agent/src/comm/cJSON.c:554
FunctioncJSON_GetErrorPtr
sg_agent/src/comm/cJSON.c:37
FunctioncJSON_InitHooks
sg_agent/src/comm/cJSON.c:60
FunctioncJSON_Minify
sg_agent/src/comm/cJSON.c:581
FunctioncJSON_PrintUnformatted
sg_agent/src/comm/cJSON.c:284
FunctioncJSON_ReplaceItemInObject
sg_agent/src/comm/cJSON.c:535
MethodcJson_AddServiceObject
sg_agent/src/util/json_data_tools.cc:460
MethodcJson_AddStringArray
sg_agent/src/util/json_data_tools.cc:443
FunctioncallbackLocking
sg_agent/thrid_party/thrift/include/transport/TSSLSocket.cpp:493
FunctioncallbackThreadID
sg_agent/thrid_party/thrift/include/transport/TSSLSocket.cpp:502
MethodcanSleep
sg_agent/thrid_party/thrift/include/concurrency/ThreadManager.cpp:455
Methodchanged
(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
MethodchannelRead0
(ChannelHandlerContext channelHandlerContext, Header header)
scanner/src/main/java/com/meituan/octo/mns/scanner/util/heartbeat/HeartbeatHandler.java:34
MethodcheckConnection
check连接
sdk/mns-sdk/src/thrift_client.cc:97
MethodcheckEnv
()
sdk/mns-invoker/src/test/java/com/meituan/octo/mns/util/ProcessConfigTests.java:56
MethodcheckHandler
check handler对应的连接是否可用
sdk/mns-sdk/src/thrift_client.cc:156
MethodcheckHandshake
sg_agent/thrid_party/thrift/include/transport/TSSLSocket.cpp:216
MethodcheckTType
* 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
MethodcheckZlibRv
sg_agent/thrid_party/thrift/include/transport/TZlibTransport.cpp:75
MethodcheckZlibRvNothrow
sg_agent/thrid_party/thrift/include/transport/TZlibTransport.cpp:81
Methodciphers
sg_agent/thrid_party/thrift/include/transport/TSSLSocket.cpp:400
Methodcleanup
* 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
Methodcleanup
sg_agent/thrid_party/thrift/include/concurrency/Monitor.cpp:163
MethodcleanupOpenSSL
sg_agent/thrid_party/thrift/include/transport/TSSLSocket.cpp:551
MethodclearCache
()
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/cache/ServiceCache.java:134
MethodclearCache
()
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/cache/MnsCacheManager.java:138
MethodclientPortConfig
()
sdk/mns-invoker/src/test/java/com/meituan/octo/mns/SocketClientPortTests.java:35
Methodclose
sg_agent/thrid_party/thrift/include/transport/THttpTransport.h:53
Methodclose
sg_agent/thrid_party/thrift/include/transport/TFDTransport.cpp:37
Methodclose
sg_agent/thrid_party/thrift/include/transport/TZlibTransport.h:152
Methodclose
sg_agent/thrid_party/thrift/include/transport/TShortReadTransport.h:55
Methodclose
sg_agent/thrid_party/thrift/include/transport/TTransportUtils.h:137
Methodclose
sg_agent/thrid_party/thrift/include/transport/TSocketPool.cpp:245
Methodclose
sg_agent/thrid_party/thrift/include/transport/TBufferTransports.h:245
Methodclose
sg_agent/thrid_party/thrift/include/transport/TBufferTransports.h:364
Methodclose
sg_agent/thrid_party/thrift/include/transport/TTransportUtils.cpp:115
Methodclose
sg_agent/thrid_party/thrift/include/transport/TSSLSocket.cpp:143
Methodclose
sg_agent/thrid_party/thrift/include/transport/TServerSocket.cpp:466
Methodclose
* Closes the transport. */
sg_agent/thrid_party/thrift/include/transport/TTransport.h:95
Methodcmp
sg_agent/thrid_party/thrift/include/VirtualProfiling.cpp:79
Methodcmp
sg_agent/thrid_party/thrift/include/VirtualProfiling.cpp:219
Methodcomplete
sg_agent/thrid_party/thrift/include/async/TEvhttpServer.cpp:129
Methodcompleted__
sg_agent/thrid_party/cthrift/include/cthrift/Echo.h:322
MethodcomputeRead
sg_agent/thrid_party/thrift/include/transport/TBufferTransports.cpp:280
Functionconst_cast_sockopt
sg_agent/thrid_party/thrift/include/transport/TServerSocket.cpp:64
Methodconsume
sg_agent/thrid_party/thrift/include/transport/TShortReadTransport.h:82
Methodconsume
* Consume doesn't require a slow path. */
sg_agent/thrid_party/thrift/include/transport/TBufferTransports.h:120
Methodconsume
* 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
Methodconsume_virt
sg_agent/thrid_party/thrift/include/transport/TVirtualTransport.h:110
Methodconsume_virt
sg_agent/thrid_party/thrift/include/transport/TTransport.h:235
Methodcontains
(R row, C column)
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/cache/MultiMap.java:87
FunctionconvertIntegerToString
sg_agent/thrid_party/logs/include/helpers/stringhelper.h:155
FunctionconvertIntegerToString
sg_agent/thrid_party/logs/log4cplus/include/log4cplus/helpers/stringhelper.h:155
Methodcpu_util
sg_agent/src/remote/monitor/monitor_collector.h:41
Methodcreate
()
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/cache/MnsCache.java:34
MethodcreateConnection
创建连接
sdk/mns-sdk/src/thrift_client.cc:104
MethodcreateConnection
* 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
MethodcreateNotificationPipe
sg_agent/thrid_party/thrift/include/server/TNonblockingServer.cpp:1095
MethodcreateObject
sg_agent/thrid_party/logs/include/spi/factory.h:240
MethodcreateObject
sg_agent/thrid_party/logs/log4cplus/include/log4cplus/spi/factory.h:240
MethodcreateSocket
sg_agent/thrid_party/thrift/include/transport/TSSLSocket.cpp:371
MethodcreateSocket
sg_agent/thrid_party/thrift/include/transport/TSSLServerSocket.cpp:43
MethodcreateSocket
sg_agent/thrid_party/thrift/include/transport/TServerSocket.cpp:453
MethodcuratorFramework
(@Value("${zookeeper.url}") String zkUrl)
scanner/src/main/java/com/meituan/octo/mns/scanner/configuration/CuratorConfiguration.java:28
MethodcurrentTime
* Get current time as milliseconds from epoch */
sg_agent/thrid_party/thrift/include/concurrency/Util.h:140
MethodcurrentTimeTicks
sg_agent/thrid_party/thrift/include/concurrency/Util.cpp:34
MethodcurrentTimeUsec
* Get current time as micros from epoch */
sg_agent/thrid_party/thrift/include/concurrency/Util.h:145
MethoddeadCheckExecutor
(@Value("${executor.dead.threadCount}") int threadCount)
scanner/src/main/java/com/meituan/octo/mns/scanner/configuration/ExecutorConfiguration.java:34
Methoddecode
(ChannelHandlerContext channelHandlerContext, ByteBuf byteBuf, List<Object> list)
scanner/src/main/java/com/meituan/octo/mns/scanner/util/heartbeat/HeartbeatCodec.java:61
Methoddecode
decodes input (unsigned char) into output (uint4). Assumes len is a multiple of 4.
sg_agent/src/comm/md5.cc:136
Methoddel
sg_agent/src/comm/buffer_mgr.h:162
MethoddelayException
sg_agent/thrid_party/thrift/include/Thrift.h:195
Methoddelete
(String remoteAppkey, String protocol, String ipPort)
sdk/mns-invoker/src/test/java/com/meituan/octo/mns/cache/getServerTests.java:95
MethoddeletePostProviders
(@RequestBody List<SGService> providers)
nsc/src/main/java/com/meituan/octo/mnsc/web/api/ProvidersController.java:89
Methoddestroy
()
sdk/mns-invoker/src/test/java/com/meituan/octo/mns/listener/ServiceListListenerTest.java:166
Methoddestroy
()
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/http/HttpServerPublisher.java:89
MethoddoGetServiceList
(ServiceAgent.Iface client, ProtocolRequest req)
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/cache/OriginServiceCache.java:32
← previousnext →2,201–2,300 of 3,969, ranked by callers