Skip to content

Commit 676a274

Browse files
committed
Address review comments
1 parent 6fe5f94 commit 676a274

1 file changed

Lines changed: 3 additions & 6 deletions

File tree

google/cloud/pubsub/internal/defaults.cc

Lines changed: 3 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -114,6 +114,7 @@ Options DefaultSubscriberOptionsOnly(Options opts) {
114114
Options{}
115115
.set<pubsub::MaxDeadlineTimeOption>(seconds(0))
116116
.set<pubsub::MaxDeadlineExtensionOption>(seconds(600))
117+
.set<pubsub::MinDeadlineExtensionOption>(seconds(60))
117118
.set<pubsub::MaxOutstandingMessagesOption>(1000)
118119
.set<pubsub::MaxOutstandingBytesOption>(100 * 1024 * 1024L)
119120
.set<pubsub::ShutdownPollingPeriodOption>(seconds(5))
@@ -136,12 +137,8 @@ Options DefaultSubscriberOptionsOnly(Options opts) {
136137
auto& max = opts.lookup<pubsub::MaxDeadlineExtensionOption>();
137138
max = (std::max)((std::min)(max, seconds(600)), seconds(10));
138139

139-
if (opts.has<pubsub::MinDeadlineExtensionOption>()) {
140-
auto& min = opts.lookup<pubsub::MinDeadlineExtensionOption>();
141-
min = (std::max)((std::min)(min, max), seconds(10));
142-
} else {
143-
opts.set<pubsub::MinDeadlineExtensionOption>((std::min)(seconds(60), max));
144-
}
140+
auto& min = opts.lookup<pubsub::MinDeadlineExtensionOption>();
141+
min = (std::max)((std::min)(min, max), seconds(10));
145142

146143
auto& messages = opts.lookup<pubsub::MaxOutstandingMessagesOption>();
147144
messages = std::max<std::int64_t>(0, messages);

0 commit comments

Comments
 (0)