Merged branch 'jetty-11.0.x' into 'jetty-12.0.x'.
Signed-off-by: Simone Bordet <simone.bordet@gmail.com>
This commit is contained in:
commit
8a12ed57df
|
@ -247,14 +247,20 @@ public class HttpReceiverOverHTTPTest
|
||||||
{
|
{
|
||||||
return new HttpReceiverOverHTTP(this)
|
return new HttpReceiverOverHTTP(this)
|
||||||
{
|
{
|
||||||
|
private boolean once = true;
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
protected void fillInterested()
|
protected void fillInterested()
|
||||||
{
|
{
|
||||||
|
if (once)
|
||||||
|
{
|
||||||
|
once = false;
|
||||||
// Verify that the buffer has been released
|
// Verify that the buffer has been released
|
||||||
// before fillInterested() is called.
|
// before fillInterested() is called.
|
||||||
assertNull(getResponseBuffer());
|
assertNull(getResponseBuffer());
|
||||||
// Fill the endpoint so receive is called again.
|
// Fill the endpoint so receive is called again.
|
||||||
endPoint.addInput("X");
|
endPoint.addInput("X");
|
||||||
|
}
|
||||||
super.fillInterested();
|
super.fillInterested();
|
||||||
}
|
}
|
||||||
};
|
};
|
||||||
|
@ -277,5 +283,7 @@ public class HttpReceiverOverHTTPTest
|
||||||
Response response = completable.get(5, TimeUnit.SECONDS);
|
Response response = completable.get(5, TimeUnit.SECONDS);
|
||||||
assertNotNull(response);
|
assertNotNull(response);
|
||||||
assertEquals(200, response.getStatus());
|
assertEquals(200, response.getStatus());
|
||||||
|
|
||||||
|
Thread.sleep(2000);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue