comparison src/org/eclipse/jetty/server/nio/BlockingChannelConnector.java @ 1075:ebb0f1343ef6

remove JBuffer
author Franklin Schmidt <fschmidt@gmail.com>
date Thu, 10 Nov 2016 03:08:20 -0700
parents 2b769da7f67d
children
comparison
equal deleted inserted replaced
1074:6b7ff30bb990 1075:ebb0f1343ef6
19 package org.eclipse.jetty.server.nio; 19 package org.eclipse.jetty.server.nio;
20 20
21 import java.io.IOException; 21 import java.io.IOException;
22 import java.net.InetSocketAddress; 22 import java.net.InetSocketAddress;
23 import java.net.Socket; 23 import java.net.Socket;
24 import java.nio.ByteBuffer;
24 import java.nio.channels.ByteChannel; 25 import java.nio.channels.ByteChannel;
25 import java.nio.channels.SelectionKey; 26 import java.nio.channels.SelectionKey;
26 import java.nio.channels.ServerSocketChannel; 27 import java.nio.channels.ServerSocketChannel;
27 import java.nio.channels.SocketChannel; 28 import java.nio.channels.SocketChannel;
28 import java.util.Set; 29 import java.util.Set;
29 import java.util.concurrent.ConcurrentHashMap; 30 import java.util.concurrent.ConcurrentHashMap;
30 import java.util.concurrent.RejectedExecutionException; 31 import java.util.concurrent.RejectedExecutionException;
31 32
32 import org.eclipse.jetty.http.HttpException; 33 import org.eclipse.jetty.http.HttpException;
33 import org.eclipse.jetty.io.JBuffer;
34 import org.eclipse.jetty.io.EndPoint; 34 import org.eclipse.jetty.io.EndPoint;
35 import org.eclipse.jetty.io.EofException; 35 import org.eclipse.jetty.io.EofException;
36 import org.eclipse.jetty.io.nio.ChannelEndPoint; 36 import org.eclipse.jetty.io.nio.ChannelEndPoint;
37 import org.eclipse.jetty.server.BlockingHttpConnection; 37 import org.eclipse.jetty.server.BlockingHttpConnection;
38 import org.eclipse.jetty.server.Connector; 38 import org.eclipse.jetty.server.Connector;
169 } 169 }
170 } 170 }
171 } 171 }
172 172
173 @Override 173 @Override
174 public int fill(JBuffer buffer) throws IOException 174 public int fill(ByteBuffer buffer) throws IOException
175 { 175 {
176 _idleTimestamp = System.currentTimeMillis(); 176 _idleTimestamp = System.currentTimeMillis();
177 return super.fill(buffer); 177 return super.fill(buffer);
178 } 178 }
179 179
180 @Override 180 @Override
181 public int flush(JBuffer buffer) throws IOException 181 public int flush(ByteBuffer buffer) throws IOException
182 { 182 {
183 _idleTimestamp = System.currentTimeMillis(); 183 _idleTimestamp = System.currentTimeMillis();
184 return super.flush(buffer); 184 return super.flush(buffer);
185 } 185 }
186 186
187 @Override 187 @Override
188 public int flush(JBuffer header, JBuffer buffer, JBuffer trailer) throws IOException 188 public int flush(ByteBuffer header, ByteBuffer buffer, ByteBuffer trailer) throws IOException
189 { 189 {
190 _idleTimestamp = System.currentTimeMillis(); 190 _idleTimestamp = System.currentTimeMillis();
191 return super.flush(header,buffer,trailer); 191 return super.flush(header,buffer,trailer);
192 } 192 }
193 193