Skip to content

Commit

Permalink
format and IWYU
Browse files Browse the repository at this point in the history
  • Loading branch information
ninsmiracle committed Feb 18, 2024
1 parent e60dc0a commit 31a4271
Show file tree
Hide file tree
Showing 3 changed files with 2 additions and 3 deletions.
3 changes: 2 additions & 1 deletion src/replica/duplication/mutation_batch.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -173,7 +173,8 @@ void mutation_batch::add_mutation_if_valid(mutation_ptr &mu, decree start_decree
// ERR_OPERATION_DISABLED, but there could still be a mutation written
// before the duplication was added.
// To ignore means this write will be lost, which is acceptable under this rare case.
if (!task_spec::get(update.code)->rpc_request_is_write_idempotent && !FLAGS_force_send_no_idempotent_when_duplication) {
if (!task_spec::get(update.code)->rpc_request_is_write_idempotent &&
!FLAGS_force_send_no_idempotent_when_duplication) {
continue;
}
blob bb;
Expand Down
1 change: 0 additions & 1 deletion src/replica/replica_2pc.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -93,7 +93,6 @@ DSN_DEFINE_bool("replication",
"doing duplication");
DSN_TAG_VARIABLE(force_send_no_idempotent_when_duplication, FT_MUTABLE);


DSN_DEFINE_int32(replication,
prepare_timeout_ms_for_secondaries,
1000,
Expand Down
1 change: 0 additions & 1 deletion src/server/pegasus_write_service.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -456,7 +456,6 @@ int pegasus_write_service::duplicate(int64_t decree,
}
}


resp.__set_error(rocksdb::Status::kInvalidArgument);
resp.__set_error_hint(fmt::format("unrecognized task code {}", request.task_code));
return empty_put(ctx.decree);
Expand Down

0 comments on commit 31a4271

Please sign in to comment.