Mercurial Hosting > luan
comparison src/org/eclipse/jetty/io/nio/SelectChannelEndPoint.java @ 1048:2b769da7f67d
remove Buffer
| author | Franklin Schmidt <fschmidt@gmail.com> |
|---|---|
| date | Mon, 07 Nov 2016 23:15:42 -0700 |
| parents | 3c4c7cc7904f |
| children | ebb0f1343ef6 |
comparison
equal
deleted
inserted
replaced
| 1047:1accf965d51a | 1048:2b769da7f67d |
|---|---|
| 26 import java.nio.channels.SocketChannel; | 26 import java.nio.channels.SocketChannel; |
| 27 import java.util.Locale; | 27 import java.util.Locale; |
| 28 import java.util.concurrent.RejectedExecutionException; | 28 import java.util.concurrent.RejectedExecutionException; |
| 29 | 29 |
| 30 import org.eclipse.jetty.io.AsyncEndPoint; | 30 import org.eclipse.jetty.io.AsyncEndPoint; |
| 31 import org.eclipse.jetty.io.Buffer; | 31 import org.eclipse.jetty.io.JBuffer; |
| 32 import org.eclipse.jetty.io.EofException; | 32 import org.eclipse.jetty.io.EofException; |
| 33 import org.slf4j.Logger; | 33 import org.slf4j.Logger; |
| 34 import org.slf4j.LoggerFactory; | 34 import org.slf4j.LoggerFactory; |
| 35 | 35 |
| 36 | 36 |
| 155 } | 155 } |
| 156 } | 156 } |
| 157 } | 157 } |
| 158 | 158 |
| 159 @Override | 159 @Override |
| 160 public int fill(Buffer buffer) throws IOException | 160 public int fill(JBuffer buffer) throws IOException |
| 161 { | 161 { |
| 162 int fill=super.fill(buffer); | 162 int fill=super.fill(buffer); |
| 163 return fill; | 163 return fill; |
| 164 } | 164 } |
| 165 | 165 |
| 166 @Override | 166 @Override |
| 167 public int flush(Buffer header, Buffer buffer, Buffer trailer) throws IOException | 167 public int flush(JBuffer header, JBuffer buffer, JBuffer trailer) throws IOException |
| 168 { | 168 { |
| 169 int l = super.flush(header, buffer, trailer); | 169 int l = super.flush(header, buffer, trailer); |
| 170 | 170 |
| 171 // If there was something to write and it wasn't written, then we are not writable. | 171 // If there was something to write and it wasn't written, then we are not writable. |
| 172 if (l==0 && ( header!=null && header.hasRemaining() || buffer!=null && buffer.hasRemaining() || trailer!=null && trailer.hasRemaining())) | 172 if (l==0 && ( header!=null && header.hasRemaining() || buffer!=null && buffer.hasRemaining() || trailer!=null && trailer.hasRemaining())) |
| 184 } | 184 } |
| 185 return l; | 185 return l; |
| 186 } | 186 } |
| 187 | 187 |
| 188 @Override | 188 @Override |
| 189 public int flush(Buffer buffer) throws IOException | 189 public int flush(JBuffer buffer) throws IOException |
| 190 { | 190 { |
| 191 int l = super.flush(buffer); | 191 int l = super.flush(buffer); |
| 192 | 192 |
| 193 // If there was something to write and it wasn't written, then we are not writable. | 193 // If there was something to write and it wasn't written, then we are not writable. |
| 194 if (l==0 && buffer!=null && buffer.hasRemaining()) | 194 if (l==0 && buffer!=null && buffer.hasRemaining()) |
