MCPcopy Create free account

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

Functions316 in github.com/dingwpmz/netty-learning

MethodgetRPCHooks
Custom RPC hooks. @return RPC hooks if specified; null otherwise.
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyRemotingAbstract.java:375
MethodgetRemark
()
netty-framework/src/main/java/com/prestigeding/remoting/protocol/RemotingCommand.java:124
MethodgetResponseCommand
()
netty-framework/src/main/java/com/prestigeding/remoting/netty/ResponseFuture.java:108
MethodgetSemaphore
()
netty-framework/src/main/java/com/prestigeding/remoting/common/SemaphoreReleaseOnlyOnce.java:36
MethodgetVersion
()
netty-framework/src/main/java/com/prestigeding/remoting/protocol/RemotingCommand.java:99
MethodhashCode
()
netty-framework/src/main/java/com/prestigeding/remoting/netty/RequestTask.java:36
MethodinitChannel
(SocketChannel ch)
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyRemotingClient.java:157
MethodinitChannel
(SocketChannel ch)
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyRemotingServer.java:206
MethodinvokeAsync
(final String addr, final RemotingCommand request, final long timeoutMillis, final InvokeCallback invo
netty-framework/src/main/java/com/prestigeding/remoting/RemotingClient.java:35
MethodinvokeAsync
(final Channel channel, final RemotingCommand request, final long timeoutMillis, final InvokeCallback
netty-framework/src/main/java/com/prestigeding/remoting/RemotingServer.java:43
MethodinvokeAsync
(String addr, RemotingCommand request, long timeoutMillis, InvokeCallback invokeCallback)
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyRemotingClient.java:469
MethodinvokeAsync
(Channel channel, RemotingCommand request, long timeoutMillis, InvokeCallback invokeCallback)
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyRemotingServer.java:318
MethodinvokeOneway
(final String addr, final RemotingCommand request, final long timeoutMillis)
netty-framework/src/main/java/com/prestigeding/remoting/RemotingClient.java:39
MethodinvokeOneway
(final Channel channel, final RemotingCommand request, final long timeoutMillis)
netty-framework/src/main/java/com/prestigeding/remoting/RemotingServer.java:47
MethodinvokeOneway
(String addr, RemotingCommand request, long timeoutMillis)
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyRemotingClient.java:494
MethodinvokeOneway
(Channel channel, RemotingCommand request, long timeoutMillis)
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyRemotingServer.java:324
MethodinvokeSync
(final String addr, final RemotingCommand request, final long timeoutMillis)
netty-framework/src/main/java/com/prestigeding/remoting/RemotingClient.java:31
MethodinvokeSync
(final Channel channel, final RemotingCommand request, final long timeoutMillis
netty-framework/src/main/java/com/prestigeding/remoting/RemotingServer.java:39
MethodinvokeSync
(String addr, final RemotingCommand request, long timeoutMillis)
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyRemotingClient.java:320
MethodinvokeSync
(final Channel channel, final RemotingCommand request, final long timeoutMillis)
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyRemotingServer.java:312
MethodisChannelWritable
(final String addr)
netty-framework/src/main/java/com/prestigeding/remoting/RemotingClient.java:50
MethodisChannelWritable
(String addr)
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyRemotingClient.java:524
MethodisClientPooledByteBufAllocatorEnable
()
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyClientConfig.java:123
MethodisDebugEnabled
()
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyLogger.java:195
MethodisErrorEnabled
()
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyLogger.java:285
MethodisInfoEnabled
()
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyLogger.java:225
MethodisOpen
()
netty-framework/src/main/java/com/prestigeding/remoting/netty/FileRegionEncoder.java:58
MethodisTimeout
()
netty-framework/src/main/java/com/prestigeding/remoting/netty/ResponseFuture.java:65
MethodisTraceEnabled
()
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyLogger.java:165
MethodisWarnEnabled
()
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyLogger.java:255
MethodisWindowsPlatform
()
netty-framework/src/main/java/com/prestigeding/remoting/common/RemotingUtil.java:55
MethodlocalListenPort
()
netty-framework/src/main/java/com/prestigeding/remoting/RemotingServer.java:35
MethodlocalListenPort
()
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyRemotingServer.java:302
Methodlog
(InternalLogLevel internalLogLevel, String s)
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyLogger.java:70
Methodmain
(String[] args)
reactor-nio/src/main/java/com/prestigeding/nio/reactor/SubReactorThreadGroup.java:57
Methodmain
(String[] args)
reactor-nio/src/main/java/com/prestigeding/nio/reactor/NioClient.java:15
Methodmain
(String[] args)
reactor-nio/src/main/java/com/prestigeding/nio/reactor/NioServer.java:15
Methodmain
(String[] args)
netty-framework/src/test/java/com/prestigeding/remoting/Test.java:7
MethodnewInstance
(String s)
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyLogger.java:46
MethodnewThread
(Runnable r)
reactor-nio/src/main/java/com/prestigeding/nio/reactor/SubReactorThreadGroup.java:33
MethodnewThread
(Runnable r)
reactor-nio/src/main/java/com/prestigeding/nio/reactor/NioServer.java:24
MethodnewThread
(Runnable r)
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyRemotingClient.java:105
MethodnewThread
(Runnable r)
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyRemotingServer.java:108
MethodopenSelector
()
netty-framework/src/main/java/com/prestigeding/remoting/common/RemotingUtil.java:59
MethodoperationComplete
(ChannelFuture future)
netty-framework/src/main/java/com/prestigeding/remoting/common/RemotingUtil.java:196
MethodoperationComplete
(ChannelFuture f)
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyRemotingAbstract.java:425
MethodputNettyEvent
(final NettyEvent event)
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyRemotingAbstract.java:573
MethodregisterDecryptionStrategy
(final DecryptionStrategy decryptionStrategy)
netty-framework/src/main/java/com/prestigeding/remoting/netty/TlsHelper.java:88
MethodregisterDefaultProcessor
(final NettyRequestProcessor processor, final ExecutorService executor)
netty-framework/src/main/java/com/prestigeding/remoting/RemotingServer.java:33
MethodregisterDefaultProcessor
(NettyRequestProcessor processor, ExecutorService executor)
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyRemotingServer.java:297
MethodregisterProcessor
(final int requestCode, final NettyRequestProcessor processor, final ExecutorService executor)
netty-framework/src/main/java/com/prestigeding/remoting/RemotingClient.java:43
MethodregisterProcessor
(final int requestCode, final NettyRequestProcessor processor, final ExecutorService executor)
netty-framework/src/main/java/com/prestigeding/remoting/RemotingServer.java:30
MethodregisterProcessor
(int requestCode, NettyRequestProcessor processor, ExecutorService executor)
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyRemotingClient.java:513
MethodregisterProcessor
(int requestCode, NettyRequestProcessor processor, ExecutorService executor)
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyRemotingServer.java:286
MethodregisterRPCHook
(RPCHook rpcHook)
netty-framework/src/main/java/com/prestigeding/remoting/RemotingService.java:25
MethodregisterRPCHook
(RPCHook rpcHook)
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyRemotingClient.java:268
MethodregisterRPCHook
(RPCHook rpcHook)
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyRemotingServer.java:279
MethodreturnResponse
(int code, String remark)
netty-framework/src/main/java/com/prestigeding/remoting/netty/RequestTask.java:83
Methodrun
()
reactor-nio/src/main/java/com/prestigeding/nio/reactor/MainReactor.java:22
Methodrun
()
reactor-nio/src/main/java/com/prestigeding/nio/reactor/Handler.java:23
Methodrun
()
reactor-nio/src/main/java/com/prestigeding/nio/reactor/SubReactorThread.java:59
Methodrun
()
reactor-nio/src/main/java/com/prestigeding/nio/reactor/NioServer.java:32
Methodrun
()
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyRemotingClient.java:178
Methodrun
()
netty-framework/src/main/java/com/prestigeding/remoting/netty/RequestTask.java:77
Methodrun
()
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyRemotingAbstract.java:208
Methodrun
()
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyRemotingAbstract.java:581
Methodrun
()
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyRemotingServer.java:237
MethodsetCallbackExecutor
(final ExecutorService callbackExecutor)
netty-framework/src/main/java/com/prestigeding/remoting/RemotingClient.java:46
MethodsetCallbackExecutor
(final ExecutorService callbackExecutor)
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyRemotingClient.java:543
MethodsetChannelNotActiveInterval
(long channelNotActiveInterval)
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyClientConfig.java:87
MethodsetClientAsyncSemaphoreValue
(int clientAsyncSemaphoreValue)
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyClientConfig.java:95
MethodsetClientCallbackExecutorThreads
(int clientCallbackExecutorThreads)
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyClientConfig.java:79
MethodsetClientChannelMaxIdleTimeSeconds
(int clientChannelMaxIdleTimeSeconds)
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyClientConfig.java:103
MethodsetClientCloseSocketIfTimeout
(final boolean clientCloseSocketIfTimeout)
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyClientConfig.java:47
MethodsetClientOnewaySemaphoreValue
(int clientOnewaySemaphoreValue)
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyClientConfig.java:63
MethodsetClientPooledByteBufAllocatorEnable
(boolean clientPooledByteBufAllocatorEnable)
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyClientConfig.java:127
MethodsetClientSocketRcvBufSize
(int clientSocketRcvBufSize)
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyClientConfig.java:119
MethodsetClientSocketSndBufSize
(int clientSocketSndBufSize)
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyClientConfig.java:111
MethodsetClientWorkerThreads
(int clientWorkerThreads)
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyClientConfig.java:55
MethodsetConnectTimeoutMillis
(int connectTimeoutMillis)
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyClientConfig.java:71
MethodsetCustomBody
(CustomBody customBody)
netty-framework/src/main/java/com/prestigeding/remoting/protocol/RemotingCommand.java:153
MethodsetData
(Object data)
reactor-nio/src/main/java/com/prestigeding/nio/reactor/NioTask.java:35
MethodsetExtFields
(HashMap<String, String> extFields)
netty-framework/src/main/java/com/prestigeding/remoting/protocol/RemotingCommand.java:137
MethodsetFlag
(int flag)
netty-framework/src/main/java/com/prestigeding/remoting/protocol/RemotingCommand.java:120
MethodsetLanguage
(LanguageCode language)
netty-framework/src/main/java/com/prestigeding/remoting/protocol/RemotingCommand.java:95
MethodsetListenPort
(int listenPort)
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyServerConfig.java:45
MethodsetObject1
(T1 object1)
netty-framework/src/main/java/com/prestigeding/remoting/common/Pair.java:32
MethodsetObject2
(T2 object2)
netty-framework/src/main/java/com/prestigeding/remoting/common/Pair.java:40
MethodsetOp
(int op)
reactor-nio/src/main/java/com/prestigeding/nio/reactor/NioTask.java:29
MethodsetSc
(SocketChannel sc)
reactor-nio/src/main/java/com/prestigeding/nio/reactor/NioTask.java:23
MethodsetServerAsyncSemaphoreValue
(int serverAsyncSemaphoreValue)
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyServerConfig.java:85
MethodsetServerCallbackExecutorThreads
(int serverCallbackExecutorThreads)
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyServerConfig.java:77
MethodsetServerChannelMaxIdleTimeSeconds
(int serverChannelMaxIdleTimeSeconds)
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyServerConfig.java:93
MethodsetServerOnewaySemaphoreValue
(int serverOnewaySemaphoreValue)
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyServerConfig.java:69
MethodsetServerPooledByteBufAllocatorEnable
(boolean serverPooledByteBufAllocatorEnable)
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyServerConfig.java:117
MethodsetServerSelectorThreads
(int serverSelectorThreads)
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyServerConfig.java:61
MethodsetServerSocketRcvBufSize
(int serverSocketRcvBufSize)
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyServerConfig.java:109
MethodsetServerSocketSndBufSize
(int serverSocketSndBufSize)
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyServerConfig.java:101
MethodsetServerWorkerThreads
(int serverWorkerThreads)
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyServerConfig.java:53
MethodsetStopRun
(final boolean stopRun)
netty-framework/src/main/java/com/prestigeding/remoting/netty/RequestTask.java:73
← previousnext →201–300 of 316, ranked by callers