VER: Release 0.34.1

Author: threecgreen

CHANGELOG.md

@@ -1,6 +1,6 @@
 # Changelog
 
-## 0.34.1 - TBD
+## 0.34.1 - 2025-04-29
 
 ### Enhancements
 - Added `InstitutionalPrioritization` variant to `MatchingAlgorithm`

CMakeLists.txt

@@ -6,7 +6,7 @@ cmake_minimum_required(VERSION 3.24..4.0)
 
 project(
   databento
-  VERSION 0.34.0
+  VERSION 0.34.1
   LANGUAGES CXX
   DESCRIPTION "Official Databento client library"
 )

pkg/PKGBUILD

@@ -1,7 +1,7 @@
 # Maintainer: Databento <support@databento.com>
 _pkgname=databento-cpp
 pkgname=databento-cpp-git
-pkgver=0.34.0
+pkgver=0.34.1
 pkgrel=1
 pkgdesc="Official C++ client for Databento"
 arch=('any')

src/dbn_decoder.cpp

@@ -190,7 +190,7 @@ databento::Metadata DbnDecoder::DecodeMetadata() {
   input_->ReadExact(read_buffer_.data(), read_buffer_.size());
   buffer_idx_ = read_buffer_.size();
   auto metadata = DbnDecoder::DecodeMetadataFields(
-      version_, read_buffer_.data(), &*read_buffer_.cend());
+      version_, read_buffer_.data(), read_buffer_.data() + read_buffer_.size());
   ts_out_ = metadata.ts_out;
   metadata.Upgrade(upgrade_policy_);
   return metadata;

src/live_blocking.cpp

@@ -138,12 +138,16 @@ void LiveBlocking::Subscribe(std::string_view sub_msg,
 databento::Metadata LiveBlocking::Start() {
   client_.WriteAll("start_session\n");
   client_.ReadExact(buffer_.WriteBegin(), kMetadataPreludeSize);
+  buffer_.WriteBegin() += kMetadataPreludeSize;
   const auto [version, size] = DbnDecoder::DecodeMetadataVersionAndSize(
       buffer_.ReadBegin(), kMetadataPreludeSize);
-  std::vector<std::byte> meta_buffer(size);
-  client_.ReadExact(meta_buffer.data(), size);
-  auto metadata = DbnDecoder::DecodeMetadataFields(version, meta_buffer.data(),
-                                                   &*meta_buffer.end());
+  buffer_.ReadBegin() += kMetadataPreludeSize;
+  buffer_.Reserve(size);
+  client_.ReadExact(buffer_.WriteBegin(), size);
+  buffer_.WriteBegin() += size;
+  auto metadata = DbnDecoder::DecodeMetadataFields(version, buffer_.ReadBegin(),
+                                                   buffer_.ReadEnd());
+  buffer_.ReadBegin() += size;
   version_ = metadata.version;
   metadata.Upgrade(upgrade_policy_);
   return metadata;