Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/dingwpmz/netty-learning
/ functions
Functions
316 in github.com/dingwpmz/netty-learning
⨍
Functions
316
◇
Types & classes
63
↓ 57 callers
Method
info
(String var1)
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyLogger.java:230
↓ 44 callers
Method
warn
(String var1)
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyLogger.java:260
↓ 32 callers
Method
error
(String var1)
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyLogger.java:290
↓ 29 callers
Method
equals
(final Object o)
netty-framework/src/main/java/com/prestigeding/remoting/netty/RequestTask.java:46
↓ 23 callers
Method
parseChannelRemoteAddr
(final Channel channel)
netty-framework/src/main/java/com/prestigeding/remoting/common/RemotingHelper.java:148
↓ 16 callers
Method
toString
()
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyEvent.java:44
↓ 12 callers
Method
closeChannel
(final String addr, final Channel channel)
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyRemotingClient.java:226
↓ 10 callers
Method
getChannel
()
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyRemotingClient.java:563
↓ 9 callers
Method
putNettyEvent
Put a netty event to the executor. @param event Netty event instance.
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyRemotingAbstract.java:134
↓ 9 callers
Method
release
()
netty-framework/src/main/java/com/prestigeding/remoting/netty/ResponseFuture.java:59
↓ 8 callers
Method
isNullOrEmpty
Determine if a string is {@code null} or {@link String#isEmpty()} returns {@code true}.
netty-framework/src/main/java/com/prestigeding/remoting/netty/TlsHelper.java:232
↓ 8 callers
Method
register
socket channel @param socketChannel
reactor-nio/src/main/java/com/prestigeding/nio/reactor/SubReactorThread.java:38
↓ 7 callers
Method
getOpaque
()
netty-framework/src/main/java/com/prestigeding/remoting/netty/ResponseFuture.java:116
↓ 7 callers
Method
isOK
()
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyRemotingClient.java:555
↓ 7 callers
Method
next
()
reactor-nio/src/main/java/com/prestigeding/nio/reactor/SubReactorThreadGroup.java:53
↓ 6 callers
Method
close
()
netty-framework/src/main/java/com/prestigeding/remoting/netty/FileRegionEncoder.java:63
↓ 6 callers
Method
closeChannel
(Channel channel)
netty-framework/src/main/java/com/prestigeding/remoting/common/RemotingUtil.java:193
↓ 6 callers
Method
setOpaque
(int opaque)
netty-framework/src/main/java/com/prestigeding/remoting/protocol/RemotingCommand.java:111
↓ 5 callers
Method
createResponseCommand
(int code, String remark)
netty-framework/src/main/java/com/prestigeding/remoting/protocol/RemotingCommand.java:44
↓ 5 callers
Method
debug
(String var1)
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyLogger.java:200
↓ 5 callers
Method
isEnabled
(InternalLogLevel internalLogLevel)
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyLogger.java:65
↓ 5 callers
Method
start
()
netty-framework/src/main/java/com/prestigeding/remoting/RemotingService.java:21
↓ 5 callers
Method
write
(ByteBuffer src)
netty-framework/src/main/java/com/prestigeding/remoting/netty/FileRegionEncoder.java:52
↓ 4 callers
Method
doBeforeRpcHooks
(String addr, RemotingCommand request)
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyRemotingAbstract.java:178
↓ 4 callers
Method
executeInvokeCallback
Execute callback in callback executor. If callback executor is null, run directly in current thread
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyRemotingAbstract.java:320
↓ 4 callers
Method
getChannel
()
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyEvent.java:40
↓ 4 callers
Method
getCode
()
netty-framework/src/main/java/com/prestigeding/remoting/protocol/LanguageCode.java:49
↓ 4 callers
Method
getCreateTimestamp
()
netty-framework/src/main/java/com/prestigeding/remoting/netty/RequestTask.java:65
↓ 4 callers
Method
getObject1
()
netty-framework/src/main/java/com/prestigeding/remoting/common/Pair.java:28
↓ 4 callers
Method
getRemoteAddr
()
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyEvent.java:36
↓ 4 callers
Method
getServerSelectorThreads
()
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyServerConfig.java:57
↓ 4 callers
Method
parseSocketAddressAddr
(SocketAddress socketAddress)
netty-framework/src/main/java/com/prestigeding/remoting/common/RemotingHelper.java:167
↓ 4 callers
Method
setSendRequestOK
(boolean sendRequestOK)
netty-framework/src/main/java/com/prestigeding/remoting/netty/ResponseFuture.java:88
↓ 4 callers
Method
shutdown
()
netty-framework/src/main/java/com/prestigeding/remoting/RemotingService.java:23
↓ 3 callers
Method
doAfterRpcHooks
(String addr, RemotingCommand request, RemotingCommand response)
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyRemotingAbstract.java:186
↓ 3 callers
Method
getAndCreateChannel
(final String addr)
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyRemotingClient.java:353
↓ 3 callers
Method
getConnectTimeoutMillis
()
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyClientConfig.java:67
↓ 3 callers
Method
getData
()
reactor-nio/src/main/java/com/prestigeding/nio/reactor/NioTask.java:32
↓ 3 callers
Method
getServiceName
()
netty-framework/src/main/java/com/prestigeding/remoting/common/ServiceThread.java:39
↓ 3 callers
Method
getServiceName
()
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyRemotingAbstract.java:617
↓ 3 callers
Method
isOnewayRPC
()
netty-framework/src/main/java/com/prestigeding/remoting/protocol/RemotingCommand.java:62
↓ 3 callers
Method
isStopRun
()
netty-framework/src/main/java/com/prestigeding/remoting/netty/RequestTask.java:69
↓ 3 callers
Method
isWritable
()
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyRemotingClient.java:559
↓ 3 callers
Method
markResponseType
()
netty-framework/src/main/java/com/prestigeding/remoting/protocol/RemotingCommand.java:52
↓ 3 callers
Method
normalizeHostAddress
(final InetAddress localHost)
netty-framework/src/main/java/com/prestigeding/remoting/common/RemotingUtil.java:139
↓ 3 callers
Method
putResponse
(final RemotingCommand responseCommand)
netty-framework/src/main/java/com/prestigeding/remoting/netty/ResponseFuture.java:75
↓ 3 callers
Method
valueOf
(byte code)
netty-framework/src/main/java/com/prestigeding/remoting/protocol/LanguageCode.java:40
↓ 2 callers
Method
buildSslContext
(boolean forClient)
netty-framework/src/main/java/com/prestigeding/remoting/netty/TlsHelper.java:92
↓ 2 callers
Method
callback
(RemotingCommand response)
netty-framework/src/main/java/com/prestigeding/remoting/netty/RemotingResponseCallback.java:23
↓ 2 callers
Method
createChannel
(final String addr)
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyRemotingClient.java:412
↓ 2 callers
Method
decryptPrivateKey
Decrypt the target encrpted private key file. @param privateKeyEncryptPath A pathname string @param forClient tells whether it's a client-side key fi
netty-framework/src/main/java/com/prestigeding/remoting/netty/TlsHelper.java:74
↓ 2 callers
Method
getCause
()
netty-framework/src/main/java/com/prestigeding/remoting/netty/ResponseFuture.java:100
↓ 2 callers
Method
getChannelFuture
()
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyRemotingClient.java:567
↓ 2 callers
Method
getJointime
()
netty-framework/src/main/java/com/prestigeding/remoting/common/ServiceThread.java:74
↓ 2 callers
Method
getName
()
netty-framework/src/main/java/com/prestigeding/remoting/common/TlsMode.java:50
↓ 2 callers
Method
getObject2
()
netty-framework/src/main/java/com/prestigeding/remoting/common/Pair.java:36
↓ 2 callers
Method
getOp
()
reactor-nio/src/main/java/com/prestigeding/nio/reactor/NioTask.java:26
↓ 2 callers
Method
invokeAsyncImpl
(final Channel channel, final RemotingCommand request, final long timeoutMillis, final InvokeCallback
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyRemotingAbstract.java:451
↓ 2 callers
Method
invokeOnewayImpl
(final Channel channel, final RemotingCommand request, final long timeoutMillis)
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyRemotingAbstract.java:532
↓ 2 callers
Method
invokeSyncImpl
(final Channel channel, final RemotingCommand request, final long timeoutMillis)
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyRemotingAbstract.java:417
↓ 2 callers
Method
isLinuxPlatform
()
netty-framework/src/main/java/com/prestigeding/remoting/common/RemotingUtil.java:90
↓ 2 callers
Method
isResponseType
()
netty-framework/src/main/java/com/prestigeding/remoting/protocol/RemotingCommand.java:85
↓ 2 callers
Method
isUseTLS
()
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyClientConfig.java:131
↓ 2 callers
Method
processMessageReceived
Entry of incoming command processing. <p> <strong>Note:</strong> The incoming remoting command may be <ul> <li>An inquiry request from a remote peer
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyRemotingAbstract.java:162
↓ 2 callers
Method
processRequest
(ChannelHandlerContext ctx, RemotingCommand request)
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyRequestProcessor.java:26
↓ 2 callers
Method
release
()
netty-framework/src/main/java/com/prestigeding/remoting/common/SemaphoreReleaseOnlyOnce.java:29
↓ 2 callers
Method
requestFail
(final int opaque)
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyRemotingAbstract.java:500
↓ 2 callers
Method
scanResponseTable
<p> This method is periodically invoked to scan and expire deprecated request. </p>
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyRemotingAbstract.java:393
↓ 2 callers
Method
useEpoll
()
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyRemotingServer.java:173
↓ 1 callers
Method
asyncProcessRequest
(ChannelHandlerContext ctx, RemotingCommand request, RemotingResponseCallback responseCallback)
netty-framework/src/main/java/com/prestigeding/remoting/netty/AsyncNettyRequestProcessor.java:25
↓ 1 callers
Method
connect
(SocketAddress remote)
netty-framework/src/main/java/com/prestigeding/remoting/common/RemotingUtil.java:164
↓ 1 callers
Method
connect
(ChannelHandlerContext ctx, SocketAddress remoteAddress, SocketAddress localAddress, ChannelPromis
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyRemotingClient.java:581
↓ 1 callers
Method
decode
(ByteBuf byteBuf)
netty-framework/src/main/java/com/prestigeding/remoting/protocol/CustomBody.java:7
↓ 1 callers
Method
dispatch
(SocketChannel socketChannel)
reactor-nio/src/main/java/com/prestigeding/nio/reactor/SubReactorThreadGroup.java:48
↓ 1 callers
Method
dispatch
此处的reqBuffer处于可写状态 @param sc @param reqBuffer
reactor-nio/src/main/java/com/prestigeding/nio/reactor/SubReactorThread.java:53
↓ 1 callers
Method
dispatch
(ServerSocketChannel ssc)
reactor-nio/src/main/java/com/prestigeding/nio/reactor/NioServer.java:47
↓ 1 callers
Method
doAfterResponse
(final String remoteAddr, final RemotingCommand request, final RemotingCommand response)
netty-framework/src/main/java/com/prestigeding/remoting/RPCHook.java:25
↓ 1 callers
Method
doBeforeRequest
(final String remoteAddr, final RemotingCommand request)
netty-framework/src/main/java/com/prestigeding/remoting/RPCHook.java:23
↓ 1 callers
Method
encode
()
netty-framework/src/main/java/com/prestigeding/remoting/protocol/CustomBody.java:6
↓ 1 callers
Method
exceptionSimpleDesc
(final Throwable e)
netty-framework/src/main/java/com/prestigeding/remoting/common/RemotingHelper.java:32
↓ 1 callers
Method
extractTlsConfigFromFile
(final File configFile)
netty-framework/src/main/java/com/prestigeding/remoting/netty/TlsHelper.java:161
↓ 1 callers
Method
failFast
mark the request of the specified channel as fail and to invoke fail callback immediately @param channel the channel which is close already
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyRemotingAbstract.java:519
↓ 1 callers
Method
getAndCreateNameserverChannel
()
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyRemotingClient.java:366
↓ 1 callers
Method
getBeginTimestamp
()
netty-framework/src/main/java/com/prestigeding/remoting/netty/ResponseFuture.java:80
↓ 1 callers
Method
getCallbackExecutor
This method specifies thread pool to use while invoking callback methods. @return Dedicated thread pool instance if specified; or null if the callbac
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyRemotingAbstract.java:386
↓ 1 callers
Method
getChannelEventListener
Custom channel event listener. @return custom channel event listener if defined; null otherwise.
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyRemotingAbstract.java:127
↓ 1 callers
Method
getClientAsyncSemaphoreValue
()
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyClientConfig.java:91
↓ 1 callers
Method
getClientCallbackExecutorThreads
()
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyClientConfig.java:75
↓ 1 callers
Method
getClientChannelMaxIdleTimeSeconds
()
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyClientConfig.java:99
↓ 1 callers
Method
getClientOnewaySemaphoreValue
()
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyClientConfig.java:59
↓ 1 callers
Method
getClientSocketRcvBufSize
()
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyClientConfig.java:115
↓ 1 callers
Method
getClientSocketSndBufSize
()
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyClientConfig.java:107
↓ 1 callers
Method
getClientWorkerThreads
()
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyClientConfig.java:51
↓ 1 callers
Method
getCustomBody
()
netty-framework/src/main/java/com/prestigeding/remoting/protocol/RemotingCommand.java:148
↓ 1 callers
Method
getInvokeCallback
()
netty-framework/src/main/java/com/prestigeding/remoting/netty/ResponseFuture.java:96
↓ 1 callers
Method
getListenPort
()
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyServerConfig.java:41
↓ 1 callers
Method
getProcessChannel
()
netty-framework/src/main/java/com/prestigeding/remoting/netty/ResponseFuture.java:120
↓ 1 callers
Method
getSc
()
reactor-nio/src/main/java/com/prestigeding/nio/reactor/NioTask.java:20
↓ 1 callers
Method
getServerAsyncSemaphoreValue
()
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyServerConfig.java:81
↓ 1 callers
Method
getServerCallbackExecutorThreads
()
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyServerConfig.java:73
next →
1–100 of 316, ranked by callers