-
Notifications
You must be signed in to change notification settings - Fork 877
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
fix(set): fix random in SRANDMEMBER and SPOP commands #3022
fix(set): fix random in SRANDMEMBER and SPOP commands #3022
Conversation
|
||
class NonUniquePicksGenerator : public PicksGenerator { | ||
public: | ||
NonUniquePicksGenerator(RandomPick max_range); |
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.
We can add a comment for max_range is open or closed
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.
Fixed
src/server/set_family.cc
Outdated
@@ -284,19 +284,32 @@ void InterStrSet(const DbContext& db_context, const vector<SetType>& vec, String | |||
} | |||
} | |||
|
|||
StringVec PopStrSet(const DbContext& db_context, unsigned count, const SetType& st) { | |||
StringVec RandMemberStrSet(const DbContext& db_context, const SetType& st, | |||
const std::unique_ptr<PicksGenerator>& generator, |
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.
Would a virtual function making it even slower?
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.
- You can pass just const PicksGenerator&
- I don't think the virtual function call adds any mesurable latency 🙂
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.
I agree with @dranikpg, keep the virtual function call as it was
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.
Sorry if this was not ready for review, just strolling by 👣
src/server/set_family.cc
Outdated
std::copy(result.begin(), result.end(), mapped.begin() + 1); | ||
RecordJournal(op_args, "SREM"sv, mapped); | ||
} | ||
StringVec rand_members = rand_members_result.value(); |
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.
that's a copy 👮🏻
src/server/set_family.cc
Outdated
ArgSlice span{members_to_remove.data(), members_to_remove.size()}; | ||
|
||
auto rem_members_result = OpRem(op_args, key, span, false); | ||
if (!rem_members_result) { | ||
return rem_members_result.status(); | ||
} |
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.
RETURN_ON_BAD_STATUS(op_args, key, absl::MakeSpan(members), false)
😅
src/server/set_family.cc
Outdated
int count = 1; | ||
if (args.size() > 1) { | ||
string_view arg = ArgS(args, 1); | ||
if (!absl::SimpleAtoi(arg, &count)) { |
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.
This changes what overload of SimpleAtoi is selected
auto ConsistsOf(std::initializer_list<std::string> elements) { | ||
return ConsistsOfMatcher(std::unordered_set<std::string>{elements}); | ||
} |
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.
🤩
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.
Please explain what this means 😀
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.
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.
хороший кот
src/server/set_family.cc
Outdated
std::unique_ptr<PicksGenerator> generator = | ||
picks_are_unique ? static_cast<std::unique_ptr<PicksGenerator>>( | ||
std::make_unique<UniquePicksGenerator>(picks_count, size)) | ||
: std::make_unique<NonUniquePicksGenerator>(size); |
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.
ok mabye the function thing was more readable 😆 You can always also just use a declaration and an if after
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.
Ok, I'll fix it in zset_family.cc
too
src/server/set_family.cc
Outdated
@@ -284,19 +284,32 @@ void InterStrSet(const DbContext& db_context, const vector<SetType>& vec, String | |||
} | |||
} | |||
|
|||
StringVec PopStrSet(const DbContext& db_context, unsigned count, const SetType& st) { | |||
StringVec RandMemberStrSet(const DbContext& db_context, const SetType& st, | |||
const std::unique_ptr<PicksGenerator>& generator, |
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.
- You can pass just const PicksGenerator&
- I don't think the virtual function call adds any mesurable latency 🙂
src/server/set_family.cc
Outdated
std::uint32_t ss_entry_index = 0; | ||
for (const sds ptr : *ss) { | ||
std::uint32_t t = times_index_is_picked[ss_entry_index++]; | ||
while (t--) { | ||
result.emplace_back(ptr, sdslen(ptr)); | ||
} |
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.
you use an unordered_map, but during iteration you'll end up creating every cell up to N because of [ss_entry_index]
, so better use find()
src/server/set_family.cc
Outdated
} | ||
} | ||
|
||
/* Members in result are sorted by scores. So, it is necessary to shuffle them*/ |
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.
Scores? I think you just mean that equal elements are always succesive and we're limited by the string-set order
src/server/set_family.cc
Outdated
int64_t value; | ||
DCHECK_GT(intsetGet(is, picked_index, &value), std::uint8_t(0)); | ||
|
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.
DCHECK it's not called in release builds 🙂
0f19aa7
to
74b498d
Compare
74b498d
to
a1162b7
Compare
fixes dragonflydb#3018 Signed-off-by: Stepan Bagritsevich <sbagritsevich@quantumbrains.com>
a1162b7
to
1111eb5
Compare
Fix a bug where replicas remove other elements during |
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.
👍🏻 (Please push separate commits in the future so it's easier to see changes)
…nfly ( v1.18.1 → v1.19.0 ) (#3784) This PR contains the following updates: | Package | Update | Change | |---|---|---| | [docker.dragonflydb.io/dragonflydb/dragonfly](https://togithub.com/dragonflydb/dragonfly) | minor | `v1.18.1` -> `v1.19.0` | --- ### Release Notes <details> <summary>dragonflydb/dragonfly (docker.dragonflydb.io/dragonflydb/dragonfly)</summary> ### [`v1.19.0`](https://togithub.com/dragonflydb/dragonfly/releases/tag/v1.19.0) [Compare Source](https://togithub.com/dragonflydb/dragonfly/compare/v1.18.1...v1.19.0) ##### Dragonfly v1.19.0 Some prominent changes include: - SPOP and SRANDMEMBER return truly randomized results ([#​3022](https://togithub.com/dragonflydb/dragonfly/issues/3022)) - Fix memory blowup in some cases during replication ([#​3084](https://togithub.com/dragonflydb/dragonfly/issues/3084) [#​3103](https://togithub.com/dragonflydb/dragonfly/issues/3103)) - Snapshotting works with data tiering ([#​3073](https://togithub.com/dragonflydb/dragonfly/issues/3073)) - Fix incompatibility issue of RDB snapshot with Redis 6.x ([#​3121](https://togithub.com/dragonflydb/dragonfly/issues/3121)) - Memory utilization improvements + better introspection of memory usage via /metrics ##### What's Changed - chore: update versions and remove caching code by [@​romange](https://togithub.com/romange) in [dragonflydb/dragonfly#3030 - chore: fix macos tiering by [@​dranikpg](https://togithub.com/dranikpg) in [dragonflydb/dragonfly#3032 - feat: support subrange expressions in jsonpathv2 by [@​romange](https://togithub.com/romange) in [dragonflydb/dragonfly#3036 - fix: reduce delay when stop replica [#​3020](https://togithub.com/dragonflydb/dragonfly/issues/3020) by [@​BorysTheDev](https://togithub.com/BorysTheDev) in [dragonflydb/dragonfly#3028 - fix(set): fix random in SRANDMEMBER and SPOP commands by [@​BagritsevichStepan](https://togithub.com/BagritsevichStepan) in [dragonflydb/dragonfly#3022 - chore: prevent updating gcc on macos by [@​romange](https://togithub.com/romange) in [dragonflydb/dragonfly#3037 - chore: add half-range indices by [@​romange](https://togithub.com/romange) in [dragonflydb/dragonfly#3041 - chore: update helio together with new mimalloc version by [@​romange](https://togithub.com/romange) in [dragonflydb/dragonfly#3040 - fix: header for oom_errors_total by [@​romange](https://togithub.com/romange) in [dragonflydb/dragonfly#3043 - chore: reset enable_direct_fd to avoid socket leakage in kernel by [@​romange](https://togithub.com/romange) in [dragonflydb/dragonfly#3051 - chore: update deprecated actions by [@​romange](https://togithub.com/romange) in [dragonflydb/dragonfly#3052 - chore: remove unneeded check-fails by [@​romange](https://togithub.com/romange) in [dragonflydb/dragonfly#3054 - chore: Export replication memory stats by [@​romange](https://togithub.com/romange) in [dragonflydb/dragonfly#3062 - <chore>!: Update grafana panel by [@​MaoMaoCake](https://togithub.com/MaoMaoCake) in [dragonflydb/dragonfly#3064 - chore: add replication memory stats to the dashboard by [@​romange](https://togithub.com/romange) in [dragonflydb/dragonfly#3065 - chore: bpop prints by [@​dranikpg](https://togithub.com/dranikpg) in [dragonflydb/dragonfly#3076 - fix(tiering): wait for IO before test teardown by [@​dranikpg](https://togithub.com/dranikpg) in [dragonflydb/dragonfly#3079 - chore: small replayer fixes by [@​dranikpg](https://togithub.com/dranikpg) in [dragonflydb/dragonfly#3081 - fix: increase lua stack limit to 8KB by [@​romange](https://togithub.com/romange) in [dragonflydb/dragonfly#3080 - chore: minor fixes by [@​romange](https://togithub.com/romange) in [dragonflydb/dragonfly#3082 - fix: fix cluster incorrect keys status by [@​BorysTheDev](https://togithub.com/BorysTheDev) in [dragonflydb/dragonfly#3083 - fix(acl): return -NOPERM instead of response error by [@​kostasrim](https://togithub.com/kostasrim) in [dragonflydb/dragonfly#3049 - feat(server): Expose serialization bytes via `INFO` and `/metrics` by [@​chakaz](https://togithub.com/chakaz) in [dragonflydb/dragonfly#3087 - chore(streams): Some refactoring by [@​dranikpg](https://togithub.com/dranikpg) in [dragonflydb/dragonfly#3088 - feat(server): remove multi shard sync from replication by [@​adiholden](https://togithub.com/adiholden) in [dragonflydb/dragonfly#3085 - fix(replication): fullsync phase write to sync on noop by [@​adiholden](https://togithub.com/adiholden) in [dragonflydb/dragonfly#3084 - fix(tiering): Async delete for small bins by [@​dranikpg](https://togithub.com/dranikpg) in [dragonflydb/dragonfly#3068 - fix: prevent crashing if error happened during snapshot moving by [@​BorysTheDev](https://togithub.com/BorysTheDev) in [dragonflydb/dragonfly#3092 - fix: add timeout for DFLYMIGRATE ACK to prevent deadlock by [@​BorysTheDev](https://togithub.com/BorysTheDev) in [dragonflydb/dragonfly#3093 - chore: improve Migration() by [@​kostasrim](https://togithub.com/kostasrim) in [dragonflydb/dragonfly#3033 - feat(streams): Stream optimizations by [@​dranikpg](https://togithub.com/dranikpg) in [dragonflydb/dragonfly#3091 - feat(tiering): Defragmentation by [@​dranikpg](https://togithub.com/dranikpg) in [dragonflydb/dragonfly#3021 - fix: bit shift of kTagMask by [@​haodongnj](https://togithub.com/haodongnj) in [dragonflydb/dragonfly#3099 - feat(cluster_mgr): Allow attaching replicas by [@​chakaz](https://togithub.com/chakaz) in [dragonflydb/dragonfly#3105 - bug(server): fix replication stuck in full sync by [@​adiholden](https://togithub.com/adiholden) in [dragonflydb/dragonfly#3103 - fix(server): Sync FLUSH with tiering by [@​dranikpg](https://togithub.com/dranikpg) in [dragonflydb/dragonfly#3098 - chore: export pipeline related metrics by [@​romange](https://togithub.com/romange) in [dragonflydb/dragonfly#3104 - chore: zset error log (from 1.18 branch) by [@​dranikpg](https://togithub.com/dranikpg) in [dragonflydb/dragonfly#3109 - New test for cluster migration: connection issue by [@​BorysTheDev](https://togithub.com/BorysTheDev) in [dragonflydb/dragonfly#3102 - chore: minor fixes + remove redundant DCHECK by [@​romange](https://togithub.com/romange) in [dragonflydb/dragonfly#3115 - fix: fix cluster_fuzzy_migration test by [@​BorysTheDev](https://togithub.com/BorysTheDev) in [dragonflydb/dragonfly#3116 - feat(server): Pipeline and dispatch on `/metrics` by [@​chakaz](https://togithub.com/chakaz) in [dragonflydb/dragonfly#3117 - chore: pull helio add test for tls deadlock by [@​kostasrim](https://togithub.com/kostasrim) in [dragonflydb/dragonfly#3111 - feat(cluster_mgr): Improvements to `cluster_mgr.py` by [@​chakaz](https://togithub.com/chakaz) in [dragonflydb/dragonfly#3118 - refactor client tracking, fix atomicity, squashing and multi/exec by [@​kostasrim](https://togithub.com/kostasrim) in [dragonflydb/dragonfly#2970 - fix(server): fix compatibility with rdb snapshot by [@​adiholden](https://togithub.com/adiholden) in [dragonflydb/dragonfly#3121 - Revert "refactor client tracking, fix atomicity, squashing and multi/… by [@​adiholden](https://togithub.com/adiholden) in [dragonflydb/dragonfly#3122 - feat(cluster_mgr): Take over command by [@​chakaz](https://togithub.com/chakaz) in [dragonflydb/dragonfly#3120 - fix: fix RestoreStreamer to prevent buckets skipping [#​2830](https://togithub.com/dragonflydb/dragonfly/issues/2830) by [@​BorysTheDev](https://togithub.com/BorysTheDev) in [dragonflydb/dragonfly#3119 - feat(cluster_mgr): Fix migration action by [@​chakaz](https://togithub.com/chakaz) in [dragonflydb/dragonfly#3124 - chore: prevent Dispatch fiber to be launched during migration by [@​romange](https://togithub.com/romange) in [dragonflydb/dragonfly#3123 - feat(tiering): Simple snapshotting by [@​dranikpg](https://togithub.com/dranikpg) in [dragonflydb/dragonfly#3073 - fix: upload action in version release by [@​romange](https://togithub.com/romange) in [dragonflydb/dragonfly#3127 ##### New Contributors - [@​MaoMaoCake](https://togithub.com/MaoMaoCake) made their first contribution in [dragonflydb/dragonfly#3064 - [@​haodongnj](https://togithub.com/haodongnj) made their first contribution in [dragonflydb/dragonfly#3099 ##### Huge thanks to all the contributors! ❤️ **Full Changelog**: dragonflydb/dragonfly@v1.18.0...v1.19.0 </details> <!--renovate-debug:eyJjcmVhdGVkSW5WZXIiOiIzNy4zOTEuMCIsInVwZGF0ZWRJblZlciI6IjM3LjM5MS4wIiwidGFyZ2V0QnJhbmNoIjoibWFpbiIsImxhYmVscyI6WyJyZW5vdmF0ZS9jb250YWluZXIiLCJ0eXBlL21pbm9yIl19--> Co-authored-by: repo-jeeves[bot] <106431701+repo-jeeves[bot]@users.noreply.github.com>
…nfly ( v1.18.1 → v1.19.0 ) (#629) This PR contains the following updates: | Package | Update | Change | |---|---|---| | [docker.dragonflydb.io/dragonflydb/dragonfly](https://togithub.com/dragonflydb/dragonfly) | minor | `v1.18.1` -> `v1.19.0` | --- ### Release Notes <details> <summary>dragonflydb/dragonfly (docker.dragonflydb.io/dragonflydb/dragonfly)</summary> ### [`v1.19.0`](https://togithub.com/dragonflydb/dragonfly/releases/tag/v1.19.0) [Compare Source](https://togithub.com/dragonflydb/dragonfly/compare/v1.18.1...v1.19.0) ##### Dragonfly v1.19.0 Some prominent changes include: - SPOP and SRANDMEMBER return truly randomized results ([#​3022](https://togithub.com/dragonflydb/dragonfly/issues/3022)) - Fix memory blowup in some cases during replication ([#​3084](https://togithub.com/dragonflydb/dragonfly/issues/3084) [#​3103](https://togithub.com/dragonflydb/dragonfly/issues/3103)) - Snapshotting works with data tiering ([#​3073](https://togithub.com/dragonflydb/dragonfly/issues/3073)) - Fix incompatibility issue of RDB snapshot with Redis 6.x ([#​3121](https://togithub.com/dragonflydb/dragonfly/issues/3121)) - Memory utilization improvements + better introspection of memory usage via /metrics ##### What's Changed - chore: update versions and remove caching code by [@​romange](https://togithub.com/romange) in [dragonflydb/dragonfly#3030 - chore: fix macos tiering by [@​dranikpg](https://togithub.com/dranikpg) in [dragonflydb/dragonfly#3032 - feat: support subrange expressions in jsonpathv2 by [@​romange](https://togithub.com/romange) in [dragonflydb/dragonfly#3036 - fix: reduce delay when stop replica [#​3020](https://togithub.com/dragonflydb/dragonfly/issues/3020) by [@​BorysTheDev](https://togithub.com/BorysTheDev) in [dragonflydb/dragonfly#3028 - fix(set): fix random in SRANDMEMBER and SPOP commands by [@​BagritsevichStepan](https://togithub.com/BagritsevichStepan) in [dragonflydb/dragonfly#3022 - chore: prevent updating gcc on macos by [@​romange](https://togithub.com/romange) in [dragonflydb/dragonfly#3037 - chore: add half-range indices by [@​romange](https://togithub.com/romange) in [dragonflydb/dragonfly#3041 - chore: update helio together with new mimalloc version by [@​romange](https://togithub.com/romange) in [dragonflydb/dragonfly#3040 - fix: header for oom_errors_total by [@​romange](https://togithub.com/romange) in [dragonflydb/dragonfly#3043 - chore: reset enable_direct_fd to avoid socket leakage in kernel by [@​romange](https://togithub.com/romange) in [dragonflydb/dragonfly#3051 - chore: update deprecated actions by [@​romange](https://togithub.com/romange) in [dragonflydb/dragonfly#3052 - chore: remove unneeded check-fails by [@​romange](https://togithub.com/romange) in [dragonflydb/dragonfly#3054 - chore: Export replication memory stats by [@​romange](https://togithub.com/romange) in [dragonflydb/dragonfly#3062 - <chore>!: Update grafana panel by [@​MaoMaoCake](https://togithub.com/MaoMaoCake) in [dragonflydb/dragonfly#3064 - chore: add replication memory stats to the dashboard by [@​romange](https://togithub.com/romange) in [dragonflydb/dragonfly#3065 - chore: bpop prints by [@​dranikpg](https://togithub.com/dranikpg) in [dragonflydb/dragonfly#3076 - fix(tiering): wait for IO before test teardown by [@​dranikpg](https://togithub.com/dranikpg) in [dragonflydb/dragonfly#3079 - chore: small replayer fixes by [@​dranikpg](https://togithub.com/dranikpg) in [dragonflydb/dragonfly#3081 - fix: increase lua stack limit to 8KB by [@​romange](https://togithub.com/romange) in [dragonflydb/dragonfly#3080 - chore: minor fixes by [@​romange](https://togithub.com/romange) in [dragonflydb/dragonfly#3082 - fix: fix cluster incorrect keys status by [@​BorysTheDev](https://togithub.com/BorysTheDev) in [dragonflydb/dragonfly#3083 - fix(acl): return -NOPERM instead of response error by [@​kostasrim](https://togithub.com/kostasrim) in [dragonflydb/dragonfly#3049 - feat(server): Expose serialization bytes via `INFO` and `/metrics` by [@​chakaz](https://togithub.com/chakaz) in [dragonflydb/dragonfly#3087 - chore(streams): Some refactoring by [@​dranikpg](https://togithub.com/dranikpg) in [dragonflydb/dragonfly#3088 - feat(server): remove multi shard sync from replication by [@​adiholden](https://togithub.com/adiholden) in [dragonflydb/dragonfly#3085 - fix(replication): fullsync phase write to sync on noop by [@​adiholden](https://togithub.com/adiholden) in [dragonflydb/dragonfly#3084 - fix(tiering): Async delete for small bins by [@​dranikpg](https://togithub.com/dranikpg) in [dragonflydb/dragonfly#3068 - fix: prevent crashing if error happened during snapshot moving by [@​BorysTheDev](https://togithub.com/BorysTheDev) in [dragonflydb/dragonfly#3092 - fix: add timeout for DFLYMIGRATE ACK to prevent deadlock by [@​BorysTheDev](https://togithub.com/BorysTheDev) in [dragonflydb/dragonfly#3093 - chore: improve Migration() by [@​kostasrim](https://togithub.com/kostasrim) in [dragonflydb/dragonfly#3033 - feat(streams): Stream optimizations by [@​dranikpg](https://togithub.com/dranikpg) in [dragonflydb/dragonfly#3091 - feat(tiering): Defragmentation by [@​dranikpg](https://togithub.com/dranikpg) in [dragonflydb/dragonfly#3021 - fix: bit shift of kTagMask by [@​haodongnj](https://togithub.com/haodongnj) in [dragonflydb/dragonfly#3099 - feat(cluster_mgr): Allow attaching replicas by [@​chakaz](https://togithub.com/chakaz) in [dragonflydb/dragonfly#3105 - bug(server): fix replication stuck in full sync by [@​adiholden](https://togithub.com/adiholden) in [dragonflydb/dragonfly#3103 - fix(server): Sync FLUSH with tiering by [@​dranikpg](https://togithub.com/dranikpg) in [dragonflydb/dragonfly#3098 - chore: export pipeline related metrics by [@​romange](https://togithub.com/romange) in [dragonflydb/dragonfly#3104 - chore: zset error log (from 1.18 branch) by [@​dranikpg](https://togithub.com/dranikpg) in [dragonflydb/dragonfly#3109 - New test for cluster migration: connection issue by [@​BorysTheDev](https://togithub.com/BorysTheDev) in [dragonflydb/dragonfly#3102 - chore: minor fixes + remove redundant DCHECK by [@​romange](https://togithub.com/romange) in [dragonflydb/dragonfly#3115 - fix: fix cluster_fuzzy_migration test by [@​BorysTheDev](https://togithub.com/BorysTheDev) in [dragonflydb/dragonfly#3116 - feat(server): Pipeline and dispatch on `/metrics` by [@​chakaz](https://togithub.com/chakaz) in [dragonflydb/dragonfly#3117 - chore: pull helio add test for tls deadlock by [@​kostasrim](https://togithub.com/kostasrim) in [dragonflydb/dragonfly#3111 - feat(cluster_mgr): Improvements to `cluster_mgr.py` by [@​chakaz](https://togithub.com/chakaz) in [dragonflydb/dragonfly#3118 - refactor client tracking, fix atomicity, squashing and multi/exec by [@​kostasrim](https://togithub.com/kostasrim) in [dragonflydb/dragonfly#2970 - fix(server): fix compatibility with rdb snapshot by [@​adiholden](https://togithub.com/adiholden) in [dragonflydb/dragonfly#3121 - Revert "refactor client tracking, fix atomicity, squashing and multi/… by [@​adiholden](https://togithub.com/adiholden) in [dragonflydb/dragonfly#3122 - feat(cluster_mgr): Take over command by [@​chakaz](https://togithub.com/chakaz) in [dragonflydb/dragonfly#3120 - fix: fix RestoreStreamer to prevent buckets skipping [#​2830](https://togithub.com/dragonflydb/dragonfly/issues/2830) by [@​BorysTheDev](https://togithub.com/BorysTheDev) in [dragonflydb/dragonfly#3119 - feat(cluster_mgr): Fix migration action by [@​chakaz](https://togithub.com/chakaz) in [dragonflydb/dragonfly#3124 - chore: prevent Dispatch fiber to be launched during migration by [@​romange](https://togithub.com/romange) in [dragonflydb/dragonfly#3123 - feat(tiering): Simple snapshotting by [@​dranikpg](https://togithub.com/dranikpg) in [dragonflydb/dragonfly#3073 - fix: upload action in version release by [@​romange](https://togithub.com/romange) in [dragonflydb/dragonfly#3127 ##### New Contributors - [@​MaoMaoCake](https://togithub.com/MaoMaoCake) made their first contribution in [dragonflydb/dragonfly#3064 - [@​haodongnj](https://togithub.com/haodongnj) made their first contribution in [dragonflydb/dragonfly#3099 ##### Huge thanks to all the contributors! ❤️ **Full Changelog**: dragonflydb/dragonfly@v1.18.0...v1.19.0 </details> --- ### Configuration 📅 **Schedule**: Branch creation - At any time (no schedule defined), Automerge - At any time (no schedule defined). 🚦 **Automerge**: Disabled by config. Please merge this manually once you are satisfied. ♻ **Rebasing**: Whenever PR becomes conflicted, or you tick the rebase/retry checkbox. 🔕 **Ignore**: Close this PR and you won't be reminded about these updates again. --- - [ ] <!-- rebase-check -->If you want to rebase/retry this PR, check this box --- This PR has been generated by [Renovate Bot](https://togithub.com/renovatebot/renovate). <!--renovate-debug:eyJjcmVhdGVkSW5WZXIiOiIzNy4zOTAuMSIsInVwZGF0ZWRJblZlciI6IjM3LjM5MC4xIiwidGFyZ2V0QnJhbmNoIjoibWFpbiIsImxhYmVscyI6WyJyZW5vdmF0ZS9jb250YWluZXIiLCJ0eXBlL21pbm9yIl19--> Co-authored-by: kireque-bot[bot] <143391978+kireque-bot[bot]@users.noreply.github.com>
…19.0 ) (#4821) This PR contains the following updates: | Package | Update | Change | |---|---|---| | [ghcr.io/dragonflydb/dragonfly](https://togithub.com/dragonflydb/dragonfly) | minor | `v1.18.1` -> `v1.19.0` | --- > [!WARNING] > Some dependencies could not be looked up. Check the Dependency Dashboard for more information. --- ### Release Notes <details> <summary>dragonflydb/dragonfly (ghcr.io/dragonflydb/dragonfly)</summary> ### [`v1.19.0`](https://togithub.com/dragonflydb/dragonfly/releases/tag/v1.19.0) [Compare Source](https://togithub.com/dragonflydb/dragonfly/compare/v1.18.1...v1.19.0) ##### Dragonfly v1.19.0 Some prominent changes include: - SPOP and SRANDMEMBER return truly randomized results ([#​3022](https://togithub.com/dragonflydb/dragonfly/issues/3022)) - Fix memory blowup in some cases during replication ([#​3084](https://togithub.com/dragonflydb/dragonfly/issues/3084) [#​3103](https://togithub.com/dragonflydb/dragonfly/issues/3103)) - Snapshotting works with data tiering ([#​3073](https://togithub.com/dragonflydb/dragonfly/issues/3073)) - Fix incompatibility issue of RDB snapshot with Redis 6.x ([#​3121](https://togithub.com/dragonflydb/dragonfly/issues/3121)) - Memory utilization improvements + better introspection of memory usage via /metrics ##### What's Changed - chore: update versions and remove caching code by [@​romange](https://togithub.com/romange) in [dragonflydb/dragonfly#3030 - chore: fix macos tiering by [@​dranikpg](https://togithub.com/dranikpg) in [dragonflydb/dragonfly#3032 - feat: support subrange expressions in jsonpathv2 by [@​romange](https://togithub.com/romange) in [dragonflydb/dragonfly#3036 - fix: reduce delay when stop replica [#​3020](https://togithub.com/dragonflydb/dragonfly/issues/3020) by [@​BorysTheDev](https://togithub.com/BorysTheDev) in [dragonflydb/dragonfly#3028 - fix(set): fix random in SRANDMEMBER and SPOP commands by [@​BagritsevichStepan](https://togithub.com/BagritsevichStepan) in [dragonflydb/dragonfly#3022 - chore: prevent updating gcc on macos by [@​romange](https://togithub.com/romange) in [dragonflydb/dragonfly#3037 - chore: add half-range indices by [@​romange](https://togithub.com/romange) in [dragonflydb/dragonfly#3041 - chore: update helio together with new mimalloc version by [@​romange](https://togithub.com/romange) in [dragonflydb/dragonfly#3040 - fix: header for oom_errors_total by [@​romange](https://togithub.com/romange) in [dragonflydb/dragonfly#3043 - chore: reset enable_direct_fd to avoid socket leakage in kernel by [@​romange](https://togithub.com/romange) in [dragonflydb/dragonfly#3051 - chore: update deprecated actions by [@​romange](https://togithub.com/romange) in [dragonflydb/dragonfly#3052 - chore: remove unneeded check-fails by [@​romange](https://togithub.com/romange) in [dragonflydb/dragonfly#3054 - chore: Export replication memory stats by [@​romange](https://togithub.com/romange) in [dragonflydb/dragonfly#3062 - <chore>!: Update grafana panel by [@​MaoMaoCake](https://togithub.com/MaoMaoCake) in [dragonflydb/dragonfly#3064 - chore: add replication memory stats to the dashboard by [@​romange](https://togithub.com/romange) in [dragonflydb/dragonfly#3065 - chore: bpop prints by [@​dranikpg](https://togithub.com/dranikpg) in [dragonflydb/dragonfly#3076 - fix(tiering): wait for IO before test teardown by [@​dranikpg](https://togithub.com/dranikpg) in [dragonflydb/dragonfly#3079 - chore: small replayer fixes by [@​dranikpg](https://togithub.com/dranikpg) in [dragonflydb/dragonfly#3081 - fix: increase lua stack limit to 8KB by [@​romange](https://togithub.com/romange) in [dragonflydb/dragonfly#3080 - chore: minor fixes by [@​romange](https://togithub.com/romange) in [dragonflydb/dragonfly#3082 - fix: fix cluster incorrect keys status by [@​BorysTheDev](https://togithub.com/BorysTheDev) in [dragonflydb/dragonfly#3083 - fix(acl): return -NOPERM instead of response error by [@​kostasrim](https://togithub.com/kostasrim) in [dragonflydb/dragonfly#3049 - feat(server): Expose serialization bytes via `INFO` and `/metrics` by [@​chakaz](https://togithub.com/chakaz) in [dragonflydb/dragonfly#3087 - chore(streams): Some refactoring by [@​dranikpg](https://togithub.com/dranikpg) in [dragonflydb/dragonfly#3088 - feat(server): remove multi shard sync from replication by [@​adiholden](https://togithub.com/adiholden) in [dragonflydb/dragonfly#3085 - fix(replication): fullsync phase write to sync on noop by [@​adiholden](https://togithub.com/adiholden) in [dragonflydb/dragonfly#3084 - fix(tiering): Async delete for small bins by [@​dranikpg](https://togithub.com/dranikpg) in [dragonflydb/dragonfly#3068 - fix: prevent crashing if error happened during snapshot moving by [@​BorysTheDev](https://togithub.com/BorysTheDev) in [dragonflydb/dragonfly#3092 - fix: add timeout for DFLYMIGRATE ACK to prevent deadlock by [@​BorysTheDev](https://togithub.com/BorysTheDev) in [dragonflydb/dragonfly#3093 - chore: improve Migration() by [@​kostasrim](https://togithub.com/kostasrim) in [dragonflydb/dragonfly#3033 - feat(streams): Stream optimizations by [@​dranikpg](https://togithub.com/dranikpg) in [dragonflydb/dragonfly#3091 - feat(tiering): Defragmentation by [@​dranikpg](https://togithub.com/dranikpg) in [dragonflydb/dragonfly#3021 - fix: bit shift of kTagMask by [@​haodongnj](https://togithub.com/haodongnj) in [dragonflydb/dragonfly#3099 - feat(cluster_mgr): Allow attaching replicas by [@​chakaz](https://togithub.com/chakaz) in [dragonflydb/dragonfly#3105 - bug(server): fix replication stuck in full sync by [@​adiholden](https://togithub.com/adiholden) in [dragonflydb/dragonfly#3103 - fix(server): Sync FLUSH with tiering by [@​dranikpg](https://togithub.com/dranikpg) in [dragonflydb/dragonfly#3098 - chore: export pipeline related metrics by [@​romange](https://togithub.com/romange) in [dragonflydb/dragonfly#3104 - chore: zset error log (from 1.18 branch) by [@​dranikpg](https://togithub.com/dranikpg) in [dragonflydb/dragonfly#3109 - New test for cluster migration: connection issue by [@​BorysTheDev](https://togithub.com/BorysTheDev) in [dragonflydb/dragonfly#3102 - chore: minor fixes + remove redundant DCHECK by [@​romange](https://togithub.com/romange) in [dragonflydb/dragonfly#3115 - fix: fix cluster_fuzzy_migration test by [@​BorysTheDev](https://togithub.com/BorysTheDev) in [dragonflydb/dragonfly#3116 - feat(server): Pipeline and dispatch on `/metrics` by [@​chakaz](https://togithub.com/chakaz) in [dragonflydb/dragonfly#3117 - chore: pull helio add test for tls deadlock by [@​kostasrim](https://togithub.com/kostasrim) in [dragonflydb/dragonfly#3111 - feat(cluster_mgr): Improvements to `cluster_mgr.py` by [@​chakaz](https://togithub.com/chakaz) in [dragonflydb/dragonfly#3118 - refactor client tracking, fix atomicity, squashing and multi/exec by [@​kostasrim](https://togithub.com/kostasrim) in [dragonflydb/dragonfly#2970 - fix(server): fix compatibility with rdb snapshot by [@​adiholden](https://togithub.com/adiholden) in [dragonflydb/dragonfly#3121 - Revert "refactor client tracking, fix atomicity, squashing and multi/… by [@​adiholden](https://togithub.com/adiholden) in [dragonflydb/dragonfly#3122 - feat(cluster_mgr): Take over command by [@​chakaz](https://togithub.com/chakaz) in [dragonflydb/dragonfly#3120 - fix: fix RestoreStreamer to prevent buckets skipping [#​2830](https://togithub.com/dragonflydb/dragonfly/issues/2830) by [@​BorysTheDev](https://togithub.com/BorysTheDev) in [dragonflydb/dragonfly#3119 - feat(cluster_mgr): Fix migration action by [@​chakaz](https://togithub.com/chakaz) in [dragonflydb/dragonfly#3124 - chore: prevent Dispatch fiber to be launched during migration by [@​romange](https://togithub.com/romange) in [dragonflydb/dragonfly#3123 - feat(tiering): Simple snapshotting by [@​dranikpg](https://togithub.com/dranikpg) in [dragonflydb/dragonfly#3073 - fix: upload action in version release by [@​romange](https://togithub.com/romange) in [dragonflydb/dragonfly#3127 ##### New Contributors - [@​MaoMaoCake](https://togithub.com/MaoMaoCake) made their first contribution in [dragonflydb/dragonfly#3064 - [@​haodongnj](https://togithub.com/haodongnj) made their first contribution in [dragonflydb/dragonfly#3099 ##### Huge thanks to all the contributors! ❤️ **Full Changelog**: dragonflydb/dragonfly@v1.18.0...v1.19.0 </details> --- ### Configuration 📅 **Schedule**: Branch creation - At any time (no schedule defined), Automerge - At any time (no schedule defined). 🚦 **Automerge**: Disabled by config. Please merge this manually once you are satisfied. ♻ **Rebasing**: Whenever PR becomes conflicted, or you tick the rebase/retry checkbox. 🔕 **Ignore**: Close this PR and you won't be reminded about these updates again. --- - [ ] <!-- rebase-check -->If you want to rebase/retry this PR, check this box --- This PR has been generated by [Renovate Bot](https://togithub.com/renovatebot/renovate). <!--renovate-debug:eyJjcmVhdGVkSW5WZXIiOiIzNy4zOTAuMSIsInVwZGF0ZWRJblZlciI6IjM3LjM5MC4xIiwidGFyZ2V0QnJhbmNoIjoibWFpbiIsImxhYmVscyI6WyJyZW5vdmF0ZS9jb250YWluZXIiLCJ0eXBlL21pbm9yIl19--> Co-authored-by: lumiere-bot[bot] <98047013+lumiere-bot[bot]@users.noreply.github.com>
fixes #3018
IntSet
, the time complexity isO(n)
(n
- number of elements to return/remove). The space complexity is alsoO(n)
StrSet
, the time complexity isO(m)
(m
- number of elements in set). The space complexity isO(n)