Mercurial Hosting > luan
comparison src/org/eclipse/jetty/io/nio/ChannelEndPoint.java @ 1049:4afdf0f0c5bc
remove unused JBuffer methods
author | Franklin Schmidt <fschmidt@gmail.com> |
---|---|
date | Mon, 07 Nov 2016 23:34:48 -0700 |
parents | 2b769da7f67d |
children | 4a50422596b6 |
comparison
equal
deleted
inserted
replaced
1048:2b769da7f67d | 1049:4afdf0f0c5bc |
---|---|
166 @Override | 166 @Override |
167 public int fill(JBuffer buffer) throws IOException | 167 public int fill(JBuffer buffer) throws IOException |
168 { | 168 { |
169 if (_ishut) | 169 if (_ishut) |
170 return -1; | 170 return -1; |
171 JBuffer nbuf = buffer.buffer(); | |
172 int len = 0; | 171 int len = 0; |
173 final ByteBuffer bbuf = nbuf.getByteBuffer(); | 172 final ByteBuffer bbuf = buffer.getByteBuffer(); |
174 | 173 |
175 //noinspection SynchronizationOnLocalVariableOrMethodParameter | 174 //noinspection SynchronizationOnLocalVariableOrMethodParameter |
176 try | 175 try |
177 { | 176 { |
178 synchronized(bbuf) | 177 synchronized(bbuf) |
219 } | 218 } |
220 | 219 |
221 @Override | 220 @Override |
222 public int flush(JBuffer buffer) throws IOException | 221 public int flush(JBuffer buffer) throws IOException |
223 { | 222 { |
224 JBuffer nbuf = buffer.buffer(); | |
225 int len=0; | 223 int len=0; |
226 final ByteBuffer bbuf = nbuf.getByteBuffer().asReadOnlyBuffer(); | 224 final ByteBuffer bbuf = buffer.getByteBuffer().asReadOnlyBuffer(); |
227 try | 225 try |
228 { | 226 { |
229 bbuf.position(buffer.getIndex()); | 227 bbuf.position(buffer.getIndex()); |
230 bbuf.limit(buffer.putIndex()); | 228 bbuf.limit(buffer.putIndex()); |
231 len=_channel.write(bbuf); | 229 len=_channel.write(bbuf); |
241 @Override | 239 @Override |
242 public int flush(JBuffer header, JBuffer buffer, JBuffer trailer) throws IOException | 240 public int flush(JBuffer header, JBuffer buffer, JBuffer trailer) throws IOException |
243 { | 241 { |
244 int length=0; | 242 int length=0; |
245 | 243 |
246 JBuffer buf0 = header==null?null:header.buffer(); | |
247 JBuffer buf1 = buffer==null?null:buffer.buffer(); | |
248 | |
249 if (_channel instanceof GatheringByteChannel && | 244 if (_channel instanceof GatheringByteChannel && |
250 header!=null && header.remaining()!=0 && | 245 header!=null && header.remaining()!=0 && |
251 buffer!=null && buffer.remaining()!=0) | 246 buffer!=null && buffer.remaining()!=0) |
252 { | 247 { |
253 length = gatheringFlush(header,buf0.getByteBuffer(),buffer,buf1.getByteBuffer()); | 248 length = gatheringFlush(header,header.getByteBuffer(),buffer,buffer.getByteBuffer()); |
254 } | 249 } |
255 else | 250 else |
256 { | 251 { |
257 // flush header | 252 // flush header |
258 if (header!=null && header.remaining()>0) | 253 if (header!=null && header.remaining()>0) |