Skip to content
This repository

Changes DechunkingChannelBuffer to use milliseconds since that's the configuration provided value #642

Merged
merged 1 commit into from over 1 year ago

2 participants

Chris Gioran Jacob Hansson
Chris Gioran
Collaborator

No description provided.

Jacob Hansson jakewins merged commit 13f5302 into from
Jacob Hansson jakewins closed this
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Showing 1 unique commit by 1 author.

Mar 19, 2013
Chris Gioran digitalstain Changes DechunkingChannelBuffer to use milliseconds since that's the …
…configuration provided value
866b7fa
This page is out of date. Refresh to see the latest.
8 enterprise/com/src/main/java/org/neo4j/com/DechunkingChannelBuffer.java
@@ -44,16 +44,16 @@
44 44 private ChannelBuffer buffer;
45 45 private boolean more;
46 46 private boolean hasMarkedReaderIndex;
47   - private final long timeoutSeconds;
  47 + private final long timeoutMillis;
48 48 private boolean failure;
49 49 private final byte applicationProtocolVersion;
50 50 private final byte internalProtocolVersion;
51 51
52   - DechunkingChannelBuffer( BlockingReadHandler<ChannelBuffer> reader, long timeoutSeconds, byte internalProtocolVersion,
  52 + DechunkingChannelBuffer( BlockingReadHandler<ChannelBuffer> reader, long timeoutMillis, byte internalProtocolVersion,
53 53 byte applicationProtocolVersion )
54 54 {
55 55 this.reader = reader;
56   - this.timeoutSeconds = timeoutSeconds;
  56 + this.timeoutMillis = timeoutMillis;
57 57 this.internalProtocolVersion = internalProtocolVersion;
58 58 this.applicationProtocolVersion = applicationProtocolVersion;
59 59 readNextChunk();
@@ -63,7 +63,7 @@ protected ChannelBuffer readNext()
63 63 {
64 64 try
65 65 {
66   - ChannelBuffer result = reader.read( timeoutSeconds, TimeUnit.SECONDS );
  66 + ChannelBuffer result = reader.read( timeoutMillis, TimeUnit.MILLISECONDS );
67 67 if ( result == null )
68 68 {
69 69 throw new ComException( "Channel has been closed" );

Tip: You can add notes to lines in a file. Hover to the left of a line to make a note

Something went wrong with that request. Please try again.