@@ -88,7 +88,7 @@ private class MemoryEndPoint extends AbstractEndPoint
8888 private static final RetainableByteBuffer EOF = RetainableByteBuffer .EMPTY ;
8989
9090 private final AutoLock lock = new AutoLock ();
91- private final Deque <RetainableByteBuffer > buffers = new ArrayDeque <>();
91+ private final Deque <RetainableByteBuffer > byteBuffers = new ArrayDeque <>();
9292 private final SocketAddress localAddress ;
9393 private MemoryEndPoint peerEndPoint ;
9494 private Invocable .Task fillableTask ;
@@ -183,7 +183,7 @@ private int fillInto(ByteBuffer dest)
183183 {
184184 while (true )
185185 {
186- RetainableByteBuffer data = buffers .peek ();
186+ RetainableByteBuffer data = byteBuffers .peek ();
187187 if (data == null )
188188 return filled ;
189189 if (data == EOF )
@@ -201,7 +201,7 @@ private int fillInto(ByteBuffer dest)
201201 // Copy all and consume
202202 data .putTo (dest );
203203 data .release ();
204- buffers .poll ();
204+ byteBuffers .poll ();
205205 }
206206 else
207207 {
@@ -237,7 +237,7 @@ public void fillInterested(Callback callback)
237237 {
238238 // Checking for data and setting the callback must be atomic,
239239 // otherwise the notification issued by a write() may be lost.
240- if (peerEndPoint .buffers .isEmpty ())
240+ if (peerEndPoint .byteBuffers .isEmpty ())
241241 {
242242 super .fillInterested (callback );
243243 return ;
@@ -255,7 +255,7 @@ public boolean tryFillInterested(Callback callback)
255255 {
256256 // Checking for data and setting the callback must be atomic,
257257 // otherwise the notification issued by a write() may be lost.
258- if (peerEndPoint .buffers .isEmpty ())
258+ if (peerEndPoint .byteBuffers .isEmpty ())
259259 return super .tryFillInterested (callback );
260260 }
261261 if (LOG .isDebugEnabled ())
@@ -291,7 +291,7 @@ public boolean flush(ByteBuffer... buffers) throws IOException
291291 result = false ;
292292 break ;
293293 }
294- this .buffers .offer (copy );
294+ this .byteBuffers .offer (copy );
295295 int length = (int )copy .size ();
296296 capacity += length ;
297297 flushed += length ;
@@ -358,7 +358,7 @@ protected void doShutdownOutput()
358358 super .doShutdownOutput ();
359359 try (AutoLock ignored = lock .lock ())
360360 {
361- buffers .offer (EOF );
361+ byteBuffers .offer (EOF );
362362 }
363363 onFlushed ();
364364 }
@@ -369,9 +369,9 @@ protected void doClose()
369369 super .doClose ();
370370 try (AutoLock ignored = lock .lock ())
371371 {
372- RetainableByteBuffer last = buffers .peekLast ();
372+ RetainableByteBuffer last = byteBuffers .peekLast ();
373373 if (last != EOF )
374- buffers .offer (EOF );
374+ byteBuffers .offer (EOF );
375375 }
376376 onFlushed ();
377377 }
0 commit comments