Pass msg to tracer

This commit is contained in:
Bojan Serafimov
2022-09-12 10:36:56 -04:00
parent 42f603cb13
commit 1209572cec
2 changed files with 7 additions and 4 deletions

View File

@@ -46,7 +46,8 @@ use postgres_ffi::v14::pg_constants::DEFAULTTABLESPACE_OID;
use postgres_ffi::BLCKSZ;
// Wrapped in libpq CopyData
enum PagestreamFeMessage {
// TODO these should be in a library outside the pageserver
pub enum PagestreamFeMessage {
Exists(PagestreamExistsRequest),
Nblocks(PagestreamNblocksRequest),
GetPage(PagestreamGetPageRequest),
@@ -54,7 +55,7 @@ enum PagestreamFeMessage {
}
// Wrapped in libpq CopyData
enum PagestreamBeMessage {
pub enum PagestreamBeMessage {
Exists(PagestreamExistsResponse),
Nblocks(PagestreamNblocksResponse),
GetPage(PagestreamGetPageResponse),
@@ -484,7 +485,7 @@ impl PageServerHandler {
// Trace request if needed
if let Some(t) = tracer.as_mut() {
t.trace() // TODO(now) pass zenith_fe_msg
t.trace(&zenith_fe_msg)
}
let response = match zenith_fe_msg {

View File

@@ -1,3 +1,5 @@
use crate::page_service::PagestreamFeMessage;
pub struct Tracer {}
impl Drop for Tracer {
@@ -11,7 +13,7 @@ impl Tracer {
Tracer {}
}
pub fn trace(&mut self) {
pub fn trace(&mut self, _msg: &PagestreamFeMessage) {
// TODO(now) implement
}