Skip to content

Commit d95d219

Browse files
author
Karolina Drabik
committed
send serialized cache counter to the client in custom payload
1 parent ef214f8 commit d95d219

File tree

2 files changed

+8
-0
lines changed

2 files changed

+8
-0
lines changed

tracing/trace_state.cc

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -359,4 +359,10 @@ void opentelemetry_state::serialize_replicas(bytes& serialized) const {
359359
void opentelemetry_state::serialize_statement_type(bytes& serialized) const {
360360
serialized += bytes{reinterpret_cast<const signed char*>(_statement_type.c_str()), _statement_type.length()};
361361
}
362+
363+
void opentelemetry_state::serialize_cache_counter(bytes& serialized) const {
364+
const auto counter = htonl(_cache_counter);
365+
const auto *counter_ptr = reinterpret_cast<const int8_t*>(&counter);
366+
serialized += bytes{counter_ptr, sizeof(counter)};
367+
}
362368
}

tracing/trace_state.hh

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -521,6 +521,7 @@ private:
521521

522522
void serialize_replicas(bytes& serialized) const;
523523
void serialize_statement_type(bytes& serialized) const;
524+
void serialize_cache_counter(bytes& serialized) const;
524525

525526
public:
526527
opentelemetry_state() = default;
@@ -538,6 +539,7 @@ public:
538539
bytes serialized{};
539540

540541
serialize_replicas(serialized);
542+
serialize_cache_counter(serialized);
541543
serialize_statement_type(serialized);
542544

543545
return serialized;

0 commit comments

Comments
 (0)