Chiebot-Mirror
/
grpc
8
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

[test] Extend cancellation deadline (that should not be reached) (#34571)

Browse Source
pull/34586/head
Craig Tiller 1 year ago committed by GitHub
parent 4c16e6b68f
commit b9fbf41e3c
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 30 additions and 17 deletions
Whitespace
Show all changes Ignore whitespace when comparing lines Ignore changes in amount of whitespace Ignore changes in whitespace at EOL
Split View
Diff Options
Show Stats Download Patch File Download Diff File
  1. 47
      test/core/end2end/tests/cancel_after_invoke.cc

47
test/core/end2end/tests/cancel_after_invoke.cc
Unescape View File

@ -29,12 +29,14 @@
namespace grpc_core {
namespace {
const Duration kTimeout = Duration::Seconds(2);
const Duration kCancelTimeout = Duration::Seconds(20);
const Duration kDeadlineTimeout = Duration::Seconds(2);
} // namespace
void CancelAfterInvoke6(CoreEnd2endTest& test,
std::unique_ptr<CancellationMode> mode) {
auto c = test.NewClientCall("/service/method").Timeout(kTimeout).Create();
std::unique_ptr<CancellationMode> mode,
Duration timeout) {
auto c = test.NewClientCall("/service/method").Timeout(timeout).Create();
CoreEnd2endTest::IncomingStatusOnClient server_status;
CoreEnd2endTest::IncomingMetadata server_initial_metadata;
CoreEnd2endTest::IncomingMessage server_message;
@ -53,8 +55,9 @@ void CancelAfterInvoke6(CoreEnd2endTest& test,
}
void CancelAfterInvoke5(CoreEnd2endTest& test,
std::unique_ptr<CancellationMode> mode) {
auto c = test.NewClientCall("/service/method").Timeout(kTimeout).Create();
std::unique_ptr<CancellationMode> mode,
Duration timeout) {
auto c = test.NewClientCall("/service/method").Timeout(timeout).Create();
CoreEnd2endTest::IncomingStatusOnClient server_status;
CoreEnd2endTest::IncomingMetadata server_initial_metadata;
c.NewBatch(1)
@ -71,8 +74,9 @@ void CancelAfterInvoke5(CoreEnd2endTest& test,
}
void CancelAfterInvoke4(CoreEnd2endTest& test,
std::unique_ptr<CancellationMode> mode) {
auto c = test.NewClientCall("/service/method").Timeout(kTimeout).Create();
std::unique_ptr<CancellationMode> mode,
Duration timeout) {
auto c = test.NewClientCall("/service/method").Timeout(timeout).Create();
CoreEnd2endTest::IncomingStatusOnClient server_status;
CoreEnd2endTest::IncomingMetadata server_initial_metadata;
c.NewBatch(1)
@ -88,8 +92,9 @@ void CancelAfterInvoke4(CoreEnd2endTest& test,
}
void CancelAfterInvoke3(CoreEnd2endTest& test,
std::unique_ptr<CancellationMode> mode) {
auto c = test.NewClientCall("/service/method").Timeout(kTimeout).Create();
std::unique_ptr<CancellationMode> mode,
Duration timeout) {
auto c = test.NewClientCall("/service/method").Timeout(timeout).Create();
CoreEnd2endTest::IncomingStatusOnClient server_status;
CoreEnd2endTest::IncomingMetadata server_initial_metadata;
c.NewBatch(1)
@ -106,41 +111,49 @@ void CancelAfterInvoke3(CoreEnd2endTest& test,
CORE_END2END_TEST(CoreEnd2endTest, CancelAfterInvoke6) {
// TODO(vigneshbabu): re-enable these before release
SKIP_IF_USES_EVENT_ENGINE_LISTENER();
CancelAfterInvoke6(*this, std::make_unique<CancelCancellationMode>());
CancelAfterInvoke6(*this, std::make_unique<CancelCancellationMode>(),
kCancelTimeout);
}
CORE_END2END_TEST(CoreEnd2endTest, CancelAfterInvoke5) {
// TODO(vigneshbabu): re-enable these before release
SKIP_IF_USES_EVENT_ENGINE_LISTENER();
CancelAfterInvoke5(*this, std::make_unique<CancelCancellationMode>());
CancelAfterInvoke5(*this, std::make_unique<CancelCancellationMode>(),
kCancelTimeout);
}
CORE_END2END_TEST(CoreEnd2endTest, CancelAfterInvoke4) {
// TODO(vigneshbabu): re-enable these before release
SKIP_IF_USES_EVENT_ENGINE_LISTENER();
CancelAfterInvoke4(*this, std::make_unique<CancelCancellationMode>());
CancelAfterInvoke4(*this, std::make_unique<CancelCancellationMode>(),
kCancelTimeout);
}
CORE_END2END_TEST(CoreEnd2endTest, CancelAfterInvoke3) {
// TODO(vigneshbabu): re-enable these before release
SKIP_IF_USES_EVENT_ENGINE_LISTENER();
CancelAfterInvoke3(*this, std::make_unique<CancelCancellationMode>());
CancelAfterInvoke3(*this, std::make_unique<CancelCancellationMode>(),
kCancelTimeout);
}
CORE_END2END_TEST(CoreDeadlineTest, DeadlineAfterInvoke6) {
CancelAfterInvoke6(*this, std::make_unique<DeadlineCancellationMode>());
CancelAfterInvoke6(*this, std::make_unique<DeadlineCancellationMode>(),
kDeadlineTimeout);
}
CORE_END2END_TEST(CoreDeadlineTest, DeadlineAfterInvoke5) {
CancelAfterInvoke5(*this, std::make_unique<DeadlineCancellationMode>());
CancelAfterInvoke5(*this, std::make_unique<DeadlineCancellationMode>(),
kDeadlineTimeout);
}
CORE_END2END_TEST(CoreDeadlineTest, DeadlineAfterInvoke4) {
CancelAfterInvoke4(*this, std::make_unique<DeadlineCancellationMode>());
CancelAfterInvoke4(*this, std::make_unique<DeadlineCancellationMode>(),
kDeadlineTimeout);
}
CORE_END2END_TEST(CoreDeadlineTest, DeadlineAfterInvoke3) {
CancelAfterInvoke3(*this, std::make_unique<DeadlineCancellationMode>());
CancelAfterInvoke3(*this, std::make_unique<DeadlineCancellationMode>(),
kDeadlineTimeout);
}
} // namespace grpc_core

Write Preview
Loading…
Cancel
Save