Skip to content
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
5 changes: 5 additions & 0 deletions CHANGELOG.md
Original file line number Diff line number Diff line change
@@ -1,5 +1,10 @@
# Changelog

## 0.39.1 - 2025-07-22

### Bug fixes
- Fixed potential corrupted data in `DbnFileStore::Replay`

## 0.39.0 - 2025-07-15

### Breaking changes
Expand Down
2 changes: 1 addition & 1 deletion CMakeLists.txt
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@ cmake_minimum_required(VERSION 3.24..4.0)

project(
databento
VERSION 0.39.0
VERSION 0.39.1
LANGUAGES CXX
DESCRIPTION "Official Databento client library"
)
Expand Down
2 changes: 1 addition & 1 deletion pkg/PKGBUILD
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
# Maintainer: Databento <support@databento.com>
_pkgname=databento-cpp
pkgname=databento-cpp-git
pkgver=0.39.0
pkgver=0.39.1
pkgrel=1
pkgdesc="Official C++ client for Databento"
arch=('any')
Expand Down
2 changes: 1 addition & 1 deletion src/dbn_decoder.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -311,7 +311,7 @@ const databento::Record* DbnDecoder::DecodeRecord() {
}
}
current_record_ = Record{BufferRecordHeader()};
buffer_.Consume(current_record_.Size());
buffer_.ConsumeNoShift(current_record_.Size());
current_record_ = DbnDecoder::DecodeRecordCompat(
version_, upgrade_policy_, ts_out_, &compat_buffer_, current_record_);
return &current_record_;
Expand Down
3 changes: 1 addition & 2 deletions src/live_blocking.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -190,11 +190,10 @@ const databento::Record* LiveBlocking::NextRecord(
}
current_record_ = Record{BufferRecordHeader()};
const auto bytes_to_consume = current_record_.Size();
buffer_.ConsumeNoShift(bytes_to_consume);
current_record_ =
DbnDecoder::DecodeRecordCompat(version_, upgrade_policy_, send_ts_out_,
&compat_buffer_, current_record_);
// Can't consume til after upgrade as Consume may shift
buffer_.Consume(bytes_to_consume);
return &current_record_;
}

Expand Down
Loading