Fifo opt #732
Merged
Fifo opt #732
Conversation
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Signed-off-by: Li Zhanhui <lizhanhui@gmail.com>
Signed-off-by: Li Zhanhui <lizhanhui@gmail.com>
…sent Signed-off-by: Li Zhanhui <lizhanhui@gmail.com>
Signed-off-by: Li Zhanhui <lizhanhui@gmail.com>
Signed-off-by: Li Zhanhui <lizhanhui@gmail.com>
Signed-off-by: Li Zhanhui <lizhanhui@gmail.com>
Signed-off-by: Li Zhanhui <lizhanhui@gmail.com>
Signed-off-by: Li Zhanhui <lizhanhui@gmail.com>
lizhanhui
added a commit
that referenced
this pull request
Jun 13, 2024
* Prepare to optimize FIFO publishing Signed-off-by: Li Zhanhui <lizhanhui@gmail.com> * fix: SendReceipt now contains std::unique_ptr<Message> being sent Signed-off-by: Li Zhanhui <lizhanhui@gmail.com> * fix: add doc explaining why we taking ownership of the message being sent Signed-off-by: Li Zhanhui <lizhanhui@gmail.com> * feat: implement FifoProducerPartition Signed-off-by: Li Zhanhui <lizhanhui@gmail.com> * feat: implement FifoProducerImpl Signed-off-by: Li Zhanhui <lizhanhui@gmail.com> * feat: implement builder for FifoProducer Signed-off-by: Li Zhanhui <lizhanhui@gmail.com> * fix: prepare to debug Signed-off-by: Li Zhanhui <lizhanhui@gmail.com> * fix: log sending sending stages Signed-off-by: Li Zhanhui <lizhanhui@gmail.com> --------- Signed-off-by: Li Zhanhui <lizhanhui@gmail.com>
lizhanhui
added a commit
that referenced
this pull request
Jun 26, 2024
* feat: add tagged-release github action pipeline Signed-off-by: Zhanhui Li <lizhanhui@gmail.com> * Fix C++ SDK core dump issue (#2) * fix: sync namespace from server Settings * feat: use opentelemetry for tracing/metrics/logging * Remove broken links and add targets to generate compile_commands.json Signed-off-by: lizhanhui <lizhanhui@gmail.com> * fix: timer task may invoke a call to a destructing stream Signed-off-by: Zhanhui Li <lizhanhui@gmail.com> * fix: update document as we have changed the way to generate compile_commands.json * fix: static_cast StreamState to std::uint8_t as enum class by default is not formattable Signed-off-by: Li Zhanhui <lizhanhui@gmail.com> --------- Signed-off-by: lizhanhui <lizhanhui@gmail.com> Signed-off-by: Zhanhui Li <lizhanhui@gmail.com> Signed-off-by: Li Zhanhui <lizhanhui@gmail.com> * fix: fix stream state transition with gRPC reactor Signed-off-by: Li Zhanhui <lizhanhui@gmail.com> * fix: revamp TelemetryBidiRecator Signed-off-by: Li Zhanhui <lizhanhui@gmail.com> * feat: explicitly control exported symbols Signed-off-by: Li Zhanhui <lizhanhui@gmail.com> * fix: release write hold when OnReadDone with ok=false and there is no inflight write Signed-off-by: Li Zhanhui <lizhanhui@gmail.com> * feat: revamp TelemetryBidiReactor states and their transition graph Signed-off-by: Li Zhanhui <lizhanhui@gmail.com> * fix: example publish message QPS stats lambda * Fifo opt (#732) * Prepare to optimize FIFO publishing Signed-off-by: Li Zhanhui <lizhanhui@gmail.com> * fix: SendReceipt now contains std::unique_ptr<Message> being sent Signed-off-by: Li Zhanhui <lizhanhui@gmail.com> * fix: add doc explaining why we taking ownership of the message being sent Signed-off-by: Li Zhanhui <lizhanhui@gmail.com> * feat: implement FifoProducerPartition Signed-off-by: Li Zhanhui <lizhanhui@gmail.com> * feat: implement FifoProducerImpl Signed-off-by: Li Zhanhui <lizhanhui@gmail.com> * feat: implement builder for FifoProducer Signed-off-by: Li Zhanhui <lizhanhui@gmail.com> * fix: prepare to debug Signed-off-by: Li Zhanhui <lizhanhui@gmail.com> * fix: log sending sending stages Signed-off-by: Li Zhanhui <lizhanhui@gmail.com> --------- Signed-off-by: Li Zhanhui <lizhanhui@gmail.com> * fix: spell errors Signed-off-by: Li Zhanhui <lizhanhui@gmail.com> * fix: markdown code blocks should be fenced by blank lines Signed-off-by: Li Zhanhui <lizhanhui@gmail.com> * fix: copyright header Signed-off-by: Li Zhanhui <lizhanhui@gmail.com> * fix: copyright header Signed-off-by: Li Zhanhui <lizhanhui@gmail.com> * fix: include statements Signed-off-by: Zhanhui Li <lizhanhui@gmail.com> * feat: build example_fifo_producer in BUILD.bazel Signed-off-by: Zhanhui Li <lizhanhui@gmail.com> * fix: #713 correct misuse of absl::make_optional Signed-off-by: Zhanhui Li <lizhanhui@gmail.com> --------- Signed-off-by: Zhanhui Li <lizhanhui@gmail.com> Signed-off-by: lizhanhui <lizhanhui@gmail.com> Signed-off-by: Li Zhanhui <lizhanhui@gmail.com>
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
Which Issue(s) This PR Fixes
Fixes #issue_id
Brief Description
How Did You Test This Change?