Skip to content

Commit 31a4271

Browse files
author
ninsmiracle
committed
format and IWYU
1 parent e60dc0a commit 31a4271

File tree

3 files changed

+2
-3
lines changed

3 files changed

+2
-3
lines changed

src/replica/duplication/mutation_batch.cpp

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -173,7 +173,8 @@ void mutation_batch::add_mutation_if_valid(mutation_ptr &mu, decree start_decree
173173
// ERR_OPERATION_DISABLED, but there could still be a mutation written
174174
// before the duplication was added.
175175
// To ignore means this write will be lost, which is acceptable under this rare case.
176-
if (!task_spec::get(update.code)->rpc_request_is_write_idempotent && !FLAGS_force_send_no_idempotent_when_duplication) {
176+
if (!task_spec::get(update.code)->rpc_request_is_write_idempotent &&
177+
!FLAGS_force_send_no_idempotent_when_duplication) {
177178
continue;
178179
}
179180
blob bb;

src/replica/replica_2pc.cpp

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -93,7 +93,6 @@ DSN_DEFINE_bool("replication",
9393
"doing duplication");
9494
DSN_TAG_VARIABLE(force_send_no_idempotent_when_duplication, FT_MUTABLE);
9595

96-
9796
DSN_DEFINE_int32(replication,
9897
prepare_timeout_ms_for_secondaries,
9998
1000,

src/server/pegasus_write_service.cpp

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -456,7 +456,6 @@ int pegasus_write_service::duplicate(int64_t decree,
456456
}
457457
}
458458

459-
460459
resp.__set_error(rocksdb::Status::kInvalidArgument);
461460
resp.__set_error_hint(fmt::format("unrecognized task code {}", request.task_code));
462461
return empty_put(ctx.decree);

0 commit comments

Comments
 (0)