| org.xsocket.connection |
Provides classes to handle a connection-oriented, sequenced flow of data in a blocking
or non-blocking mode on the server and on the client side.
|
| Java Source File Name | Type | Comment |
| AbstractNonBlockingStream.java | Class | Base implementation of a data stream. |
| AsyncFlushModeTest.java | Class | |
| AttachmentTest.java | Class | |
| BenchmarkingClients.java | Class | |
| BenchmarkingProxies.java | Class | |
| BlockingClient.java | Class | |
| BlockingClientTest.java | Class | |
| BlockingConnection.java | Class | Implementation of the IBlockingConnection interface. |
| BlockingConnectionPool.java | Class | A blocking connection pool implementation. |
| BlockingConnectionPoolTest.java | Class | |
| BlockingConnectionTest.java | Class | |
| BulkClient.java | Class | |
| BulkDownloadServer.java | Class | |
| BulkUploadServer.java | Class | |
| ByteBufferParserTest.java | Class | |
| ByteBufferUtil.java | Class | |
| CachedDelimiterPositionTest.java | Class | |
| ChainedRecordsCallTest.java | Class | |
| ChannelCloseTest.java | Class | |
| ChannelWriteTest.java | Class | |
| ClassicProxy.java | Class | |
| ClassicStreamTest.java | Class | |
| CloseTest.java | Class | |
| CompatibilityFileChannelTest.java | Class | |
| CompatibilityReadableByteChannelTest.java | Class | |
| CompatibilityWriteableByteChannelTest.java | Class | |
| ComplexExampleTest.java | Class | |
| ConcurrentCallbackCallsTest.java | Class | |
| ConcurrentReadWriteTest.java | Class | |
| ConnectionPoolMBeanProxyFactory.java | Class | A Mbean proxy factory, which creates and registers an appropriated mbean
for a given connction pool instance. |
| ConnectionScopedTest.java | Class | |
| ConnectionUtils.java | Class | |
| ConnectionUtilsTest.java | Class | |
| DataPackagesTest.java | Class | |
| DataTypesTest.java | Class | |
| DecoupledReceiveAndConsumeTest.java | Class | |
| DevNullHandler.java | Class | |
| DisconnectTest.java | Class | |
| EchoHandler.java | Class | |
| EchoServer.java | Class | |
| EchoServerTest.java | Class | |
| EndOfFileTest.java | Class | |
| FlushOnCloseTest.java | Class | |
| FlushTest.java | Class | |
| GrizzlyServer.java | Class | |
| HandlerAutoflushTest.java | Class | |
| HandlerProxy.java | Class | |
| HandlerProxyTest.java | Class | |
| HandlerSynchronizeTest.java | Class | |
| HandlerThrowsIOExceptionTest.java | Class | |
| IBlockingConnection.java | Interface | A connection which accesses the underlying channel in a non-blocking manner. |
| IConnectHandler.java | Interface | Handles new incoming connections. |
| IConnection.java | Interface | A connection (session) between two endpoints. |
| IConnectionPool.java | Interface | A connection pool manages a pool of open connections. |
| IConnectionScoped.java | Interface | Defines that the
IHandler is connection scoped. |
| IConnectionTimeoutHandler.java | Interface | Handles connection timeout. |
| IDataHandler.java | Interface | Reads and processes the incoming data. |
| IDisconnectHandler.java | Interface | Handles the disconnecting of connections. |
| IHandler.java | Interface | A marker interface for a handler
Specific handlers defines on<event> callback methods. |
| IHandlerAdapter.java | Interface | Adapter interface, which is implemented by xSocket extension such as http or multiplexed.
By implementing this interface the adapted handler will be exported by JMX instead of the adapter. |
| IHttpConnection.java | Interface | |
| IHttpMessageHandler.java | Interface | |
| IIdleTimeoutHandler.java | Interface | Handles idle timeout. |
| IInternalHandler.java | Interface | |
| IncompleteDataReceivedTest.java | Class | |
| IndexOfTest.java | Class | |
| INonBlockingConnection.java | Interface | A connection which accesses the underlying channel in a non-blocking manner. |
| IsAssertionActivatedTest.java | Class | |
| IServer.java | Interface | A server accepts new incoming connections, and delegates the handling of the
INonBlockingConnection to the assigned handler.
The server includes dispatchers, which are responsible to perform the
socket I/O operations. |
| IServerListener.java | Interface | |
| JavaProcess.java | Class | |
| LargeDataTransferTest.java | Class | |
| LifeCycleTest.java | Class | |
| LoadClient.java | Class | |
| MarkAndResetTest.java | Class | |
| MarkAndResetWithDelimiterTest.java | Class | |
| MaxReadSizeExceededTest.java | Class | |
| MinaNativeServer.java | Class | |
| MinaServer.java | Class | |
| MixedThreadedTest.java | Class | |
| NonBlockingClient.java | Class | |
| NonBlockingClientTest.java | Class | |
| NonBlockingConnection.java | Class | Implementation of the INonBlockingConnection interface. |
| NonBlockingConnectionClientHandlerTest.java | Class | |
| NonBlockingConnectionClientTest.java | Class | |
| NonBlockingConnectionPool.java | Class | A connection pool implementation.
This class is thread safe
// create a unbound connection pool
NonBlockingConnectionPool pool = new NonBlockingConnectionPool();
INonBlockingCinnection con = null;
try {
// retrieve a connection (if no connection is in pool, a new one will be created)
con = pool.getNonBlockingConnection(host, port);
con.write("Hello");
... |
| NonBlockingConnectionPoolHandlerTest.java | Class | |
| NonBlockingConnectionPoolTest.java | Class | |
| NonBlockingConnectionSinglethreadedTest.java | Class | |
| NonBlockingConnnectionResetTest.java | Class | |
| NonBlockingWriteLoopTest.java | Class | |
| NonThreadedEchoHandler.java | Class | |
| NonThreadedTest.java | Class | |
| OnConnectTest.java | Class | |
| OnHandlerMethodsOrderTest.java | Class | |
| PendingWriteDataTest.java | Class | |
| PrintServer.java | Class | |
| Proxy.java | Class | |
| ProxyTest.java | Class | |
| QAUtil.java | Class | |
| ReadableByteBufferTest.java | Class | |
| ReadableTest.java | Class | |
| ReadByDelimiterAndMaxSizeTest.java | Class | |
| ReadByteBufferTest.java | Class | |
| ReadErrorTest.java | Class | |
| ReadOnServerCloseTest.java | Class | |
| ReadQeueTest.java | Class | |
| ReadQueue.java | Class | |
| ReadSuspendAndResumeTest.java | Class | |
| RepeatedCloseTest.java | Class | |
| RepeatedOnDataTest.java | Class | |
| Server.java | Class | Implementation of a server. |
| ServerContextTest.java | Class | |
| ServerMBeanProxyFactory.java | Class | A Mbean proxy factory, which creates and registers an appropriated mbean
for a given
Server instance. |
| ServerPush.java | Class | |
| SimpleFileChannelPerformanceTest.java | Class | |
| SimpleNonBlockingClientConnectionTest.java | Class | |
| SimultaneousReadWriteTest.java | Class | |
| SingleConnectionLoadClient.java | Class | |
| SmallPacketTest.java | Class | |
| SocketOptionsTest.java | Class | |
| SpringTest.java | Class | |
| SSLLargeDataTest.java | Class | |
| SSLUserActivatedTest.java | Class | |
| SSLxSocketBothSideTest.java | Class | |
| SSLxSocketClientTest.java | Class | |
| SSLxSocketServerTest.java | Class | |
| Statistic.java | Class | |
| SyncFlushModeTest.java | Class | |
| TestUtil.java | Class | |
| ThrottledReadTest.java | Class | |
| ThrottledWriteTest.java | Class | |
| TimeoutTest.java | Class | |
| TransferAvailableByDelimiterTest.java | Class | |
| UncleanDisconnectProcessKillTest.java | Class | |
| UncleanDisconnectTest.java | Class | |
| UnsynchronizedTest.java | Class | |
| WriteQueue.java | Class | |
| XSocketEchoServer.java | Class | |