You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hc.apache.org by ol...@apache.org on 2014/01/14 16:22:34 UTC
svn commit: r1558077 [4/4] - in /httpcomponents/httpcore/trunk:
httpcore-ab/src/main/java/org/apache/http/benchmark/
httpcore-ab/src/test/java/org/apache/http/benchmark/
httpcore-nio/src/main/java/org/apache/http/impl/nio/
httpcore-nio/src/main/java/or...
Modified: httpcomponents/httpcore/trunk/httpcore/src/main/java/org/apache/http/params/AbstractHttpParams.java
URL: http://svn.apache.org/viewvc/httpcomponents/httpcore/trunk/httpcore/src/main/java/org/apache/http/params/AbstractHttpParams.java?rev=1558077&r1=1558076&r2=1558077&view=diff
==============================================================================
--- httpcomponents/httpcore/trunk/httpcore/src/main/java/org/apache/http/params/AbstractHttpParams.java (original)
+++ httpcomponents/httpcore/trunk/httpcore/src/main/java/org/apache/http/params/AbstractHttpParams.java Tue Jan 14 15:22:31 2014
@@ -49,6 +49,7 @@ public abstract class AbstractHttpParams
super();
}
+ @Override
public long getLongParameter(final String name, final long defaultValue) {
final Object param = getParameter(name);
if (param == null) {
@@ -57,11 +58,13 @@ public abstract class AbstractHttpParams
return ((Long) param).longValue();
}
+ @Override
public HttpParams setLongParameter(final String name, final long value) {
setParameter(name, Long.valueOf(value));
return this;
}
+ @Override
public int getIntParameter(final String name, final int defaultValue) {
final Object param = getParameter(name);
if (param == null) {
@@ -70,11 +73,13 @@ public abstract class AbstractHttpParams
return ((Integer) param).intValue();
}
+ @Override
public HttpParams setIntParameter(final String name, final int value) {
setParameter(name, Integer.valueOf(value));
return this;
}
+ @Override
public double getDoubleParameter(final String name, final double defaultValue) {
final Object param = getParameter(name);
if (param == null) {
@@ -83,11 +88,13 @@ public abstract class AbstractHttpParams
return ((Double) param).doubleValue();
}
+ @Override
public HttpParams setDoubleParameter(final String name, final double value) {
setParameter(name, Double.valueOf(value));
return this;
}
+ @Override
public boolean getBooleanParameter(final String name, final boolean defaultValue) {
final Object param = getParameter(name);
if (param == null) {
@@ -96,15 +103,18 @@ public abstract class AbstractHttpParams
return ((Boolean) param).booleanValue();
}
+ @Override
public HttpParams setBooleanParameter(final String name, final boolean value) {
setParameter(name, value ? Boolean.TRUE : Boolean.FALSE);
return this;
}
+ @Override
public boolean isParameterTrue(final String name) {
return getBooleanParameter(name, false);
}
+ @Override
public boolean isParameterFalse(final String name) {
return !getBooleanParameter(name, false);
}
@@ -117,6 +127,7 @@ public abstract class AbstractHttpParams
* @since 4.2
* @throws UnsupportedOperationException - always
*/
+ @Override
public Set<String> getNames(){
throw new UnsupportedOperationException();
}
Modified: httpcomponents/httpcore/trunk/httpcore/src/main/java/org/apache/http/params/BasicHttpParams.java
URL: http://svn.apache.org/viewvc/httpcomponents/httpcore/trunk/httpcore/src/main/java/org/apache/http/params/BasicHttpParams.java?rev=1558077&r1=1558076&r2=1558077&view=diff
==============================================================================
--- httpcomponents/httpcore/trunk/httpcore/src/main/java/org/apache/http/params/BasicHttpParams.java (original)
+++ httpcomponents/httpcore/trunk/httpcore/src/main/java/org/apache/http/params/BasicHttpParams.java Tue Jan 14 15:22:31 2014
@@ -59,10 +59,12 @@ public class BasicHttpParams extends Abs
super();
}
+ @Override
public Object getParameter(final String name) {
return this.parameters.get(name);
}
+ @Override
public HttpParams setParameter(final String name, final Object value) {
if (name == null) {
return this;
@@ -75,6 +77,7 @@ public class BasicHttpParams extends Abs
return this;
}
+ @Override
public boolean removeParameter(final String name) {
//this is to avoid the case in which the key has a null value
if (this.parameters.containsKey(name)) {
@@ -142,6 +145,7 @@ public class BasicHttpParams extends Abs
*
* @throws UnsupportedOperationException if the clone() fails
*/
+ @Override
public HttpParams copy() {
try {
return (HttpParams) clone();
Modified: httpcomponents/httpcore/trunk/httpcore/src/main/java/org/apache/http/pool/AbstractConnPool.java
URL: http://svn.apache.org/viewvc/httpcomponents/httpcore/trunk/httpcore/src/main/java/org/apache/http/pool/AbstractConnPool.java?rev=1558077&r1=1558076&r2=1558077&view=diff
==============================================================================
--- httpcomponents/httpcore/trunk/httpcore/src/main/java/org/apache/http/pool/AbstractConnPool.java (original)
+++ httpcomponents/httpcore/trunk/httpcore/src/main/java/org/apache/http/pool/AbstractConnPool.java Tue Jan 14 15:22:31 2014
@@ -164,6 +164,7 @@ public abstract class AbstractConnPool<T
* or {@link Future#get(long, TimeUnit)} method on the {@link Future}
* returned by this method in order for the lease operation to complete.
*/
+ @Override
public Future<E> lease(final T route, final Object state, final FutureCallback<E> callback) {
Args.notNull(route, "Route");
Asserts.check(!this.isShutDown, "Connection pool shut down");
@@ -300,6 +301,7 @@ public abstract class AbstractConnPool<T
}
}
+ @Override
public void release(final E entry, final boolean reusable) {
this.lock.lock();
try {
@@ -336,6 +338,7 @@ public abstract class AbstractConnPool<T
}
}
+ @Override
public void setMaxTotal(final int max) {
Args.notNegative(max, "Max value");
this.lock.lock();
@@ -346,6 +349,7 @@ public abstract class AbstractConnPool<T
}
}
+ @Override
public int getMaxTotal() {
this.lock.lock();
try {
@@ -355,6 +359,7 @@ public abstract class AbstractConnPool<T
}
}
+ @Override
public void setDefaultMaxPerRoute(final int max) {
Args.notNegative(max, "Max per route value");
this.lock.lock();
@@ -365,6 +370,7 @@ public abstract class AbstractConnPool<T
}
}
+ @Override
public int getDefaultMaxPerRoute() {
this.lock.lock();
try {
@@ -374,6 +380,7 @@ public abstract class AbstractConnPool<T
}
}
+ @Override
public void setMaxPerRoute(final T route, final int max) {
Args.notNull(route, "Route");
Args.notNegative(max, "Max per route value");
@@ -385,6 +392,7 @@ public abstract class AbstractConnPool<T
}
}
+ @Override
public int getMaxPerRoute(final T route) {
Args.notNull(route, "Route");
this.lock.lock();
@@ -395,6 +403,7 @@ public abstract class AbstractConnPool<T
}
}
+ @Override
public PoolStats getTotalStats() {
this.lock.lock();
try {
@@ -408,6 +417,7 @@ public abstract class AbstractConnPool<T
}
}
+ @Override
public PoolStats getStats(final T route) {
Args.notNull(route, "Route");
this.lock.lock();
@@ -490,6 +500,7 @@ public abstract class AbstractConnPool<T
final long deadline = System.currentTimeMillis() - time;
enumAvailable(new PoolEntryCallback<T, C>() {
+ @Override
public void process(final PoolEntry<T, C> entry) {
if (entry.getUpdated() <= deadline) {
entry.close();
@@ -507,6 +518,7 @@ public abstract class AbstractConnPool<T
final long now = System.currentTimeMillis();
enumAvailable(new PoolEntryCallback<T, C>() {
+ @Override
public void process(final PoolEntry<T, C> entry) {
if (entry.isExpired(now)) {
entry.close();
Modified: httpcomponents/httpcore/trunk/httpcore/src/main/java/org/apache/http/pool/PoolEntryFuture.java
URL: http://svn.apache.org/viewvc/httpcomponents/httpcore/trunk/httpcore/src/main/java/org/apache/http/pool/PoolEntryFuture.java?rev=1558077&r1=1558076&r2=1558077&view=diff
==============================================================================
--- httpcomponents/httpcore/trunk/httpcore/src/main/java/org/apache/http/pool/PoolEntryFuture.java (original)
+++ httpcomponents/httpcore/trunk/httpcore/src/main/java/org/apache/http/pool/PoolEntryFuture.java Tue Jan 14 15:22:31 2014
@@ -56,6 +56,7 @@ abstract class PoolEntryFuture<T> implem
this.callback = callback;
}
+ @Override
public boolean cancel(final boolean mayInterruptIfRunning) {
this.lock.lock();
try {
@@ -74,14 +75,17 @@ abstract class PoolEntryFuture<T> implem
}
}
+ @Override
public boolean isCancelled() {
return this.cancelled;
}
+ @Override
public boolean isDone() {
return this.completed;
}
+ @Override
public T get() throws InterruptedException, ExecutionException {
try {
return get(0, TimeUnit.MILLISECONDS);
@@ -90,6 +94,7 @@ abstract class PoolEntryFuture<T> implem
}
}
+ @Override
public T get(
final long timeout,
final TimeUnit unit) throws InterruptedException, ExecutionException, TimeoutException {
Modified: httpcomponents/httpcore/trunk/httpcore/src/main/java/org/apache/http/protocol/BasicHttpContext.java
URL: http://svn.apache.org/viewvc/httpcomponents/httpcore/trunk/httpcore/src/main/java/org/apache/http/protocol/BasicHttpContext.java?rev=1558077&r1=1558076&r2=1558077&view=diff
==============================================================================
--- httpcomponents/httpcore/trunk/httpcore/src/main/java/org/apache/http/protocol/BasicHttpContext.java (original)
+++ httpcomponents/httpcore/trunk/httpcore/src/main/java/org/apache/http/protocol/BasicHttpContext.java Tue Jan 14 15:22:31 2014
@@ -57,6 +57,7 @@ public class BasicHttpContext implements
this.parentContext = parentContext;
}
+ @Override
public Object getAttribute(final String id) {
Args.notNull(id, "Id");
Object obj = this.map.get(id);
@@ -66,6 +67,7 @@ public class BasicHttpContext implements
return obj;
}
+ @Override
public void setAttribute(final String id, final Object obj) {
Args.notNull(id, "Id");
if (obj != null) {
@@ -75,6 +77,7 @@ public class BasicHttpContext implements
}
}
+ @Override
public Object removeAttribute(final String id) {
Args.notNull(id, "Id");
return this.map.remove(id);
Modified: httpcomponents/httpcore/trunk/httpcore/src/main/java/org/apache/http/protocol/HttpCoreContext.java
URL: http://svn.apache.org/viewvc/httpcomponents/httpcore/trunk/httpcore/src/main/java/org/apache/http/protocol/HttpCoreContext.java?rev=1558077&r1=1558076&r2=1558077&view=diff
==============================================================================
--- httpcomponents/httpcore/trunk/httpcore/src/main/java/org/apache/http/protocol/HttpCoreContext.java (original)
+++ httpcomponents/httpcore/trunk/httpcore/src/main/java/org/apache/http/protocol/HttpCoreContext.java Tue Jan 14 15:22:31 2014
@@ -99,14 +99,17 @@ public class HttpCoreContext implements
this.context = new BasicHttpContext();
}
+ @Override
public Object getAttribute(final String id) {
return context.getAttribute(id);
}
+ @Override
public void setAttribute(final String id, final Object obj) {
context.setAttribute(id, obj);
}
+ @Override
public Object removeAttribute(final String id) {
return context.removeAttribute(id);
}
Modified: httpcomponents/httpcore/trunk/httpcore/src/main/java/org/apache/http/protocol/HttpService.java
URL: http://svn.apache.org/viewvc/httpcomponents/httpcore/trunk/httpcore/src/main/java/org/apache/http/protocol/HttpService.java?rev=1558077&r1=1558076&r2=1558077&view=diff
==============================================================================
--- httpcomponents/httpcore/trunk/httpcore/src/main/java/org/apache/http/protocol/HttpService.java (original)
+++ httpcomponents/httpcore/trunk/httpcore/src/main/java/org/apache/http/protocol/HttpService.java Tue Jan 14 15:22:31 2014
@@ -438,6 +438,7 @@ public class HttpService {
this.resolver = resolver;
}
+ @Override
public HttpRequestHandler lookup(final HttpRequest request) {
return resolver.lookup(request.getRequestLine().getUri());
}
Modified: httpcomponents/httpcore/trunk/httpcore/src/main/java/org/apache/http/protocol/ImmutableHttpProcessor.java
URL: http://svn.apache.org/viewvc/httpcomponents/httpcore/trunk/httpcore/src/main/java/org/apache/http/protocol/ImmutableHttpProcessor.java?rev=1558077&r1=1558076&r2=1558077&view=diff
==============================================================================
--- httpcomponents/httpcore/trunk/httpcore/src/main/java/org/apache/http/protocol/ImmutableHttpProcessor.java (original)
+++ httpcomponents/httpcore/trunk/httpcore/src/main/java/org/apache/http/protocol/ImmutableHttpProcessor.java Tue Jan 14 15:22:31 2014
@@ -124,6 +124,7 @@ public final class ImmutableHttpProcesso
this(null, responseInterceptors);
}
+ @Override
public void process(
final HttpRequest request,
final HttpContext context) throws IOException, HttpException {
@@ -132,6 +133,7 @@ public final class ImmutableHttpProcesso
}
}
+ @Override
public void process(
final HttpResponse response,
final HttpContext context) throws IOException, HttpException {
Modified: httpcomponents/httpcore/trunk/httpcore/src/main/java/org/apache/http/protocol/RequestConnControl.java
URL: http://svn.apache.org/viewvc/httpcomponents/httpcore/trunk/httpcore/src/main/java/org/apache/http/protocol/RequestConnControl.java?rev=1558077&r1=1558076&r2=1558077&view=diff
==============================================================================
--- httpcomponents/httpcore/trunk/httpcore/src/main/java/org/apache/http/protocol/RequestConnControl.java (original)
+++ httpcomponents/httpcore/trunk/httpcore/src/main/java/org/apache/http/protocol/RequestConnControl.java Tue Jan 14 15:22:31 2014
@@ -50,6 +50,7 @@ public class RequestConnControl implemen
super();
}
+ @Override
public void process(final HttpRequest request, final HttpContext context)
throws HttpException, IOException {
Args.notNull(request, "HTTP request");
Modified: httpcomponents/httpcore/trunk/httpcore/src/main/java/org/apache/http/protocol/RequestContent.java
URL: http://svn.apache.org/viewvc/httpcomponents/httpcore/trunk/httpcore/src/main/java/org/apache/http/protocol/RequestContent.java?rev=1558077&r1=1558076&r2=1558077&view=diff
==============================================================================
--- httpcomponents/httpcore/trunk/httpcore/src/main/java/org/apache/http/protocol/RequestContent.java (original)
+++ httpcomponents/httpcore/trunk/httpcore/src/main/java/org/apache/http/protocol/RequestContent.java Tue Jan 14 15:22:31 2014
@@ -80,6 +80,7 @@ public class RequestContent implements H
this.overwrite = overwrite;
}
+ @Override
public void process(final HttpRequest request, final HttpContext context)
throws HttpException, IOException {
Args.notNull(request, "HTTP request");
Modified: httpcomponents/httpcore/trunk/httpcore/src/main/java/org/apache/http/protocol/RequestDate.java
URL: http://svn.apache.org/viewvc/httpcomponents/httpcore/trunk/httpcore/src/main/java/org/apache/http/protocol/RequestDate.java?rev=1558077&r1=1558076&r2=1558077&view=diff
==============================================================================
--- httpcomponents/httpcore/trunk/httpcore/src/main/java/org/apache/http/protocol/RequestDate.java (original)
+++ httpcomponents/httpcore/trunk/httpcore/src/main/java/org/apache/http/protocol/RequestDate.java Tue Jan 14 15:22:31 2014
@@ -52,6 +52,7 @@ public class RequestDate implements Http
super();
}
+ @Override
public void process(final HttpRequest request, final HttpContext context)
throws HttpException, IOException {
Args.notNull(request, "HTTP request");
Modified: httpcomponents/httpcore/trunk/httpcore/src/main/java/org/apache/http/protocol/RequestExpectContinue.java
URL: http://svn.apache.org/viewvc/httpcomponents/httpcore/trunk/httpcore/src/main/java/org/apache/http/protocol/RequestExpectContinue.java?rev=1558077&r1=1558076&r2=1558077&view=diff
==============================================================================
--- httpcomponents/httpcore/trunk/httpcore/src/main/java/org/apache/http/protocol/RequestExpectContinue.java (original)
+++ httpcomponents/httpcore/trunk/httpcore/src/main/java/org/apache/http/protocol/RequestExpectContinue.java Tue Jan 14 15:22:31 2014
@@ -69,6 +69,7 @@ public class RequestExpectContinue imple
this.activeByDefault = activeByDefault;
}
+ @Override
public void process(final HttpRequest request, final HttpContext context)
throws HttpException, IOException {
Args.notNull(request, "HTTP request");
Modified: httpcomponents/httpcore/trunk/httpcore/src/main/java/org/apache/http/protocol/RequestTargetHost.java
URL: http://svn.apache.org/viewvc/httpcomponents/httpcore/trunk/httpcore/src/main/java/org/apache/http/protocol/RequestTargetHost.java?rev=1558077&r1=1558076&r2=1558077&view=diff
==============================================================================
--- httpcomponents/httpcore/trunk/httpcore/src/main/java/org/apache/http/protocol/RequestTargetHost.java (original)
+++ httpcomponents/httpcore/trunk/httpcore/src/main/java/org/apache/http/protocol/RequestTargetHost.java Tue Jan 14 15:22:31 2014
@@ -55,6 +55,7 @@ public class RequestTargetHost implement
super();
}
+ @Override
public void process(final HttpRequest request, final HttpContext context)
throws HttpException, IOException {
Args.notNull(request, "HTTP request");
Modified: httpcomponents/httpcore/trunk/httpcore/src/main/java/org/apache/http/protocol/RequestUserAgent.java
URL: http://svn.apache.org/viewvc/httpcomponents/httpcore/trunk/httpcore/src/main/java/org/apache/http/protocol/RequestUserAgent.java?rev=1558077&r1=1558076&r2=1558077&view=diff
==============================================================================
--- httpcomponents/httpcore/trunk/httpcore/src/main/java/org/apache/http/protocol/RequestUserAgent.java (original)
+++ httpcomponents/httpcore/trunk/httpcore/src/main/java/org/apache/http/protocol/RequestUserAgent.java Tue Jan 14 15:22:31 2014
@@ -58,6 +58,7 @@ public class RequestUserAgent implements
this(null);
}
+ @Override
public void process(final HttpRequest request, final HttpContext context)
throws HttpException, IOException {
Args.notNull(request, "HTTP request");
Modified: httpcomponents/httpcore/trunk/httpcore/src/main/java/org/apache/http/protocol/ResponseConnControl.java
URL: http://svn.apache.org/viewvc/httpcomponents/httpcore/trunk/httpcore/src/main/java/org/apache/http/protocol/ResponseConnControl.java?rev=1558077&r1=1558076&r2=1558077&view=diff
==============================================================================
--- httpcomponents/httpcore/trunk/httpcore/src/main/java/org/apache/http/protocol/ResponseConnControl.java (original)
+++ httpcomponents/httpcore/trunk/httpcore/src/main/java/org/apache/http/protocol/ResponseConnControl.java Tue Jan 14 15:22:31 2014
@@ -56,6 +56,7 @@ public class ResponseConnControl impleme
super();
}
+ @Override
public void process(final HttpResponse response, final HttpContext context)
throws HttpException, IOException {
Args.notNull(response, "HTTP response");
Modified: httpcomponents/httpcore/trunk/httpcore/src/main/java/org/apache/http/protocol/ResponseContent.java
URL: http://svn.apache.org/viewvc/httpcomponents/httpcore/trunk/httpcore/src/main/java/org/apache/http/protocol/ResponseContent.java?rev=1558077&r1=1558076&r2=1558077&view=diff
==============================================================================
--- httpcomponents/httpcore/trunk/httpcore/src/main/java/org/apache/http/protocol/ResponseContent.java (original)
+++ httpcomponents/httpcore/trunk/httpcore/src/main/java/org/apache/http/protocol/ResponseContent.java Tue Jan 14 15:22:31 2014
@@ -87,6 +87,7 @@ public class ResponseContent implements
* @throws ProtocolException If either the Content-Length or Transfer-Encoding headers are found.
* @throws IllegalArgumentException If the response is null.
*/
+ @Override
public void process(final HttpResponse response, final HttpContext context)
throws HttpException, IOException {
Args.notNull(response, "HTTP response");
Modified: httpcomponents/httpcore/trunk/httpcore/src/main/java/org/apache/http/protocol/ResponseDate.java
URL: http://svn.apache.org/viewvc/httpcomponents/httpcore/trunk/httpcore/src/main/java/org/apache/http/protocol/ResponseDate.java?rev=1558077&r1=1558076&r2=1558077&view=diff
==============================================================================
--- httpcomponents/httpcore/trunk/httpcore/src/main/java/org/apache/http/protocol/ResponseDate.java (original)
+++ httpcomponents/httpcore/trunk/httpcore/src/main/java/org/apache/http/protocol/ResponseDate.java Tue Jan 14 15:22:31 2014
@@ -52,6 +52,7 @@ public class ResponseDate implements Htt
super();
}
+ @Override
public void process(final HttpResponse response, final HttpContext context)
throws HttpException, IOException {
Args.notNull(response, "HTTP response");
Modified: httpcomponents/httpcore/trunk/httpcore/src/main/java/org/apache/http/protocol/ResponseServer.java
URL: http://svn.apache.org/viewvc/httpcomponents/httpcore/trunk/httpcore/src/main/java/org/apache/http/protocol/ResponseServer.java?rev=1558077&r1=1558076&r2=1558077&view=diff
==============================================================================
--- httpcomponents/httpcore/trunk/httpcore/src/main/java/org/apache/http/protocol/ResponseServer.java (original)
+++ httpcomponents/httpcore/trunk/httpcore/src/main/java/org/apache/http/protocol/ResponseServer.java Tue Jan 14 15:22:31 2014
@@ -58,6 +58,7 @@ public class ResponseServer implements H
this(null);
}
+ @Override
public void process(final HttpResponse response, final HttpContext context)
throws HttpException, IOException {
Args.notNull(response, "HTTP response");
Modified: httpcomponents/httpcore/trunk/httpcore/src/main/java/org/apache/http/protocol/UriHttpRequestHandlerMapper.java
URL: http://svn.apache.org/viewvc/httpcomponents/httpcore/trunk/httpcore/src/main/java/org/apache/http/protocol/UriHttpRequestHandlerMapper.java?rev=1558077&r1=1558076&r2=1558077&view=diff
==============================================================================
--- httpcomponents/httpcore/trunk/httpcore/src/main/java/org/apache/http/protocol/UriHttpRequestHandlerMapper.java (original)
+++ httpcomponents/httpcore/trunk/httpcore/src/main/java/org/apache/http/protocol/UriHttpRequestHandlerMapper.java Tue Jan 14 15:22:31 2014
@@ -107,6 +107,7 @@ public class UriHttpRequestHandlerMapper
* @param request the request
* @return handler or <code>null</code> if no match is found.
*/
+ @Override
public HttpRequestHandler lookup(final HttpRequest request) {
Args.notNull(request, "HTTP request");
return matcher.lookup(getRequestPath(request));
Modified: httpcomponents/httpcore/trunk/httpcore/src/test/java/org/apache/http/concurrent/BasicFutureCallback.java
URL: http://svn.apache.org/viewvc/httpcomponents/httpcore/trunk/httpcore/src/test/java/org/apache/http/concurrent/BasicFutureCallback.java?rev=1558077&r1=1558076&r2=1558077&view=diff
==============================================================================
--- httpcomponents/httpcore/trunk/httpcore/src/test/java/org/apache/http/concurrent/BasicFutureCallback.java (original)
+++ httpcomponents/httpcore/trunk/httpcore/src/test/java/org/apache/http/concurrent/BasicFutureCallback.java Tue Jan 14 15:22:31 2014
@@ -35,6 +35,7 @@ class BasicFutureCallback<T> implements
private boolean failed;
private boolean cancelled;
+ @Override
public void completed(final T result) {
this.result = result;
this.completed = true;
@@ -48,11 +49,13 @@ class BasicFutureCallback<T> implements
return this.ex;
}
+ @Override
public void failed(final Exception ex) {
this.ex = ex;
this.failed = true;
}
+ @Override
public void cancelled() {
this.cancelled = true;
}
Modified: httpcomponents/httpcore/trunk/httpcore/src/test/java/org/apache/http/entity/TestEntityTemplate.java
URL: http://svn.apache.org/viewvc/httpcomponents/httpcore/trunk/httpcore/src/test/java/org/apache/http/entity/TestEntityTemplate.java?rev=1558077&r1=1558076&r2=1558077&view=diff
==============================================================================
--- httpcomponents/httpcore/trunk/httpcore/src/test/java/org/apache/http/entity/TestEntityTemplate.java (original)
+++ httpcomponents/httpcore/trunk/httpcore/src/test/java/org/apache/http/entity/TestEntityTemplate.java Tue Jan 14 15:22:31 2014
@@ -47,6 +47,7 @@ public class TestEntityTemplate {
final HttpEntity httpentity = new EntityTemplate(new ContentProducer() {
+ @Override
public void writeTo(final OutputStream outstream) throws IOException {
outstream.write('a');
}
@@ -72,6 +73,7 @@ public class TestEntityTemplate {
public void testWriteTo() throws Exception {
final HttpEntity httpentity = new EntityTemplate(new ContentProducer() {
+ @Override
public void writeTo(final OutputStream outstream) throws IOException {
outstream.write('a');
}
@@ -96,6 +98,7 @@ public class TestEntityTemplate {
public void testgetContent() throws Exception {
final HttpEntity httpentity = new EntityTemplate(new ContentProducer() {
+ @Override
public void writeTo(final OutputStream outstream) throws IOException {
outstream.write('a');
}
Modified: httpcomponents/httpcore/trunk/httpcore/src/test/java/org/apache/http/impl/entity/DummyHttpMessage.java
URL: http://svn.apache.org/viewvc/httpcomponents/httpcore/trunk/httpcore/src/test/java/org/apache/http/impl/entity/DummyHttpMessage.java?rev=1558077&r1=1558076&r2=1558077&view=diff
==============================================================================
--- httpcomponents/httpcore/trunk/httpcore/src/test/java/org/apache/http/impl/entity/DummyHttpMessage.java (original)
+++ httpcomponents/httpcore/trunk/httpcore/src/test/java/org/apache/http/impl/entity/DummyHttpMessage.java Tue Jan 14 15:22:31 2014
@@ -44,6 +44,7 @@ class DummyHttpMessage extends AbstractH
this(HttpVersion.HTTP_1_1);
}
+ @Override
public ProtocolVersion getProtocolVersion() {
return ver;
}
Modified: httpcomponents/httpcore/trunk/httpcore/src/test/java/org/apache/http/integration/TestSyncHttp.java
URL: http://svn.apache.org/viewvc/httpcomponents/httpcore/trunk/httpcore/src/test/java/org/apache/http/integration/TestSyncHttp.java?rev=1558077&r1=1558076&r2=1558077&view=diff
==============================================================================
--- httpcomponents/httpcore/trunk/httpcore/src/test/java/org/apache/http/integration/TestSyncHttp.java (original)
+++ httpcomponents/httpcore/trunk/httpcore/src/test/java/org/apache/http/integration/TestSyncHttp.java Tue Jan 14 15:22:31 2014
@@ -120,6 +120,7 @@ public class TestSyncHttp {
// Initialize the server-side request handler
this.server.registerHandler("*", new HttpRequestHandler() {
+ @Override
public void handle(
final HttpRequest request,
final HttpResponse response,
@@ -196,6 +197,7 @@ public class TestSyncHttp {
// Initialize the server-side request handler
this.server.registerHandler("*", new HttpRequestHandler() {
+ @Override
public void handle(
final HttpRequest request,
final HttpResponse response,
@@ -278,6 +280,7 @@ public class TestSyncHttp {
// Initialize the server-side request handler
this.server.registerHandler("*", new HttpRequestHandler() {
+ @Override
public void handle(
final HttpRequest request,
final HttpResponse response,
@@ -359,6 +362,7 @@ public class TestSyncHttp {
// Initialize the server-side request handler
this.server.registerHandler("*", new HttpRequestHandler() {
+ @Override
public void handle(
final HttpRequest request,
final HttpResponse response,
@@ -444,6 +448,7 @@ public class TestSyncHttp {
// Initialize the server-side request handler
this.server.registerHandler("*", new HttpRequestHandler() {
+ @Override
public void handle(
final HttpRequest request,
final HttpResponse response,
@@ -518,6 +523,7 @@ public class TestSyncHttp {
// Initialize the server-side request handler
this.server.registerHandler("*", new HttpRequestHandler() {
+ @Override
public void handle(
final HttpRequest request,
final HttpResponse response,
@@ -531,6 +537,7 @@ public class TestSyncHttp {
this.server.setExpectationVerifier(new HttpExpectationVerifier() {
+ @Override
public void verify(
final HttpRequest request,
final HttpResponse response,
@@ -619,22 +626,27 @@ public class TestSyncHttp {
this.n = n;
}
+ @Override
public InputStream getContent() throws IOException, IllegalStateException {
throw new IllegalStateException("This method is not implemented");
}
+ @Override
public long getContentLength() {
return (this.raw.length + 2) * this.n;
}
+ @Override
public boolean isRepeatable() {
return true;
}
+ @Override
public boolean isStreaming() {
return false;
}
+ @Override
public void writeTo(final OutputStream outstream) throws IOException {
for (int i = 0; i < this.n; i++) {
outstream.write(this.raw);
@@ -672,6 +684,7 @@ public class TestSyncHttp {
// Initialize the server-side request handler
this.server.registerHandler("*", new HttpRequestHandler() {
+ @Override
public void handle(
final HttpRequest request,
final HttpResponse response,
@@ -762,6 +775,7 @@ public class TestSyncHttp {
public void testHttpPostNoEntity() throws Exception {
this.server.registerHandler("*", new HttpRequestHandler() {
+ @Override
public void handle(
final HttpRequest request,
final HttpResponse response,
@@ -807,6 +821,7 @@ public class TestSyncHttp {
public void testHttpPostNoContentLength() throws Exception {
this.server.registerHandler("*", new HttpRequestHandler() {
+ @Override
public void handle(
final HttpRequest request,
final HttpResponse response,
@@ -859,6 +874,7 @@ public class TestSyncHttp {
public void testHttpPostIdentity() throws Exception {
this.server.registerHandler("*", new HttpRequestHandler() {
+ @Override
public void handle(
final HttpRequest request,
final HttpResponse response,
@@ -894,6 +910,7 @@ public class TestSyncHttp {
new HttpRequestInterceptor[] {
new HttpRequestInterceptor() {
+ @Override
public void process(
final HttpRequest request,
final HttpContext context) throws HttpException, IOException {
@@ -922,6 +939,7 @@ public class TestSyncHttp {
// Initialize the server-side request handler
this.server.registerHandler("*", new HttpRequestHandler() {
+ @Override
public void handle(
final HttpRequest request,
final HttpResponse response,
Modified: httpcomponents/httpcore/trunk/httpcore/src/test/java/org/apache/http/message/TestAbstractMessage.java
URL: http://svn.apache.org/viewvc/httpcomponents/httpcore/trunk/httpcore/src/test/java/org/apache/http/message/TestAbstractMessage.java?rev=1558077&r1=1558076&r2=1558077&view=diff
==============================================================================
--- httpcomponents/httpcore/trunk/httpcore/src/test/java/org/apache/http/message/TestAbstractMessage.java (original)
+++ httpcomponents/httpcore/trunk/httpcore/src/test/java/org/apache/http/message/TestAbstractMessage.java Tue Jan 14 15:22:31 2014
@@ -52,6 +52,7 @@ public class TestAbstractMessage {
this(HttpVersion.HTTP_1_1);
}
+ @Override
public ProtocolVersion getProtocolVersion() {
return ver;
}
Modified: httpcomponents/httpcore/trunk/httpcore/src/test/java/org/apache/http/protocol/TestHttpService.java
URL: http://svn.apache.org/viewvc/httpcomponents/httpcore/trunk/httpcore/src/test/java/org/apache/http/protocol/TestHttpService.java?rev=1558077&r1=1558076&r2=1558077&view=diff
==============================================================================
--- httpcomponents/httpcore/trunk/httpcore/src/test/java/org/apache/http/protocol/TestHttpService.java (original)
+++ httpcomponents/httpcore/trunk/httpcore/src/test/java/org/apache/http/protocol/TestHttpService.java Tue Jan 14 15:22:31 2014
@@ -250,6 +250,7 @@ public class TestHttpService {
final HttpExpectationVerifier expectationVerifier = new HttpExpectationVerifier() {
+ @Override
public void verify(
final HttpRequest request,
final HttpResponse response,
Modified: httpcomponents/httpcore/trunk/httpcore/src/test/java/org/apache/http/testserver/HttpServer.java
URL: http://svn.apache.org/viewvc/httpcomponents/httpcore/trunk/httpcore/src/test/java/org/apache/http/testserver/HttpServer.java?rev=1558077&r1=1558076&r2=1558077&view=diff
==============================================================================
--- httpcomponents/httpcore/trunk/httpcore/src/test/java/org/apache/http/testserver/HttpServer.java (original)
+++ httpcomponents/httpcore/trunk/httpcore/src/test/java/org/apache/http/testserver/HttpServer.java Tue Jan 14 15:22:31 2014
@@ -121,6 +121,7 @@ public class HttpServer {
Asserts.check(this.listener == null, "Listener already running");
this.listener = new Thread(new Runnable() {
+ @Override
public void run() {
while (!shutdown && !Thread.interrupted()) {
try {