MCPcopy Create free account

hub / github.com/annabergite/abg-rpc / functions

Functions1,654 in github.com/annabergite/abg-rpc

↓ 2 callersMethodensureSize
(int length)
abg-kryo/src/main/java/rpc/abg/serialization/kryo/ByteBufInput.java:67
↓ 2 callersMethoderror
(Object message)
abg-jcl/src/main/java/org/apache/commons/logging/LogFactory.java:359
↓ 2 callersMethoderror
(Object message)
abg-jcl/src/main/java/org/apache/commons/logging/LogFactory.java:444
↓ 2 callersMethoderror
(Object message)
abg-jcl/src/main/java/org/apache/commons/logging/LogFactory.java:565
↓ 2 callersMethodexchange
(final Object value)
abg-jmh/src/main/java/rpc/abg/benchmark/pool/ConcurrentObjectPool2.java:114
↓ 2 callersMethodexecute
远程调用,无参,无失败回退 @param serviceId 远程serviceId @param timeout millseconds @return
abg-cloud/src/main/java/rpc/abg/transport/client/ConnectorContext.java:188
↓ 2 callersMethodforceCast
(Class<?> clazz)
abg-utils/src/main/java/rpc/abg/util/SourceCodeUtils.java:51
↓ 2 callersMethodfromHex
high performance @param hex @return
abg-utils/src/main/java/rpc/abg/util/HexUtils.java:252
↓ 2 callersMethodfromHex2
(String hex)
abg-utils/src/main/java/rpc/abg/util/HexUtils.java:295
↓ 2 callersMethodget
@param key @return null为找不到
abg-utils/src/main/java/rpc/abg/util/IntToObjectArrayMap.java:65
↓ 2 callersMethodget
@param key @return null为找不到
abg-utils/src/main/java/rpc/abg/util/concurrent/ConcurrentIntToObjectArrayMap.java:70
↓ 2 callersMethodget
某个位置的值 @param index @return
abg-utils/src/main/java/rpc/abg/util/concurrent/AtomicMuiltInteger.java:78
↓ 2 callersMethodgetAppConfigList
()
abg-cloud/src/main/java/rpc/abg/config/client/ClientConfig.java:11
↓ 2 callersMethodgetByteBuf
()
abg-protostuff/src/main/java/io/protostuff/ByteBufInput.java:55
↓ 2 callersMethodgetClassIdMap
获取已注册的 classId @return
abg-cloud/src/main/java/rpc/abg/common/TurboConnectService.java:73
↓ 2 callersMethodgetClientAddress
获取当前远程调用的客户端地址 @return
abg-cloud/src/main/java/rpc/abg/common/RemoteContext.java:26
↓ 2 callersMethodgetConnectErrorThreshold
()
abg-cloud/src/main/java/rpc/abg/config/client/AppConfig.java:90
↓ 2 callersMethodgetCr
()
abg-cloud/src/main/java/rpc/abg/trace/Tracer.java:78
↓ 2 callersMethodgetCs
()
abg-cloud/src/main/java/rpc/abg/trace/Tracer.java:70
↓ 2 callersMethodgetEpochMinutes
()
abg-utils/src/main/java/rpc/abg/util/uuid/LongId.java:31
↓ 2 callersMethodgetFailoverInvokerFieldName
(App app, Method method)
abg-cloud/src/main/java/rpc/abg/remote/RemoteServiceFactory.java:201
↓ 2 callersMethodgetGetMethod
获取字段的get方法 @param targetClass @param field @return
abg-utils/src/main/java/rpc/abg/util/ReflectUtils.java:20
↓ 2 callersMethodgetMaxRequestWait
()
abg-cloud/src/main/java/rpc/abg/config/client/AppConfig.java:66
↓ 2 callersMethodgetParentId
()
abg-cloud/src/main/java/rpc/abg/trace/Tracer.java:54
↓ 2 callersMethodgetPermissions
()
abg-jmh/src/main/java/rpc/abg/benchmark/bean/User.java:88
↓ 2 callersMethodgetRegistration
(Class<?> type)
abg-kryo/src/main/java/rpc/abg/serialization/kryo/FastSerializer.java:182
↓ 2 callersMethodgetRegistration
(Class type)
abg-kryo/src/main/java/rpc/abg/serialization/kryo/FastClassResolver.java:95
↓ 2 callersMethodgetRemoteMethod
获取当前远程调用的接口方法, 可能为空 @return
abg-cloud/src/main/java/rpc/abg/common/RemoteContext.java:52
↓ 2 callersMethodgetRestPath
获取rest访问路径 @param method 不能为空 @return 当未配置或未正确配置时返回null
abg-cloud/src/main/java/rpc/abg/invoke/InvokerUtils.java:119
↓ 2 callersMethodgetResult
()
abg-jmh/src/main/java/rpc/abg/benchmark/bean/Page.java:40
↓ 2 callersMethodgetServerAddress
()
abg-cloud/src/main/java/rpc/abg/config/server/RegisterConfig.java:37
↓ 2 callersMethodgetService
通过服务接口获取远程代理实现类,结果缓存起来使用,不要每次调用 @param clazz 服务接口 @return
abg-cloud/src/main/java/rpc/abg/remote/RemoteServiceFactory.java:69
↓ 2 callersMethodgetServiceMethodName
()
abg-cloud/src/main/java/rpc/abg/transport/client/MethodRouter.java:50
↓ 2 callersMethodgetSetMethod
获取字段的set方法 @param targetClass @param field @return
abg-utils/src/main/java/rpc/abg/util/ReflectUtils.java:67
↓ 2 callersMethodgetSr
()
abg-cloud/src/main/java/rpc/abg/trace/Tracer.java:94
↓ 2 callersMethodgetSs
()
abg-cloud/src/main/java/rpc/abg/trace/Tracer.java:86
↓ 2 callersMethodgetStatus
()
abg-cloud/src/main/java/rpc/abg/transport/server/rest/protocol/RestHttpResponse.java:44
↓ 2 callersMethodgetValue
(Class<?> clazz)
abg-jmh/src/main/java/rpc/abg/benchmark/map/IdentityHashMapBenchmark.java:68
↓ 2 callersMethodhasNext
()
abg-utils/src/main/java/rpc/abg/util/FastMap.java:861
↓ 2 callersMethodhashCode
()
abg-utils/src/main/java/rpc/abg/util/uuid/ObjectId128.java:116
↓ 2 callersMethodinitSerializer
()
abg-cloud/src/main/java/rpc/abg/transport/client/ConnectorContext.java:107
↓ 2 callersMethodipToLong
@param ip ipv4 only @return 找不到返回-1
abg-utils/src/main/java/rpc/abg/util/IPUtils.java:12
↓ 2 callersMethodisKeepAlive
()
abg-cloud/src/main/java/rpc/abg/transport/server/rest/protocol/RestHttpResponse.java:60
↓ 2 callersMethodisSupportedClassId
是否支持classID @return
abg-cloud/src/main/java/rpc/abg/serialization/Serializer.java:84
↓ 2 callersMethodisZombie
()
abg-cloud/src/main/java/rpc/abg/transport/client/ConnectorContext.java:527
↓ 2 callersMethoditerator
()
abg-utils/src/main/java/rpc/abg/util/FastMap.java:874
↓ 2 callersMethodloadServiceId
添加时调用一次就行了 @throws Exception
abg-cloud/src/main/java/rpc/abg/transport/client/App.java:701
↓ 2 callersMethodnext
()
abg-utils/src/main/java/rpc/abg/util/FastMap.java:828
↓ 2 callersMethodoffset
(int key)
abg-jmh/src/main/java/rpc/abg/benchmark/pool/ConcurrentObjectPool2.java:153
↓ 2 callersMethodonChange
当服务发生变化时调用 @param serverWithWeight
abg-cloud/src/main/java/rpc/abg/discover/DiscoverListener.java:14
↓ 2 callersMethodonSend
客户端发送前执行 @param request 不为空 @return true表示允许发送,false表示不允许发送,不允许发送的情况将执行failover方法
abg-cloud/src/main/java/rpc/abg/filter/RpcClientFilter.java:18
↓ 2 callersMethodparse
(String resourceName)
abg-cloud/src/main/java/rpc/abg/config/client/ClientConfig.java:24
↓ 2 callersMethodpush
(K insertKey, V insertValue, int index1, K key1, int index2, K key2, int index3, K key3, int index4, K key4
abg-utils/src/main/java/rpc/abg/util/FastMap.java:268
↓ 2 callersMethodput
存储线程变量 @param index 需要从AttachmentThreadUtils.nextVarIndex()获取到 @param value
abg-utils/src/main/java/rpc/abg/util/concurrent/AttachmentThread.java:48
↓ 2 callersMethodput_internal
(K key, V value)
abg-utils/src/main/java/rpc/abg/util/FastMap.java:121
↓ 2 callersMethodreadBoolean
Reads a 1 byte boolean.
abg-kryo/src/main/java/rpc/abg/serialization/kryo/ByteBufInput.java:346
↓ 2 callersMethodreadByKryo
()
abg-jmh/src/main/java/rpc/abg/benchmark/serialization/TracerSerializerBenchmark.java:114
↓ 2 callersMethodreadByteArray
()
abg-protostuff/src/main/java/io/protostuff/ByteBufInput.java:461
↓ 2 callersMethodreadShort
Reads a 2 byte short.
abg-kryo/src/main/java/rpc/abg/serialization/kryo/ByteBufInput.java:283
↓ 2 callersMethodreadStringFast
()
abg-kryo/src/main/java/rpc/abg/serialization/kryo/ByteBufInput.java:209
↓ 2 callersMethodregister
注册invoker @param service 实现类实例,重复调用时不会覆盖,会一直使用首次注册的实例 @param clazz 服务接口
abg-cloud/src/main/java/rpc/abg/invoke/ServerInvokerFactory.java:127
↓ 2 callersMethodregisterPojoID
(Map<String, Integer> pojoIDMap)
abg-protostuff/src/main/java/io/protostuff/runtime/FastIdStrategy.java:95
↓ 2 callersMethodregisterService
手动注册一个服务 @param map
abg-cloud/src/main/java/rpc/abg/server/TurboServer.java:209
↓ 2 callersMethodrelease
释放eventLoopGroup,内部使用引用计数,当计数为0时实际关闭 @param eventLoopGroup
abg-cloud/src/main/java/rpc/abg/common/EventLoopGroupHolder.java:57
↓ 2 callersMethodremove
(K key)
abg-utils/src/main/java/rpc/abg/util/FastMap.java:441
↓ 2 callersMethodremove
(int requestId)
abg-jmh/src/main/java/rpc/abg/benchmark/future/ResponseFutureContainer2.java:43
↓ 2 callersMethodremoveStashIndex
(int index)
abg-utils/src/main/java/rpc/abg/util/FastMap.java:497
↓ 2 callersMethodresolve
()
abg-jcl/src/main/java/org/apache/commons/logging/LogFactory.java:667
↓ 2 callersMethodresolveClass
(String className)
abg-protostuff/src/main/java/io/protostuff/runtime/FastIdStrategy.java:673
↓ 2 callersMethodschema
客户端或者服务端获取ProtostuffSchema,该方法速度慢 @param clazz @return
abg-protostuff/src/main/java/rpc/abg/serialization/protostuff/ProtostuffSerializer.java:192
↓ 2 callersMethodserializer
(int id)
abg-jmh/src/main/java/rpc/abg/benchmark/serialization/manual/Register.java:33
↓ 2 callersMethodsetApp
(String app)
abg-cloud/src/main/java/rpc/abg/config/client/AppConfig.java:46
↓ 2 callersMethodsetBuffer
Sets the buffer that will be written to. maxCapacity is set to the specified buffer's capacity. @see #setBuffer(ByteBuf, int)
abg-kryo/src/main/java/rpc/abg/serialization/kryo/ByteBufOutput.java:44
↓ 2 callersMethodsetByteBuf
(ByteBuf buffer)
abg-protostuff/src/main/java/io/protostuff/ByteBufOutput.java:29
↓ 2 callersMethodsetByteBuf
(ByteBuf buffer, boolean protostuffMessage)
abg-protostuff/src/main/java/io/protostuff/ByteBufInput.java:59
↓ 2 callersMethodsetClassIds
设置classID @param classIds
abg-cloud/src/main/java/rpc/abg/serialization/Serializer.java:93
↓ 2 callersMethodsetConnect
建立连接 @param serverAddresss @throws Exception
abg-cloud/src/main/java/rpc/abg/transport/client/App.java:122
↓ 2 callersMethodsetCr
(long cr)
abg-cloud/src/main/java/rpc/abg/trace/Tracer.java:82
↓ 2 callersMethodsetCs
(long cs)
abg-cloud/src/main/java/rpc/abg/trace/Tracer.java:74
↓ 2 callersMethodsetGroup
(String group)
abg-cloud/src/main/java/rpc/abg/config/client/AppConfig.java:38
↓ 2 callersMethodsetPageNo
(int pageNo)
abg-jmh/src/main/java/rpc/abg/benchmark/bean/Page.java:28
↓ 2 callersMethodsetRequest
(Request request)
abg-cloud/src/main/java/rpc/abg/transport/client/future/RequestWithFuture.java:23
↓ 2 callersMethodsetServiceMethodNameToServiceIdMap
(Map<String, Integer> serviceMethodNameToServiceIdMap)
abg-cloud/src/main/java/rpc/abg/transport/client/ConnectorContext.java:519
↓ 2 callersMethodsetSourceClassName
(String sourceClassName)
abg-jcl/src/main/java/org/apache/commons/logging/LogFactory.java:647
↓ 2 callersMethodsetSourceMethodName
(String sourceMethodName)
abg-jcl/src/main/java/org/apache/commons/logging/LogFactory.java:661
↓ 2 callersMethodsetSr
(long sr)
abg-cloud/src/main/java/rpc/abg/trace/Tracer.java:98
↓ 2 callersMethodsetSs
(long ss)
abg-cloud/src/main/java/rpc/abg/trace/Tracer.java:90
↓ 2 callersMethodsetTotal
(int total)
abg-jmh/src/main/java/rpc/abg/benchmark/bean/Page.java:36
↓ 2 callersMethodskipField
Reads and discards a single field, given its tag value. @return {@code false} if the tag is an endgroup tag, in which case nothing is skipped
abg-protostuff/src/main/java/io/protostuff/ByteBufInput.java:140
↓ 2 callersMethodstartRestServer
(HostPort hostPort)
abg-cloud/src/main/java/rpc/abg/server/TurboServer.java:182
↓ 2 callersMethodstartRpcServer
(HostPort hostPort)
abg-cloud/src/main/java/rpc/abg/server/TurboServer.java:155
↓ 2 callersMethodsum
所有位置的和 @return
abg-utils/src/main/java/rpc/abg/util/concurrent/AtomicMuiltInteger.java:88
↓ 2 callersMethodsum
所有位置的和 @return
abg-jmh/src/main/java/rpc/abg/benchmark/concurrent/AtomicMuiltInteger1.java:85
↓ 2 callersMethodsum
获取weight之和,配合{@link #get(int)}使用<br> <pre> int seed = rendom.nextInt(sum()); T t = get(seed); </pre> @return
abg-cloud/src/main/java/rpc/abg/loadbalance/WeightableGroup.java:104
↓ 2 callersMethodsupportCast
(Class<?> clazz)
abg-utils/src/main/java/rpc/abg/util/TypeUtils.java:19
↓ 2 callersMethodsupportHttpForm
()
abg-cloud/src/main/java/rpc/abg/invoke/Invoker.java:63
↓ 2 callersMethodtest
()
abg-jmh/src/main/java/rpc/abg/benchmark/client/TruboClientBootTest.java:30
↓ 2 callersMethodtoClass
(String serviceClassName)
abg-cloud/src/main/java/rpc/abg/invoke/InvokerUtils.java:170
↓ 2 callersMethodtoHex2
略慢 @param bytes @return
abg-utils/src/main/java/rpc/abg/util/HexUtils.java:111
↓ 2 callersMethodtoHexString
128位编码, 长度为32 @return
abg-utils/src/main/java/rpc/abg/util/uuid/ObjectId128.java:146
← previousnext →301–400 of 1,654, ranked by callers