MCPcopy Create free account

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

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

↓ 186 callersMethodunsafe
()
abg-utils/src/main/java/rpc/abg/util/UnsafeUtils.java:22
↓ 172 callersMethodgetName
()
abg-jmh/src/main/java/rpc/abg/benchmark/bean/User.java:32
↓ 122 callersMethodput
Returns the old value associated with the specified key, or null.
abg-utils/src/main/java/rpc/abg/util/FastMap.java:115
↓ 103 callersMethodbyteToHexLE
(byte b)
abg-utils/src/main/java/rpc/abg/util/HexUtils.java:77
↓ 68 callersMethodregister
注册服务 @param group @param app @param protocol @param serverAddress @param serverWeight 0-100
abg-cloud/src/main/java/rpc/abg/registry/Register.java:34
↓ 56 callersMethodequals
(Object obj)
abg-utils/src/main/java/rpc/abg/util/uuid/ObjectId.java:127
↓ 56 callersMethodinfo
Logs a message with info log level. @param message log this message
abg-jcl/src/main/java/org/apache/commons/logging/Log.java:161
↓ 55 callersMethodget
某个位置的值 @param index @return
abg-jmh/src/main/java/rpc/abg/benchmark/concurrent/AtomicMuiltInteger2.java:84
↓ 55 callersMethodisInfoEnabled
Is info logging currently enabled? <p>Call this method to prevent having to perform expensive operations (for example, <code>String</code> concatenati
abg-jcl/src/main/java/org/apache/commons/logging/Log.java:97
↓ 54 callersMethodget
根据种子获取一个元素, 配合 {@link #sum()}使用<br> <pre> int seed = rendom.nextInt(sum()); T t = get(seed); </pre> @param seed @return
abg-cloud/src/main/java/rpc/abg/loadbalance/WeightableGroup.java:119
↓ 52 callersMethodclear
()
abg-jmh/src/main/java/rpc/abg/benchmark/pool/ConcurrentObjectPool3.java:190
↓ 45 callersMethodget
(K key)
abg-utils/src/main/java/rpc/abg/util/FastMap.java:379
↓ 43 callersMethodsetBuffer
Sets a new byteBuf, discarding any previous byteBuf. The byte order, position, limit and capacity are set to match the specified byteBuf. The total is
abg-kryo/src/main/java/rpc/abg/serialization/kryo/ByteBufInput.java:27
↓ 43 callersMethodwriteInt
Writes a 4 byte int.
abg-kryo/src/main/java/rpc/abg/serialization/kryo/ByteBufOutput.java:179
↓ 42 callersMethodreadByte
Reads a single byte.
abg-kryo/src/main/java/rpc/abg/serialization/kryo/ByteBufInput.java:147
↓ 40 callersMethodwriteByte
(byte value)
abg-kryo/src/main/java/rpc/abg/serialization/kryo/ByteBufOutput.java:154
↓ 38 callersMethodinvoke
(Object... params)
abg-cloud/src/main/java/rpc/abg/invoke/Invoker.java:9
↓ 38 callersMethodsize
()
abg-utils/src/main/java/rpc/abg/util/FastClearableArrayList.java:73
↓ 37 callersMethodisWarnEnabled
Is warn logging currently enabled? <p>Call this method to prevent having to perform expensive operations (for example, <code>String</code> concatenati
abg-jcl/src/main/java/org/apache/commons/logging/Log.java:88
↓ 35 callersMethodisErrorEnabled
Is error logging currently enabled? <p>Call this method to prevent having to perform expensive operations (for example, <code>String</code> concatenat
abg-jcl/src/main/java/org/apache/commons/logging/Log.java:79
↓ 35 callersMethodwarn
Logs a message with warn log level. @param message log this message
abg-jcl/src/main/java/org/apache/commons/logging/Log.java:148
↓ 33 callersMethoderror
Logs a message with error log level. @param message log this message
abg-jcl/src/main/java/org/apache/commons/logging/Log.java:135
↓ 33 callersMethodwriteVarInt
(ByteBuf byteBuf, int value)
abg-utils/src/main/java/rpc/abg/util/ByteBufUtils.java:7
↓ 28 callersMethodcurrent
()
abg-utils/src/main/java/rpc/abg/util/concurrent/ThreadLocalBytes.java:15
↓ 27 callersMethodlog
(Level level, Object message, Throwable exception)
abg-jcl/src/main/java/org/apache/commons/logging/LogFactory.java:297
↓ 26 callersMethodgetLog
Convenience method to return a named logger. @param clazz containing Class from which a log name will be derived
abg-jcl/src/main/java/org/apache/commons/logging/LogFactory.java:98
↓ 24 callersMethodreadObject
(ByteBuf buf, Class<T> clazz)
abg-kryo/src/main/java/rpc/abg/serialization/kryo/KryoContext.java:134
↓ 23 callersMethodgetBytes
()
abg-jmh/src/main/java/rpc/abg/benchmark/string/StringTest.java:48
↓ 23 callersMethodtoString
()
abg-cloud/src/main/java/rpc/abg/trace/Tracer.java:102
↓ 22 callersMethodadd
(E e)
abg-utils/src/main/java/rpc/abg/util/FastClearableArrayList.java:49
↓ 22 callersMethodwriteObject
(final int fieldNumber, final T value, final Schema<T> schema, final boolean repeated)
abg-protostuff/src/main/java/io/protostuff/ByteBufOutput.java:206
↓ 20 callersMethodwrite
写入对象 @param buffer @param value
abg-cloud/src/main/java/rpc/abg/serialization/JsonMapper.java:24
↓ 19 callersMethodgetOrUpdate
(int key, Supplier<T> producer)
abg-utils/src/main/java/rpc/abg/util/IntToObjectArrayMap.java:85
↓ 19 callersMethodgetServiceMethodName
@param group 不能包含# / @param app 不能包含# / @param method 不能为空 @return
abg-cloud/src/main/java/rpc/abg/invoke/InvokerUtils.java:51
↓ 19 callersMethodgetUser
(long id)
abg-jmh/src/main/java/rpc/abg/benchmark/service/UserService.java:32
↓ 19 callersMethodisEmpty
()
abg-utils/src/main/java/rpc/abg/util/FastClearableArrayList.java:78
↓ 18 callersMethodgetId
()
abg-jmh/src/main/java/rpc/abg/benchmark/bean/User.java:24
↓ 18 callersMethodindexOf
(Object o)
abg-utils/src/main/java/rpc/abg/util/FastClearableArrayList.java:143
↓ 18 callersMethodoffset
(int index)
abg-utils/src/main/java/rpc/abg/util/concurrent/AtomicMuiltInteger.java:127
↓ 18 callersMethodwrite
(ByteBuf byteBuf, T object)
abg-jmh/src/main/java/rpc/abg/benchmark/serialization/manual/Serializer.java:7
↓ 17 callersMethodreadInt
()
abg-kryo/src/main/java/rpc/abg/serialization/kryo/ByteBufInput.java:179
↓ 16 callersMethodread
(ByteBuf byteBuf)
abg-jmh/src/main/java/rpc/abg/benchmark/serialization/manual/Serializer.java:9
↓ 16 callersMethodresize
(int newSize)
abg-utils/src/main/java/rpc/abg/util/FastMap.java:646
↓ 15 callersMethodcurrentTimeMillis
()
abg-jmh/src/main/java/rpc/abg/benchmark/uuid/UUIDBenchmark.java:50
↓ 15 callersMethodfast
很快,但不是那么靠谱,要求高精度的地方不能用 @return
abg-utils/src/main/java/rpc/abg/util/SystemClock.java:30
↓ 15 callersMethodgetRequestId
()
abg-cloud/src/main/java/rpc/abg/protocol/Request.java:25
↓ 15 callersMethodreadRawVarint32
Reads a var int 32 from the internal byte buffer.
abg-protostuff/src/main/java/io/protostuff/ByteBufInput.java:526
↓ 14 callersMethodcheckIfPackedField
Check if this field have been packed into a length-delimited field. If so, update internal state to reflect that packed fields are being read. @throw
abg-protostuff/src/main/java/io/protostuff/ByteBufInput.java:231
↓ 14 callersMethodget
@param index 通过 {@link #nextVarIndex()} 获得 @return
abg-utils/src/main/java/rpc/abg/util/concurrent/AttachmentThreadUtils.java:126
↓ 13 callersMethodadd
(RequestWithFuture requestWithFuture)
abg-cloud/src/main/java/rpc/abg/transport/client/future/FutureContainer.java:25
↓ 13 callersMethodcontainsKey
(K key)
abg-utils/src/main/java/rpc/abg/util/FastMap.java:578
↓ 13 callersMethodequals
(Object obj)
abg-cloud/src/main/java/rpc/abg/config/HostPort.java:51
↓ 13 callersMethodmap
Used by {@link RuntimeSchema#map(Class, Class)}.
abg-protostuff/src/main/java/io/protostuff/runtime/FastIdStrategy.java:162
↓ 13 callersMethodnewInstance
()
abg-cloud/src/main/java/rpc/abg/protocol/recycle/RecycleRequest.java:20
↓ 13 callersMethodwriteShort
Writes a 2 byte short.
abg-kryo/src/main/java/rpc/abg/serialization/kryo/ByteBufOutput.java:273
↓ 12 callersMethodcurrentThread
()
abg-jmh/src/main/java/rpc/abg/benchmark/threadlocal/ThreadLocalBenchmark.java:200
↓ 12 callersMethodgetParameterTypes
()
abg-cloud/src/main/java/rpc/abg/invoke/Invoker.java:51
↓ 12 callersMethodlistUser
(int pageNo)
abg-jmh/src/main/java/rpc/abg/benchmark/service/UserService.java:35
↓ 12 callersMethodmills
返回当前毫秒 @return
abg-utils/src/main/java/rpc/abg/util/SystemClock.java:55
↓ 12 callersMethodnextVarIndex
寻找下一个线程本地变量位置 @return
abg-utils/src/main/java/rpc/abg/util/concurrent/AttachmentThreadUtils.java:31
↓ 12 callersMethodset
设置某位置的值 @param index @param value
abg-jmh/src/main/java/rpc/abg/benchmark/concurrent/AtomicMuiltInteger2.java:122
↓ 12 callersMethodtoLatin1String
very unsafe @param bytes @return
abg-utils/src/main/java/rpc/abg/util/UnsafeStringUtils.java:148
↓ 11 callersMethodappendGetFieldValue
(StringBuilder builder, Field field)
abg-kryo/src/main/java/rpc/abg/serialization/kryo/FastSerializer.java:358
↓ 11 callersMethodgetStringOrElse
(Config config, String path, String defaultValue)
abg-cloud/src/main/java/rpc/abg/config/ConfigUtils.java:9
↓ 11 callersMethodhexToByteLE
(short hex)
abg-utils/src/main/java/rpc/abg/util/HexUtils.java:93
↓ 11 callersMethodloadClass
(String name)
abg-utils/src/main/java/rpc/abg/util/SingleClassLoader.java:22
↓ 11 callersMethodwriteBytes
(int fieldNumber, ByteString value, boolean repeated)
abg-protostuff/src/main/java/io/protostuff/ByteBufOutput.java:188
↓ 10 callersMethodaddLast
添加过滤器到最后面,最后面的会被最后执行 @param filter
abg-cloud/src/main/java/rpc/abg/client/AbgClient.java:213
↓ 10 callersMethodfill
Fills the byteBuf with more bytes. Can be overridden to fill the bytes from a source other than the InputStream.
abg-kryo/src/main/java/rpc/abg/serialization/kryo/ByteBufInput.java:63
↓ 10 callersMethodgetSchema
()
abg-protostuff/src/main/java/io/protostuff/runtime/FastIdStrategy.java:777
↓ 10 callersMethodgetServiceId
()
abg-cloud/src/main/java/rpc/abg/invoke/Invoker.java:43
↓ 10 callersMethodgetValue
()
abg-jmh/src/main/java/rpc/abg/benchmark/invoke/IntegerService.java:4
↓ 10 callersMethodindexOf
@param array 不为null,不含null元素 @param value 不为null @return
abg-cloud/src/main/java/rpc/abg/param/HttpParamExtractor.java:265
↓ 10 callersMethodisDebugEnabled
Is debug logging currently enabled? <p>Call this method to prevent having to perform expensive operations (for example, <code>String</code> concatenat
abg-jcl/src/main/java/org/apache/commons/logging/Log.java:106
↓ 10 callersMethodlog
(java.util.logging.Level level, Object message, Throwable exception)
abg-jcl/src/main/java/org/apache/commons/logging/LogFactory.java:605
↓ 10 callersMethodrelease
(Object obj)
abg-cloud/src/main/java/rpc/abg/recycle/RecycleUtils.java:5
↓ 10 callersMethodremove
(int requestId)
abg-cloud/src/main/java/rpc/abg/transport/client/future/FutureContainer.java:33
↓ 10 callersMethodstart
()
abg-cloud/src/main/java/rpc/abg/transport/server/rpc/NettyRpcServer.java:43
↓ 10 callersMethodtoHexString
96位编码, 长度为24 @return
abg-utils/src/main/java/rpc/abg/util/uuid/ObjectId.java:148
↓ 10 callersMethodtrace
Logs a message with trace log level. @param message log this message
abg-jcl/src/main/java/org/apache/commons/logging/Log.java:187
↓ 10 callersMethodwriteBool
(int fieldNumber, boolean value, boolean repeated)
abg-protostuff/src/main/java/io/protostuff/ByteBufOutput.java:113
↓ 9 callersMethodclear
()
abg-cloud/src/main/java/rpc/abg/transport/client/ConnectorContext.java:515
↓ 9 callersMethodgetSchemaWrapper
(String className, boolean load)
abg-protostuff/src/main/java/io/protostuff/runtime/FastIdStrategy.java:199
↓ 9 callersMethodhashCode
()
abg-utils/src/main/java/rpc/abg/util/uuid/ObjectId.java:118
↓ 9 callersMethodread
读取对象 @param buffer @param type @return
abg-cloud/src/main/java/rpc/abg/serialization/JsonMapper.java:16
↓ 9 callersMethodreadLong
Reads an 8 byte long.
abg-kryo/src/main/java/rpc/abg/serialization/kryo/ByteBufInput.java:293
↓ 9 callersMethodreadString
()
abg-protostuff/src/main/java/io/protostuff/ByteBufInput.java:374
↓ 9 callersMethodsetRemoteMethod
(Method remoteMethod)
abg-cloud/src/main/java/rpc/abg/common/RemoteContext.java:56
↓ 9 callersMethodsetServiceMethodName
(String serviceMethodName)
abg-cloud/src/main/java/rpc/abg/common/RemoteContext.java:69
↓ 9 callersMethodtoHex
high performance @param bytes @return
abg-utils/src/main/java/rpc/abg/util/HexUtils.java:135
↓ 9 callersMethodtoString
()
abg-jmh/src/main/java/rpc/abg/benchmark/bean/User.java:120
↓ 9 callersMethodtoString
()
abg-cloud/src/main/java/rpc/abg/protocol/Request.java:57
↓ 9 callersMethodwriteLong
Writes an 8 byte long.
abg-kryo/src/main/java/rpc/abg/serialization/kryo/ByteBufOutput.java:280
↓ 9 callersMethodwriteVarLong
(ByteBuf byteBuf, long value)
abg-utils/src/main/java/rpc/abg/util/ByteBufUtils.java:158
↓ 8 callersMethodequals
(Object obj)
abg-cloud/src/main/java/rpc/abg/invoke/ReflectInvoker.java:93
↓ 8 callersMethodexecute
仅用于测试,不要用于正式使用 @param method @param timeout 超时时间,millseconds @param methodParam @return
abg-cloud/src/main/java/rpc/abg/transport/client/App.java:415
↓ 8 callersMethodgetAddress
()
abg-jmh/src/main/java/rpc/abg/benchmark/bean/User.java:72
↓ 8 callersMethodgetOrUpdate
@param index 通过 {@link #nextVarIndex()} 获得 @param producer 尽量使用final常量以获得更好的性能 @return
abg-utils/src/main/java/rpc/abg/util/concurrent/AttachmentThreadUtils.java:45
↓ 8 callersMethodgetServerAddress
获取当前远程调用的服务端地址 @return
abg-cloud/src/main/java/rpc/abg/common/RemoteContext.java:39
↓ 8 callersMethodgetService
获取一个远程服务,必须先注册 :<br> {@link #register(Class)} or {@link #register(String, String, Class, Object)} @param clazz @return
abg-cloud/src/main/java/rpc/abg/client/AbgClient.java:195
next →1–100 of 1,654, ranked by callers