Compare commits

..

3 commits

Author SHA1 Message Date
Florian Lüke
5764d7f9c0 remove debug statement 2024-12-27 20:15:55 +01:00
Florian Lüke
06da32c728 cmake: fix misleading indentation 2024-12-27 20:15:23 +01:00
Florian Lüke
2ce5bdc0bc mana auto replay: report nng perf after the producer thread terminated 2024-12-27 20:15:01 +01:00
3 changed files with 10 additions and 12 deletions

View file

@ -35,11 +35,11 @@ if (MNODE_BUILD_TESTS)
endif()
include(FetchContent)
FetchContent_Declare(pybind11 GIT_REPOSITORY https://github.com/pybind/pybind11 GIT_TAG v2.13.6)
FetchContent_GetProperties(pybind11)
if(NOT pybind11_POPULATED)
FetchContent_Populate(pybind11)
add_subdirectory(${pybind11_SOURCE_DIR} ${pybind11_BINARY_DIR})
FetchContent_Declare(pybind11 GIT_REPOSITORY https://github.com/pybind/pybind11 GIT_TAG v2.13.6)
FetchContent_GetProperties(pybind11)
if(NOT pybind11_POPULATED)
FetchContent_Populate(pybind11)
add_subdirectory(${pybind11_SOURCE_DIR} ${pybind11_BINARY_DIR})
endif()
include(CMakeRC)

View file

@ -61,9 +61,6 @@ struct ObjectPath
objectName = components.back();
components.pop_back();
}
spdlog::debug("ObjectPath: objectName={}, components={}", objectName,
fmt::join(components, ", "));
}
};

View file

@ -344,10 +344,6 @@ struct NngPairStrategy: public ProcessingStrategy
}
report();
spdlog::debug("NngPairStrategy: producerTx: {:.2f} MiB, {} messages",
producerTx.bytes / (1024.0 * 1024), producerTx.messages);
spdlog::debug("NngPairStrategy: consumerRx: {:.2f} MiB, {} messages",
consumerRx.bytes / (1024.0 * 1024), consumerRx.messages);
}
void run(ListfileContext &listfileContext, ParserContext &parserContext) override
@ -366,6 +362,11 @@ struct NngPairStrategy: public ProcessingStrategy
if (producerThread.joinable())
producerThread.join();
spdlog::debug("NngPairStrategy: producerTx: {:.2f} MiB, {} messages",
producerTx.bytes / (1024.0 * 1024), producerTx.messages);
spdlog::debug("NngPairStrategy: consumerRx: {:.2f} MiB, {} messages",
consumerRx.bytes / (1024.0 * 1024), consumerRx.messages);
}
};