Lines Matching refs:endPoint
35 private final EndPoint endPoint; field in ReadAheadEndpoint
43 return endPoint.getLocalAddress(); in getLocalAddress()
47 return endPoint.getRemoteAddress(); in getRemoteAddress()
51 return endPoint.isOpen(); in isOpen()
55 return endPoint.getCreatedTimeStamp(); in getCreatedTimeStamp()
59 return endPoint.isOutputShutdown(); in isOutputShutdown()
63 return endPoint.isInputShutdown(); in isInputShutdown()
67 endPoint.shutdownOutput(); in shutdownOutput()
71 endPoint.close(); in close()
75 return endPoint.getTransport(); in getTransport()
79 return endPoint.getIdleTimeout(); in getIdleTimeout()
83 return endPoint.getConnection(); in getConnection()
87 endPoint.onOpen(); in onOpen()
91 endPoint.onClose(); in onClose()
95 return endPoint.isOptimizedForDirectBuffers(); in isOptimizedForDirectBuffers()
99 return endPoint.isFillInterested(); in isFillInterested()
103 return endPoint.tryFillInterested(v); in tryFillInterested()
107 return endPoint.flush(v); in flush()
111 endPoint.setIdleTimeout(v); in setIdleTimeout()
115 endPoint.write(v, b); in write()
119 endPoint.setConnection(v); in setConnection()
123 endPoint.upgrade(v); in upgrade()
127 endPoint.fillInterested(v); in fillInterested()
135 this.endPoint = channel; in ReadAheadEndpoint()
145 n = endPoint.fill(start); in readAhead()
146 } while (n == 0 && endPoint.isOpen() && !endPoint.isInputShutdown()); in readAhead()
185 return sr + endPoint.fill(dst); in fill()