async server#4120
Conversation
|
/rebuild |
1 similar comment
|
/rebuild |
|
/rebuild |
|
/run-all-tests |
Coverage for changed filesCoverage summaryfull coverage report (for internal network access only) |
|
/run-all-tests |
Coverage for changed filesCoverage summaryfull coverage report (for internal network access only) |
Signed-off-by: bestwoody <bestwoody@163.com>
|
[FORMAT CHECKER NOTIFICATION] Notice: To remove the 📖 For more info, you can check the "Contribute Code" section in the development guide. |
|
/run-all-tests |
Coverage for changed filesCoverage summaryfull coverage report (for internal network access only) |
|
/merge |
|
@bestwoody: It seems you want to merge this PR, I will help you trigger all the tests: /run-all-tests You only need to trigger If you have any questions about the PR merge process, please refer to pr process. DetailsInstructions for interacting with me using PR comments are available here. If you have questions or suggestions related to my behavior, please file an issue against the ti-community-infra/tichi repository. |
|
This pull request has been accepted and is ready to merge. DetailsCommit hash: 57580bf |
Coverage for changed filesCoverage summaryfull coverage report (for internal network access only) |
|
/merge |
|
@bestwoody: It seems you want to merge this PR, I will help you trigger all the tests: /run-all-tests You only need to trigger If you have any questions about the PR merge process, please refer to pr process. DetailsInstructions for interacting with me using PR comments are available here. If you have questions or suggestions related to my behavior, please file an issue against the ti-community-infra/tichi repository. |
| flash_service = std::make_unique<AsyncFlashService>(server); | ||
| else | ||
| flash_service = std::make_unique<FlashService>(server); | ||
| diagnostics_service = std::make_unique<DiagnosticsService>(server); |
There was a problem hiding this comment.
are these args reasonalbe for async server?
What problem does this PR solve?
Issue Number: close #xxx
Problem Summary:
What is changed and how it works?
https://pingcap.feishu.cn/docs/doccnjURwS2PfTpz0tDolmUtsAe
Concept:
CallData: grpc session container with context data for that session. A state machine to react for the gRPC event(such as: write, writeDone, return Status ...)
Tag: a unique instance of CallData
CQ is the queue for polling the gRPC events.
How to develop a async server:
Use WithAsyncMethod_AAA template class to implement a async service.
For the api AAA you want it to be async, implement CallData for it.
Check List
Tests
Side effects
Documentation
Release note