-
Notifications
You must be signed in to change notification settings - Fork 312
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
pegasus_server: refine write process #110
Conversation
src/server/pegasus_server_write.cpp
Outdated
} | ||
|
||
return on_batched_writes(requests, count, decree); | ||
return on_batched_writes(requests, count, _decree); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
那这里直接不传 _decree 就好了
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
done
src/server/pegasus_write_service.cpp
Outdated
@@ -104,6 +108,8 @@ int pegasus_write_service::batch_remove(int64_t decree, | |||
const dsn::blob &key, | |||
dsn::apps::update_response &resp) | |||
{ | |||
dassert(_batch_start_time != 0, "batch_put must be called after batch_prepare"); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
batch_remove
Former-commit-id: 425e095d7242972e7b2caf4c26b01625bacd291a [formerly 8ee7e1d] Former-commit-id: 2425bc92bd82dca8a053b80b3503dedde9ea70d1
No description provided.