[#DIRMINA-39] Future interface for asynchronous operations

MINA

Future interface for asynchronous operations

Created: 13/May/05 04:26 PM Updated: 12/Jun/05 09:07 PM

Return to search

Component/s:

None

Affects Version/s:

0.7.0, 0.7.1, 0.8.0

Fix Version/s:

0.9.0

Time Tracking:

Not Specified

Issue Links:

dependent

This issue is depended upon by:

~~DIRMINA-38~~ Adding a flush method to ProtocolEncoderOutput

Resolution Date:

12/Jun/05 09:07 PM

Description

« Hide

There's no method user can wait for the message (or buffer) until it is flushed out to channel actually. We could create an interface similar to Future in Java 5 so that users can wait until or check if the request is done.

We could also apply this mechanism to close instead of specifying a boolean parameter.

All

Comments

Work Log

Change History

Subversion Commits

Sort Order:

[ Permlink | « Hide ]

Trustin Lee added a comment - 13/May/05 04:28 PM

flush() method will also return Future so that codec can await.

Trustin Lee made changes - 13/May/05 04:28 PM

Field	Original Value	New Value
Link		This issue is depended upon by ~~DIRMINA-38~~ [ ~~DIRMINA-38~~ ]

Trustin Lee made changes - 13/May/05 04:32 PM

Affects Version/s		0.8 [ 11068 ]
Affects Version/s		0.7.1 [ 11171 ]

Repository	Revision	Date	User	Message
ASF	#188680	Tue Jun 07 03:36:04 UTC 2005	trustin	Branching to resolve ~~DIRMINA-39~~
				Files Changed
				REPLACE /directory/network/branches/dirmina-39/src/test/org/apache/mina/transport/socket/nio/DatagramBindTest.java (from /directory/network/trunk/src/test/org/apache/mina/transport/socket/nio/DatagramBindTest.java) MODIFY /directory/network/branches/dirmina-39/src/java/org/apache/mina/transport/socket/nio/SocketSessionManagerFilterChain.java REPLACE /directory/network/branches/dirmina-39/src/java/org/apache/mina/transport/socket/nio/SocketAcceptor.java (from /directory/network/trunk/src/java/org/apache/mina/transport/socket/nio/SocketAcceptor.java) REPLACE /directory/network/branches/dirmina-39/src/java/org/apache/mina/filter/SSLFilter.java (from /directory/network/trunk/src/java/org/apache/mina/filter/SSLFilter.java) MODIFY /directory/network/branches/dirmina-39/src/java/org/apache/mina/common/IoFilterAdapter.java MODIFY /directory/network/branches/dirmina-39/src/java/org/apache/mina/common/IoSession.java ADD /directory/network/branches/dirmina-39 (from /directory/network/trunk) REPLACE /directory/network/branches/dirmina-39/src/java/org/apache/mina/handler/DemuxingIoHandler.java (from /directory/network/trunk/src/java/org/apache/mina/handler/DemuxingIoHandler.java) MODIFY /directory/network/branches/dirmina-39/src/java/org/apache/mina/common/ByteBuffer.java REPLACE /directory/network/branches/dirmina-39/src/java/org/apache/mina/transport/socket/nio/SocketConnector.java (from /directory/network/trunk/src/java/org/apache/mina/transport/socket/nio/SocketConnector.java) MODIFY /directory/network/branches/dirmina-39/src/java/org/apache/mina/common/IoSessionManagerFilterChain.java MODIFY /directory/network/branches/dirmina-39/src/java/org/apache/mina/filter/codec/ProtocolCodecFilter.java MODIFY /directory/network/branches/dirmina-39/src/java/org/apache/mina/transport/socket/nio/DatagramSession.java MODIFY /directory/network/branches/dirmina-39/src/java/org/apache/mina/filter/codec/SimpleProtocolEncoderOutput.java REPLACE /directory/network/branches/dirmina-39/src/test/org/apache/mina/transport/socket/nio/SocketBindTest.java (from /directory/network/trunk/src/test/org/apache/mina/transport/socket/nio/SocketBindTest.java) MODIFY /directory/network/branches/dirmina-39/src/java/org/apache/mina/filter/LoggingFilter.java MODIFY /directory/network/branches/dirmina-39/src/java/org/apache/mina/transport/socket/nio/DatagramSessionManagerFilterChain.java MODIFY /directory/network/branches/dirmina-39/src/java/org/apache/mina/common/IoFilter.java MODIFY /directory/network/branches/dirmina-39/src/java/org/apache/mina/common/AbstractIoFilterChain.java MODIFY /directory/network/branches/dirmina-39/src/java/org/apache/mina/handler/StreamIoHandler.java MODIFY /directory/network/branches/dirmina-39/src/java/org/apache/mina/common/BaseIoSession.java REPLACE /directory/network/branches/dirmina-39/src/java/org/apache/mina/transport/socket/nio/DatagramConnector.java (from /directory/network/trunk/src/java/org/apache/mina/transport/socket/nio/DatagramConnector.java) REPLACE /directory/network/branches/dirmina-39/src/java/org/apache/mina/transport/socket/nio/DatagramAcceptor.java (from /directory/network/trunk/src/java/org/apache/mina/transport/socket/nio/DatagramAcceptor.java) MODIFY /directory/network/branches/dirmina-39/src/java/org/apache/mina/common/IoSessionFilterChain.java MODIFY /directory/network/branches/dirmina-39/project.xml MODIFY /directory/network/branches/dirmina-39/src/java/org/apache/mina/filter/codec/ProtocolEncoderOutput.java REPLACE /directory/network/branches/dirmina-39/src/java/org/apache/mina/filter/SSLHandler.java (from /directory/network/trunk/src/java/org/apache/mina/filter/SSLHandler.java) MODIFY /directory/network/branches/dirmina-39/src/java/org/apache/mina/filter/ThreadPoolFilter.java MODIFY /directory/network/branches/dirmina-39/src/java/org/apache/mina/transport/socket/nio/SocketSession.java

Trustin Lee made changes - 07/Jun/05 12:59 PM

Status

Open [ 1 ]

In Progress [ 3 ]

Repository	Revision	Date	User	Message
ASF	#190245	Sun Jun 12 11:25:23 UTC 2005	trustin	Resolved ~~DIRMINA-39~~
				Files Changed
				MODIFY /directory/network/branches/dirmina-39/src/java/org/apache/mina/filter/SSLFilter.java MODIFY /directory/network/branches/dirmina-39/src/java/org/apache/mina/transport/vmpipe/VmPipeSession.java MODIFY /directory/network/branches/dirmina-39/src/java/org/apache/mina/common/IoFilterAdapter.java MODIFY /directory/network/branches/dirmina-39/src/java/org/apache/mina/common/IoSession.java MODIFY /directory/network/branches/dirmina-39/src/test/org/apache/mina/examples/echoserver/ConnectorTest.java MODIFY /directory/network/branches/dirmina-39/src/test/org/apache/mina/filter/codec/CumulativeProtocolDecoderTest.java ADD /directory/network/branches/dirmina-39/src/java/org/apache/mina/common/IoFuture.java MODIFY /directory/network/branches/dirmina-39/src/java/org/apache/mina/common/ByteBuffer.java MODIFY /directory/network/branches/dirmina-39/src/java/org/apache/mina/transport/socket/nio/SocketIoProcessor.java MODIFY /directory/network/branches/dirmina-39/src/java/org/apache/mina/filter/codec/ProtocolCodecFilter.java MODIFY /directory/network/branches/dirmina-39/src/java/org/apache/mina/transport/socket/nio/DatagramSession.java MODIFY /directory/network/branches/dirmina-39/src/test/org/apache/mina/common/IoFilterChainTest.java MODIFY /directory/network/branches/dirmina-39/src/java/org/apache/mina/filter/LoggingFilter.java MODIFY /directory/network/branches/dirmina-39/src/examples/org/apache/mina/examples/tennis/Main.java ADD /directory/network/branches/dirmina-39/src/java/org/apache/mina/common/WriteFuture.java MODIFY /directory/network/branches/dirmina-39/src/java/org/apache/mina/common/AbstractIoFilterChain.java MODIFY /directory/network/branches/dirmina-39/src/java/org/apache/mina/transport/socket/nio/DatagramAcceptor.java MODIFY /directory/network/branches/dirmina-39/src/java/org/apache/mina/common/IoSessionFilterChain.java ADD /directory/network/branches/dirmina-39/src/java/org/apache/mina/common/CloseFuture.java MODIFY /directory/network/branches/dirmina-39/src/java/org/apache/mina/filter/codec/ProtocolEncoderOutput.java MODIFY /directory/network/branches/dirmina-39/src/java/org/apache/mina/filter/SSLHandler.java MODIFY /directory/network/branches/dirmina-39/src/java/org/apache/mina/filter/ThreadPoolFilter.java MODIFY /directory/network/branches/dirmina-39/src/java/org/apache/mina/transport/socket/nio/SocketSessionManagerFilterChain.java MODIFY /directory/network/branches/dirmina-39/src/java/org/apache/mina/transport/vmpipe/VmPipeSessionManagerFilterChain.java MODIFY /directory/network/branches/dirmina-39/src/java/org/apache/mina/transport/socket/nio/SocketConnector.java ADD /directory/network/branches/dirmina-39/src/java/org/apache/mina/common/ConnectFuture.java MODIFY /directory/network/branches/dirmina-39/src/java/org/apache/mina/common/IoSessionManagerFilterChain.java MODIFY /directory/network/branches/dirmina-39/src/java/org/apache/mina/transport/vmpipe/VmPipeConnector.java MODIFY /directory/network/branches/dirmina-39/src/java/org/apache/mina/common/IoConnector.java MODIFY /directory/network/branches/dirmina-39/src/java/org/apache/mina/filter/codec/SimpleProtocolEncoderOutput.java MODIFY /directory/network/branches/dirmina-39/src/java/org/apache/mina/transport/socket/nio/DatagramSessionManagerFilterChain.java MODIFY /directory/network/branches/dirmina-39/src/java/org/apache/mina/common/IoFilter.java MODIFY /directory/network/branches/dirmina-39/src/java/org/apache/mina/transport/socket/nio/DatagramConnector.java MODIFY /directory/network/branches/dirmina-39/project.xml MODIFY /directory/network/branches/dirmina-39/src/java/org/apache/mina/transport/socket/nio/SocketSession.java

Trustin Lee made changes - 12/Jun/05 09:07 PM

Resolution		Fixed [ 1 ]
Status	In Progress [ 3 ]	Closed [ 6 ]