8000 vendor: Update vendored sources to duckdb/duckdb@8c40a99d4d1628d2ac8a689554209ddb44a72550 by github-actions[bot] · Pull Request #1252 · duckdb/duckdb-r · GitHub
[go: up one dir, main page]
More Web Proxy on the site http://driver.im/
Skip to content

vendor: Update vendored sources to duckdb/duckdb@8c40a99d4d1628d2ac8a689554209ddb44a72550 #1252

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

Merged
merged 1 commit into from
Jun 19, 2025
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
6 changes: 3 additions & 3 deletions src/duckdb/src/function/table/version/pragma_version.cpp
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
#ifndef DUCKDB_PATCH_VERSION
#define DUCKDB_PATCH_VERSION "1"
#define DUCKDB_PATCH_VERSION "2-dev8"
#endif
#ifndef DUCKDB_MINOR_VERSION
#define DUCKDB_MINOR_VERSION 3
Expand All @@ -8,10 +8,10 @@
#define DUCKDB_MAJOR_VERSION 1
#endif
#ifndef DUCKDB_VERSION
#define DUCKDB_VERSION "v1.3.1"
#define DUCKDB_VERSION "v1.3.2-dev8"
#endif
#ifndef DUCKDB_SOURCE_ID
#define DUCKDB_SOURCE_ID "2063dda3e6"
#define DUCKDB_SOURCE_ID "8c40a99d4d"
#endif
#include "duckdb/function/table/system_functions.hpp"
#include "duckdb/main/database.hpp"
Expand Down
8 changes: 5 additions & 3 deletions src/duckdb/src/storage/buffer/buffer_pool.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -211,19 +211,21 @@ void EvictionQueue::PurgeIteration(const idx_t purge_size) {
}

// bulk purge
idx_t actually_dequeued = q.try_dequeue_bulk(purge_nodes.begin(), purge_size);
const idx_t actually_dequeued = q.try_dequeue_bulk(purge_nodes.begin(), purge_size);

// retrieve all alive nodes that have been wrongly dequeued
idx_t alive_nodes = 0;
for (idx_t i = 0; i < actually_dequeued; i++) {
auto &node = purge_nodes[i];
auto handle = node.TryGetBlockHandle();
if (handle) {
q.enqueue(std::move(node));
alive_nodes++;
purge_nodes[alive_nodes++] = std::move(node);
}
}

// bulk re-add (TODO order them by timestamp to better retain the LRU behavior)
q.enqueue_bulk(purge_nodes.begin(), alive_nodes);

total_dead_nodes -= actually_dequeued - alive_nodes;
}

Expand Down
0