Skip to content
Browse files

Changes DechunkingChannelBuffer to use milliseconds since that's the …

…configuration provided value
  • Loading branch information...
1 parent 0de6104 commit 866b7fa53d41de1ef6ca158c8216c21b53e543aa @digitalstain committed Mar 19, 2013
Showing with 4 additions and 4 deletions.
  1. +4 −4 enterprise/com/src/main/java/org/neo4j/com/DechunkingChannelBuffer.java
View
8 enterprise/com/src/main/java/org/neo4j/com/DechunkingChannelBuffer.java
@@ -44,16 +44,16 @@
private ChannelBuffer buffer;
private boolean more;
private boolean hasMarkedReaderIndex;
- private final long timeoutSeconds;
+ private final long timeoutMillis;
private boolean failure;
private final byte applicationProtocolVersion;
private final byte internalProtocolVersion;
- DechunkingChannelBuffer( BlockingReadHandler<ChannelBuffer> reader, long timeoutSeconds, byte internalProtocolVersion,
+ DechunkingChannelBuffer( BlockingReadHandler<ChannelBuffer> reader, long timeoutMillis, byte internalProtocolVersion,
byte applicationProtocolVersion )
{
this.reader = reader;
- this.timeoutSeconds = timeoutSeconds;
+ this.timeoutMillis = timeoutMillis;
this.internalProtocolVersion = internalProtocolVersion;
this.applicationProtocolVersion = applicationProtocolVersion;
readNextChunk();
@@ -63,7 +63,7 @@ protected ChannelBuffer readNext()
{
try
{
- ChannelBuffer result = reader.read( timeoutSeconds, TimeUnit.SECONDS );
+ ChannelBuffer result = reader.read( timeoutMillis, TimeUnit.MILLISECONDS );
if ( result == null )
{
throw new ComException( "Channel has been closed" );

0 comments on commit 866b7fa

Please sign in to comment.
Something went wrong with that request. Please try again.