SERVER-126796 Use assertCanAcceptContainerWrites for updates (#54045)
GitOrigin-RevId: 0778d2bb5e4e97926e69372678dfd4dbb0f8d005
This commit is contained in:
parent
a9767e64da
commit
43f60af37b
@ -44,7 +44,7 @@ void assertCanAcceptContainerWrites(OperationContext* opCtx) {
|
||||
VersionContext::getDecoration(opCtx), fcv));
|
||||
|
||||
uassert(ErrorCodes::NotWritablePrimary,
|
||||
str::stream() << "Not primary while inserting to container",
|
||||
str::stream() << "Not primary while writing to container",
|
||||
repl::ReplicationCoordinator::get(opCtx)->canAcceptWritesFor(
|
||||
opCtx, NamespaceString::kContainerNamespace));
|
||||
}
|
||||
@ -91,11 +91,7 @@ Status update(OperationContext* opCtx,
|
||||
IntegerKeyedContainer& container,
|
||||
int64_t key,
|
||||
std::span<const char> value) {
|
||||
uassert(ErrorCodes::NotWritablePrimary,
|
||||
"Not primary while updating container",
|
||||
repl::ReplicationCoordinator::get(opCtx)->canAcceptWritesFor(
|
||||
opCtx, NamespaceString::kContainerNamespace));
|
||||
|
||||
assertCanAcceptContainerWrites(opCtx);
|
||||
auto status = container.update(ru, key, value);
|
||||
if (!status.isOK()) {
|
||||
return status;
|
||||
@ -112,11 +108,7 @@ Status update(OperationContext* opCtx,
|
||||
StringKeyedContainer& container,
|
||||
std::span<const char> key,
|
||||
std::span<const char> value) {
|
||||
uassert(ErrorCodes::NotWritablePrimary,
|
||||
"Not primary while updating container",
|
||||
repl::ReplicationCoordinator::get(opCtx)->canAcceptWritesFor(
|
||||
opCtx, NamespaceString::kContainerNamespace));
|
||||
|
||||
assertCanAcceptContainerWrites(opCtx);
|
||||
auto status = container.update(ru, key, value);
|
||||
if (!status.isOK()) {
|
||||
return status;
|
||||
|
||||
Loading…
Reference in New Issue
Block a user