MCPcopy Create free account

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

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

↓ 4 callersMethodsetServiceId
(int serviceId)
abg-cloud/src/main/java/rpc/abg/protocol/Request.java:37
↓ 4 callersMethodsetSpanId
(long spanId)
abg-cloud/src/main/java/rpc/abg/trace/Tracer.java:66
↓ 4 callersMethodtableSizeFor
(int cap)
abg-utils/src/main/java/rpc/abg/util/concurrent/AttachmentThread.java:132
↓ 4 callersMethodtoString
()
abg-utils/src/main/java/rpc/abg/util/uuid/ObjectId128.java:172
↓ 4 callersMethodtoString
()
abg-utils/src/main/java/rpc/abg/util/uuid/ObjectId.java:196
↓ 4 callersMethodwriteByteRange
(boolean utf8String, int fieldNumber, byte[] value, int offset, int length, boolean repeated)
abg-protostuff/src/main/java/io/protostuff/ByteBufOutput.java:198
↓ 4 callersMethodwriteBytes
Writes the bytes. Note the byte[] length is not written.
abg-kryo/src/main/java/rpc/abg/serialization/kryo/ByteBufOutput.java:163
↓ 3 callersMethodaddFuture
(int requestId, CompletableFuture<Response> future)
abg-jmh/src/main/java/rpc/abg/benchmark/future/ResponseFutureContainer1.java:26
↓ 3 callersMethodbox
(Class<?> clazz, String value)
abg-utils/src/main/java/rpc/abg/util/SourceCodeUtils.java:87
↓ 3 callersMethodcastToInteger
(String value)
abg-utils/src/main/java/rpc/abg/util/TypeUtils.java:238
↓ 3 callersMethodcheckLastTagWas
Verifies that the last call to readTag() returned the given tag value. This is used to verify that a nested group ended with the correct end tag. @th
abg-protostuff/src/main/java/io/protostuff/ByteBufInput.java:128
↓ 3 callersMethodcreateClass
方法参数封装,用于序列化传输参数数据,其实现类会自动根据方法名称生成get/set方法,<br> 必须开启"Store information about method parameters (usable via reflection)"<br> 参考:https://www.concretepa
abg-cloud/src/main/java/rpc/abg/param/MethodParamClassFactory.java:72
↓ 3 callersMethoddoExpireJob
删除过期任务 @param maxTime 毫秒,超时则跳出
abg-cloud/src/main/java/rpc/abg/transport/client/future/FutureContainer.java:75
↓ 3 callersMethoddoRequestFilter
(FullHttpRequest request, Invoker<CompletableFuture<?>> invoker)
abg-cloud/src/main/java/rpc/abg/transport/server/rest/handler/NettyRestHandler.java:188
↓ 3 callersMethodencode
(final byte[] bytes)
abg-utils/src/main/java/rpc/abg/util/URLEncodeUtils.java:102
↓ 3 callersMethodencode
(ChannelHandlerContext ctx, RequestWithFuture requestWithFuture, ByteBuf buffer)
abg-cloud/src/main/java/rpc/abg/transport/client/codec/RequestEncoder.java:30
↓ 3 callersMethodensureCapacity
(int capacity)
abg-utils/src/main/java/rpc/abg/util/concurrent/ConcurrentArrayList.java:120
↓ 3 callersMethodentries
Returns an iterator for the entries in the map. Remove is supported.
abg-utils/src/main/java/rpc/abg/util/FastMap.java:723
↓ 3 callersMethodflush
Writes the buffered bytes to the underlying OutputStream, if any.
abg-kryo/src/main/java/rpc/abg/serialization/kryo/ByteBufOutput.java:114
↓ 3 callersMethodfutureMap
(int requestId)
abg-jmh/src/main/java/rpc/abg/benchmark/future/ResponseFutureContainer3.java:38
↓ 3 callersMethodget
(final int key)
abg-utils/src/main/java/rpc/abg/util/concurrent/ConcurrentIntToIntArrayMap.java:71
↓ 3 callersMethodget
(int index)
abg-utils/src/main/java/rpc/abg/util/concurrent/ConcurrentArrayList.java:73
↓ 3 callersMethodget
某个位置的值 @param index @return
abg-jmh/src/main/java/rpc/abg/benchmark/concurrent/AtomicMuiltInteger1.java:76
↓ 3 callersMethodgetCreateTime
()
abg-jmh/src/main/java/rpc/abg/benchmark/bean/User.java:104
↓ 3 callersMethodgetRequest
()
abg-cloud/src/main/java/rpc/abg/transport/client/future/RequestWithFuture.java:19
↓ 3 callersMethodgetSpanId
()
abg-cloud/src/main/java/rpc/abg/trace/Tracer.java:62
↓ 3 callersMethodgetTraceId
()
abg-cloud/src/main/java/rpc/abg/trace/Tracer.java:46
↓ 3 callersMethodhandleResult
处理返回值,无失败回退 @param request @param future @return
abg-cloud/src/main/java/rpc/abg/transport/client/ConnectorContext.java:280
↓ 3 callersMethodloadClass
添加时调用一次就行了 @throws Exception
abg-cloud/src/main/java/rpc/abg/transport/client/App.java:688
↓ 3 callersMethodnewInstance
()
abg-cloud/src/main/java/rpc/abg/protocol/recycle/RecycleResponse.java:20
↓ 3 callersMethodnext
Gets a new object id. @return the new id
abg-utils/src/main/java/rpc/abg/util/uuid/ObjectId128.java:84
↓ 3 callersMethodnext
Gets a new object id. @return the new id
abg-utils/src/main/java/rpc/abg/util/uuid/RandomId128.java:67
↓ 3 callersMethodnext
Gets a new object id. @return the new id
abg-utils/src/main/java/rpc/abg/util/uuid/RandomId.java:69
↓ 3 callersMethodnextPowerOfTwo
(int value)
abg-utils/src/main/java/rpc/abg/util/FastMap.java:887
↓ 3 callersMethodnotifyResponse
(Response response)
abg-jmh/src/main/java/rpc/abg/benchmark/future/ResponseFutureContainer1.java:48
↓ 3 callersMethodoffset
(int key)
abg-jmh/src/main/java/rpc/abg/benchmark/pool/ConcurrentObjectPool3.java:155
↓ 3 callersMethodoffset
(int key)
abg-jmh/src/main/java/rpc/abg/benchmark/pool/ConcurrentObjectPool.java:141
↓ 3 callersMethodput
@param key 大于零,小于256k @param value
abg-utils/src/main/java/rpc/abg/util/IntToObjectArrayMap.java:117
↓ 3 callersMethodput
@param key 大于零,小于512k @param value 大于零
abg-utils/src/main/java/rpc/abg/util/concurrent/ConcurrentIntToIntArrayMap.java:114
↓ 3 callersMethodput
@param key 大于零,小于512k @param value
abg-utils/src/main/java/rpc/abg/util/concurrent/ConcurrentIntToObjectArrayMap.java:133
↓ 3 callersMethodreadClassAndObject
(ByteBuf buf)
abg-kryo/src/main/java/rpc/abg/serialization/kryo/KryoContext.java:154
↓ 3 callersMethodreadRawVarint64
Reads a var int 64 from the internal byte buffer.
abg-protostuff/src/main/java/io/protostuff/ByteBufInput.java:533
↓ 3 callersMethodreadVarInt
(ByteBuf byteBuf)
abg-utils/src/main/java/rpc/abg/util/ByteBufUtils.java:48
↓ 3 callersMethodreset
()
abg-utils/src/main/java/rpc/abg/util/FastMap.java:757
↓ 3 callersMethodselectConnector
()
abg-cloud/src/main/java/rpc/abg/transport/client/MethodRouter.java:42
↓ 3 callersMethodsend
(RequestWithFuture request)
abg-cloud/src/main/java/rpc/abg/transport/client/sender/Sender.java:9
↓ 3 callersMethodset
设置某位置的值 @param index @param value
abg-jmh/src/main/java/rpc/abg/benchmark/concurrent/AtomicMuiltInteger1.java:119
↓ 3 callersMethodsetAddress
(String address)
abg-jmh/src/main/java/rpc/abg/benchmark/bean/User.java:76
↓ 3 callersMethodsetBirthday
(LocalDate birthday)
abg-jmh/src/main/java/rpc/abg/benchmark/bean/User.java:52
↓ 3 callersMethodsetConnectors
(Collection<ConnectorContext> connectors)
abg-cloud/src/main/java/rpc/abg/transport/client/MethodRouter.java:29
↓ 3 callersMethodsetCreateTime
(LocalDateTime createTime)
abg-jmh/src/main/java/rpc/abg/benchmark/bean/User.java:108
↓ 3 callersMethodsetEmail
(String email)
abg-jmh/src/main/java/rpc/abg/benchmark/bean/User.java:60
↓ 3 callersMethodsetIcon
(String icon)
abg-jmh/src/main/java/rpc/abg/benchmark/bean/User.java:84
↓ 3 callersMethodsetId
(long id)
abg-jmh/src/main/java/rpc/abg/benchmark/bean/User.java:28
↓ 3 callersMethodsetMobile
(String mobile)
abg-jmh/src/main/java/rpc/abg/benchmark/bean/User.java:68
↓ 3 callersMethodsetName
(String name)
abg-jmh/src/main/java/rpc/abg/benchmark/bean/User.java:36
↓ 3 callersMethodsetPermissions
(List<Integer> permissions)
abg-jmh/src/main/java/rpc/abg/benchmark/bean/User.java:92
↓ 3 callersMethodsetResult
(Object result)
abg-cloud/src/main/java/rpc/abg/protocol/Response.java:52
↓ 3 callersMethodsetSex
(int sex)
abg-jmh/src/main/java/rpc/abg/benchmark/bean/User.java:44
↓ 3 callersMethodsetStatus
(int status)
abg-jmh/src/main/java/rpc/abg/benchmark/bean/User.java:100
↓ 3 callersMethodsetTracer
设置tracer上下文,后续请求将会作为parent使用 @param tracer
abg-cloud/src/main/java/rpc/abg/trace/TracerContext.java:26
↓ 3 callersMethodsetUpdateTime
(LocalDateTime updateTime)
abg-jmh/src/main/java/rpc/abg/benchmark/bean/User.java:116
↓ 3 callersMethodsum
所有位置的和 @return
abg-jmh/src/main/java/rpc/abg/benchmark/concurrent/AtomicMuiltInteger2.java:94
↓ 3 callersMethodtableSizeFor
成倍扩容 @param cap @return
abg-utils/src/main/java/rpc/abg/util/TableUtils.java:12
↓ 3 callersMethodtoString
()
abg-utils/src/main/java/rpc/abg/util/FastMap.java:692
↓ 3 callersMethodtuple
(T1 _1)
abg-utils/src/main/java/rpc/abg/util/tuple/Tuple.java:6
↓ 3 callersMethodwriteBoolean
Writes a 1 byte boolean.
abg-kryo/src/main/java/rpc/abg/serialization/kryo/ByteBufOutput.java:458
↓ 3 callersMethodwriteObject
(ByteBuf buf, Object obj)
abg-kryo/src/main/java/rpc/abg/serialization/kryo/KryoContext.java:124
↓ 3 callersMethodwriteStringFast
(String value)
abg-kryo/src/main/java/rpc/abg/serialization/kryo/ByteBufOutput.java:191
↓ 2 callersMethod_newBytes
()
abg-jmh/src/main/java/rpc/abg/benchmark/array/ArrayBenchmark.java:45
↓ 2 callersMethodaddAll
(Collection<? extends E> c)
abg-utils/src/main/java/rpc/abg/util/FastClearableArrayList.java:113
↓ 2 callersMethodaddFirst
添加过滤器到最前面,最前面的会被最先执行 @param filter
abg-cloud/src/main/java/rpc/abg/client/AbgClient.java:204
↓ 2 callersMethodappendReadFieldCode
(StringBuilder builder, Field field)
abg-kryo/src/main/java/rpc/abg/serialization/kryo/FastSerializer.java:416
↓ 2 callersMethodbinarySearch
(int[] values, int key)
abg-cloud/src/main/java/rpc/abg/loadbalance/WeightableGroup.java:145
↓ 2 callersMethodcastTo
(String str, Class<?> clazz)
abg-utils/src/main/java/rpc/abg/util/TypeUtils.java:115
↓ 2 callersMethodcastToBoolean
(String value)
abg-utils/src/main/java/rpc/abg/util/TypeUtils.java:246
↓ 2 callersMethodcastToByte
(String value)
abg-utils/src/main/java/rpc/abg/util/TypeUtils.java:266
↓ 2 callersMethodcastToCharacter
(String value)
abg-utils/src/main/java/rpc/abg/util/TypeUtils.java:270
↓ 2 callersMethodcastToDouble
(String value)
abg-utils/src/main/java/rpc/abg/util/TypeUtils.java:254
↓ 2 callersMethodcastToFloat
(String value)
abg-utils/src/main/java/rpc/abg/util/TypeUtils.java:258
↓ 2 callersMethodcastToLong
(String value)
abg-utils/src/main/java/rpc/abg/util/TypeUtils.java:242
↓ 2 callersMethodcastToShort
(String value)
abg-utils/src/main/java/rpc/abg/util/TypeUtils.java:262
↓ 2 callersMethodclose
()
abg-jmh/src/main/java/rpc/abg/benchmark/client/RpcClientBenchmark.java:75
↓ 2 callersMethodclose
(ChannelHandlerContext ctx, ChannelPromise promise)
abg-cloud/src/main/java/rpc/abg/transport/client/codec/RequestListEncoder.java:82
↓ 2 callersMethodclose
()
abg-cloud/src/main/java/rpc/abg/server/TurboServer.java:251
↓ 2 callersMethodclose
()
abg-cloud/src/main/java/rpc/abg/common/EventLoopGroupHolder.java:63
↓ 2 callersMethodconnect
()
abg-cloud/src/main/java/rpc/abg/transport/client/ConnectorContext.java:553
↓ 2 callersMethodcontains
@param key @return
abg-utils/src/main/java/rpc/abg/util/concurrent/ConcurrentIntToIntArrayMap.java:52
↓ 2 callersMethodcontainsKeyStash
(K key)
abg-utils/src/main/java/rpc/abg/util/FastMap.java:599
↓ 2 callersMethodcreateLocationAwareLog
(String name)
abg-jcl/src/main/java/org/apache/commons/logging/LogFactory.java:173
↓ 2 callersMethodcreateLog
(String name)
abg-jcl/src/main/java/org/apache/commons/logging/LogFactory.java:179
↓ 2 callersMethodcreateSerializer
创建一个 Serializer @param className @return
abg-cloud/src/main/java/rpc/abg/serialization/SerializerFactory.java:17
↓ 2 callersMethodcurrent
()
abg-utils/src/main/java/rpc/abg/util/concurrent/ThreadLocalHeapByteBuffer.java:16
↓ 2 callersMethoddoEncode
(ByteBuf buffer, RequestWithFuture request)
abg-cloud/src/main/java/rpc/abg/transport/client/codec/RequestListEncoder.java:46
↓ 2 callersMethoddoRequestFilter
(Request request)
abg-cloud/src/main/java/rpc/abg/transport/client/ConnectorContext.java:435
↓ 2 callersMethoddoResponseFilter
(Request request, Response response, Method method, String serviceMethodName, Throwable throwable)
abg-cloud/src/main/java/rpc/abg/transport/client/ConnectorContext.java:477
↓ 2 callersMethodensureCapacity
Increases the size of the backing array to acommodate the specified number of additional items. Useful before adding many items to avoid multiple back
abg-utils/src/main/java/rpc/abg/util/FastMap.java:640
↓ 2 callersMethodensureCapacity
(int capacity)
abg-utils/src/main/java/rpc/abg/util/IntToObjectArrayMap.java:139
↓ 2 callersMethodensureCapacity
(int capacity)
abg-utils/src/main/java/rpc/abg/util/concurrent/ConcurrentIntToIntArrayMap.java:182
↓ 2 callersMethodensureCapacity
(int capacity)
abg-utils/src/main/java/rpc/abg/util/concurrent/ConcurrentIntToObjectArrayMap.java:196
← previousnext →201–300 of 1,654, ranked by callers