Mercurial Hosting > luan

comparison src/org/eclipse/jetty/io/nio/ChannelEndPoint.java @ 1049:4afdf0f0c5bc

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
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)