pull/2643/head
Jan Tattermusch 10 years ago
parent 6835b92c8b
commit 49313cec38
  1. 23
      src/csharp/Grpc.Core.Tests/TimeoutsTest.cs

@ -121,11 +121,27 @@ namespace Grpc.Core.Tests
Assert.IsTrue(Math.Abs((deadline - serverDeadline).TotalMilliseconds) < 5000); Assert.IsTrue(Math.Abs((deadline - serverDeadline).TotalMilliseconds) < 5000);
} }
[Test]
public void DeadlineInThePast()
{
var deadline = DateTime.MinValue;
var internalCall = new Call<string, string>(ServiceName, TestMethod, channel, Metadata.Empty, deadline);
try
{
Calls.BlockingUnaryCall(internalCall, "TIMEOUT", CancellationToken.None);
Assert.Fail();
}
catch (RpcException e)
{
Assert.AreEqual(StatusCode.DeadlineExceeded, e.Status.StatusCode);
}
}
[Test] [Test]
public void DeadlineExceededStatusOnTimeout() public void DeadlineExceededStatusOnTimeout()
{ {
// no deadline specified, check server sees infinite deadline var deadline = DateTime.UtcNow.Add(TimeSpan.FromSeconds(5));
var deadline = DateTime.UtcNow.Add(TimeSpan.FromSeconds(1));
var internalCall = new Call<string, string>(ServiceName, TestMethod, channel, Metadata.Empty, deadline); var internalCall = new Call<string, string>(ServiceName, TestMethod, channel, Metadata.Empty, deadline);
try try
@ -142,8 +158,7 @@ namespace Grpc.Core.Tests
[Test] [Test]
public void ServerReceivesCancellationOnTimeout() public void ServerReceivesCancellationOnTimeout()
{ {
// no deadline specified, check server sees infinite deadline var deadline = DateTime.UtcNow.Add(TimeSpan.FromSeconds(5));
var deadline = DateTime.UtcNow.Add(TimeSpan.FromSeconds(1));
var internalCall = new Call<string, string>(ServiceName, TestMethod, channel, Metadata.Empty, deadline); var internalCall = new Call<string, string>(ServiceName, TestMethod, channel, Metadata.Empty, deadline);
try try

Loading…
Cancel
Save