MCPcopy Create free account

hub / github.com/dingwpmz/netty-learning / functions

Functions316 in github.com/dingwpmz/netty-learning

↓ 1 callersMethodgetServerChannelMaxIdleTimeSeconds
()
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyServerConfig.java:89
↓ 1 callersMethodgetServerOnewaySemaphoreValue
()
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyServerConfig.java:65
↓ 1 callersMethodgetServerSocketRcvBufSize
()
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyServerConfig.java:105
↓ 1 callersMethodgetServerSocketSndBufSize
()
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyServerConfig.java:97
↓ 1 callersMethodgetServerWorkerThreads
()
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyServerConfig.java:49
↓ 1 callersMethodgetTimeoutMillis
()
netty-framework/src/main/java/com/prestigeding/remoting/netty/ResponseFuture.java:92
↓ 1 callersMethodgetType
()
netty-framework/src/main/java/com/prestigeding/remoting/protocol/RemotingCommand.java:76
↓ 1 callersMethodgetType
()
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyEvent.java:32
↓ 1 callersMethodinitNettyLogger
()
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyLogger.java:34
↓ 1 callersMethodinitValueIndex
()
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyRemotingClient.java:133
↓ 1 callersMethodisClientCloseSocketIfTimeout
()
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyClientConfig.java:43
↓ 1 callersMethodisSendRequestOK
()
netty-framework/src/main/java/com/prestigeding/remoting/netty/ResponseFuture.java:84
↓ 1 callersMethodisServerPooledByteBufAllocatorEnable
()
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyServerConfig.java:113
↓ 1 callersMethodisStopped
()
netty-framework/src/main/java/com/prestigeding/remoting/common/ServiceThread.java:78
↓ 1 callersMethodisUseEpollNativeSelector
()
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyServerConfig.java:121
↓ 1 callersMethodloadSslContext
()
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyRemotingServer.java:157
↓ 1 callersMethodlogTheFinalUsedTlsConfig
()
netty-framework/src/main/java/com/prestigeding/remoting/netty/TlsHelper.java:198
↓ 1 callersMethodmarkOnewayRPC
()
netty-framework/src/main/java/com/prestigeding/remoting/protocol/RemotingCommand.java:57
↓ 1 callersMethodname
()
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyLogger.java:60
↓ 1 callersMethodonChannelClose
(final String remoteAddr, final Channel channel)
netty-framework/src/main/java/com/prestigeding/remoting/ChannelEventListener.java:24
↓ 1 callersMethodonChannelConnect
(final String remoteAddr, final Channel channel)
netty-framework/src/main/java/com/prestigeding/remoting/ChannelEventListener.java:22
↓ 1 callersMethodonChannelException
(final String remoteAddr, final Channel channel)
netty-framework/src/main/java/com/prestigeding/remoting/ChannelEventListener.java:26
↓ 1 callersMethodonChannelIdle
(final String remoteAddr, final Channel channel)
netty-framework/src/main/java/com/prestigeding/remoting/ChannelEventListener.java:28
↓ 1 callersMethodoperationComplete
(final ResponseFuture responseFuture)
netty-framework/src/main/java/com/prestigeding/remoting/InvokeCallback.java:22
↓ 1 callersMethodparse
(String mode)
netty-framework/src/main/java/com/prestigeding/remoting/common/TlsMode.java:40
↓ 1 callersMethodparseClientAuthMode
(String authMode)
netty-framework/src/main/java/com/prestigeding/remoting/netty/TlsHelper.java:215
↓ 1 callersMethodprepareSharableHandlers
()
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyRemotingServer.java:341
↓ 1 callersMethodprocessRequestCommand
Process incoming request command issued by remote peer. @param ctx channel handler context. @param cmd request command.
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyRemotingAbstract.java:201
↓ 1 callersMethodprocessResponseCommand
Process response from remote peer to the previous issued requests. @param ctx channel handler context. @param cmd response command instance.
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyRemotingAbstract.java:297
↓ 1 callersMethodrejectRequest
()
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyRequestProcessor.java:29
↓ 1 callersMethodsetBodyByteBuf
(ByteBuf bodyByteBuf)
netty-framework/src/main/java/com/prestigeding/remoting/protocol/RemotingCommand.java:162
↓ 1 callersMethodsetCause
(Throwable cause)
netty-framework/src/main/java/com/prestigeding/remoting/netty/ResponseFuture.java:104
↓ 1 callersMethodsetCode
(int code)
netty-framework/src/main/java/com/prestigeding/remoting/protocol/RemotingCommand.java:72
↓ 1 callersMethodsetRemark
(String remark)
netty-framework/src/main/java/com/prestigeding/remoting/protocol/RemotingCommand.java:128
↓ 1 callersMethodsetResponseCommand
(RemotingCommand responseCommand)
netty-framework/src/main/java/com/prestigeding/remoting/netty/ResponseFuture.java:112
↓ 1 callersMethodstring2SocketAddress
(final String addr)
netty-framework/src/main/java/com/prestigeding/remoting/common/RemotingHelper.java:48
↓ 1 callersMethodwaitResponse
(final long timeoutMillis)
netty-framework/src/main/java/com/prestigeding/remoting/netty/ResponseFuture.java:70
MethodChannelWrapper
(ChannelFuture channelFuture)
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyRemotingClient.java:551
MethodHandler
(SocketChannel sc, ByteBuffer reqBuffer, SubReactorThread parent)
reactor-nio/src/main/java/com/prestigeding/nio/reactor/Handler.java:15
MethodHandshakeHandler
(TlsMode tlsMode)
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyRemotingServer.java:354
MethodLanguageCode
(byte code)
netty-framework/src/main/java/com/prestigeding/remoting/protocol/LanguageCode.java:36
MethodMainReactor
(ServerSocketChannel channel)
reactor-nio/src/main/java/com/prestigeding/nio/reactor/MainReactor.java:13
MethodNettyBridgeLogger
(String name)
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyLogger.java:56
MethodNettyDecoder
()
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyDecoder.java:34
MethodNettyEvent
(NettyEventType type, String remoteAddr, Channel channel)
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyEvent.java:26
MethodNettyRemotingAbstract
Constructor, specifying capacity of one-way and asynchronous semaphores. @param permitsOneway Number of permits for one-way requests. @param permitsA
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyRemotingAbstract.java:117
MethodNettyRemotingClient
(final NettyClientConfig nettyClientConfig)
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyRemotingClient.java:87
MethodNettyRemotingServer
(final NettyServerConfig nettyServerConfig)
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyRemotingServer.java:89
MethodNioTask
(SocketChannel sc, int op)
reactor-nio/src/main/java/com/prestigeding/nio/reactor/NioTask.java:11
MethodPair
(T1 object1, T2 object2)
netty-framework/src/main/java/com/prestigeding/remoting/common/Pair.java:23
MethodRemotingCommand
()
netty-framework/src/main/java/com/prestigeding/remoting/protocol/RemotingCommand.java:41
MethodRemotingCommandException
(String message)
netty-framework/src/main/java/com/prestigeding/remoting/exception/RemotingCommandException.java:22
MethodRemotingConnectException
(String addr)
netty-framework/src/main/java/com/prestigeding/remoting/exception/RemotingConnectException.java:22
MethodRemotingException
(String message)
netty-framework/src/main/java/com/prestigeding/remoting/exception/RemotingException.java:22
MethodRemotingSendRequestException
(String addr)
netty-framework/src/main/java/com/prestigeding/remoting/exception/RemotingSendRequestException.java:22
MethodRemotingTimeoutException
(String message)
netty-framework/src/main/java/com/prestigeding/remoting/exception/RemotingTimeoutException.java:23
MethodRemotingTooMuchRequestException
(String message)
netty-framework/src/main/java/com/prestigeding/remoting/exception/RemotingTooMuchRequestException.java:22
MethodRequestTask
(final Runnable runnable, final Channel channel, final RemotingCommand request)
netty-framework/src/main/java/com/prestigeding/remoting/netty/RequestTask.java:30
MethodResponseFuture
(Channel channel, int opaque, long timeoutMillis, InvokeCallback invokeCallback, SemaphoreReleaseOnlyO
netty-framework/src/main/java/com/prestigeding/remoting/netty/ResponseFuture.java:42
MethodSemaphoreReleaseOnlyOnce
(Semaphore semaphore)
netty-framework/src/main/java/com/prestigeding/remoting/common/SemaphoreReleaseOnlyOnce.java:26
MethodServiceThread
()
netty-framework/src/main/java/com/prestigeding/remoting/common/ServiceThread.java:35
MethodSubReactorThread
业务线程池 @param businessExecutorPool
reactor-nio/src/main/java/com/prestigeding/nio/reactor/SubReactorThread.java:24
MethodSubReactorThreadGroup
()
reactor-nio/src/main/java/com/prestigeding/nio/reactor/SubReactorThreadGroup.java:22
MethodTlsMode
(String name)
netty-framework/src/main/java/com/prestigeding/remoting/common/TlsMode.java:36
MethodaddExtField
(String key, String value)
netty-framework/src/main/java/com/prestigeding/remoting/protocol/RemotingCommand.java:141
Methodcallback
(RemotingCommand response)
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyRemotingAbstract.java:213
MethodchannelActive
(ChannelHandlerContext ctx)
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyRemotingServer.java:435
MethodchannelInactive
(ChannelHandlerContext ctx)
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyRemotingServer.java:446
MethodchannelRead0
(ChannelHandlerContext ctx, RemotingCommand msg)
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyRemotingClient.java:574
MethodchannelRead0
(ChannelHandlerContext ctx, ByteBuf msg)
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyRemotingServer.java:358
MethodchannelRead0
(ChannelHandlerContext ctx, RemotingCommand msg)
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyRemotingServer.java:412
MethodchannelRegistered
(ChannelHandlerContext ctx)
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyRemotingServer.java:421
MethodchannelUnregistered
(ChannelHandlerContext ctx)
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyRemotingServer.java:428
MethodcheckFields
()
netty-framework/src/main/java/com/prestigeding/remoting/CommandCustomHeader.java:22
Methodclone
()
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyServerConfig.java:129
Methodclose
(ChannelHandlerContext ctx, ChannelPromise promise)
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyRemotingClient.java:607
Methoddecode
(ChannelHandlerContext ctx, ByteBuf in)
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyDecoder.java:40
MethoddecryptPrivateKey
(final String privateKeyEncryptPath, final boolean forClient)
netty-framework/src/main/java/com/prestigeding/remoting/netty/TlsHelper.java:80
Methoddisconnect
(ChannelHandlerContext ctx, ChannelPromise promise)
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyRemotingClient.java:595
Methodencode
(ChannelHandlerContext ctx, RemotingCommand cmd, ByteBuf out)
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyEncoder.java:37
Methodencode
Encode a message into a {@link io.netty.buffer.ByteBuf}. This method will be called for each written message that can be handled by this encoder. @pa
netty-framework/src/main/java/com/prestigeding/remoting/netty/FileRegionEncoder.java:49
MethodexceptionCaught
(ChannelHandlerContext ctx, Throwable cause)
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyRemotingClient.java:637
MethodexceptionCaught
(ChannelHandlerContext ctx, Throwable cause)
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyRemotingServer.java:475
MethodexecuteInvokeCallback
()
netty-framework/src/main/java/com/prestigeding/remoting/netty/ResponseFuture.java:51
MethodgetBodyByteBuf
()
netty-framework/src/main/java/com/prestigeding/remoting/protocol/RemotingCommand.java:157
MethodgetCallbackExecutor
()
netty-framework/src/main/java/com/prestigeding/remoting/RemotingClient.java:48
MethodgetCallbackExecutor
()
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyRemotingClient.java:538
MethodgetCallbackExecutor
()
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyRemotingServer.java:336
MethodgetChannelEventListener
()
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyRemotingClient.java:533
MethodgetChannelEventListener
()
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyRemotingServer.java:330
MethodgetChannelNotActiveInterval
()
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyClientConfig.java:83
MethodgetCode
()
netty-framework/src/main/java/com/prestigeding/remoting/protocol/RemotingCommand.java:68
MethodgetExtFields
()
netty-framework/src/main/java/com/prestigeding/remoting/protocol/RemotingCommand.java:132
MethodgetFlag
()
netty-framework/src/main/java/com/prestigeding/remoting/protocol/RemotingCommand.java:115
MethodgetLanguage
()
netty-framework/src/main/java/com/prestigeding/remoting/protocol/RemotingCommand.java:91
MethodgetLocalAddress
()
netty-framework/src/main/java/com/prestigeding/remoting/common/RemotingUtil.java:94
MethodgetOpaque
()
netty-framework/src/main/java/com/prestigeding/remoting/protocol/RemotingCommand.java:107
MethodgetProcessorPair
(final int requestCode)
netty-framework/src/main/java/com/prestigeding/remoting/RemotingServer.java:37
MethodgetProcessorPair
(int requestCode)
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyRemotingServer.java:307
MethodgetRPCHook
Custom RPC hook. Just be compatible with the previous version, use getRPCHooks instead.
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyRemotingAbstract.java:362
← previousnext →101–200 of 316, ranked by callers