Compare commits
3 commits
a7b5d50533
...
5764d7f9c0
Author | SHA1 | Date | |
---|---|---|---|
|
5764d7f9c0 | ||
|
06da32c728 | ||
|
2ce5bdc0bc |
3 changed files with 10 additions and 12 deletions
|
@ -35,11 +35,11 @@ if (MNODE_BUILD_TESTS)
|
||||||
endif()
|
endif()
|
||||||
|
|
||||||
include(FetchContent)
|
include(FetchContent)
|
||||||
FetchContent_Declare(pybind11 GIT_REPOSITORY https://github.com/pybind/pybind11 GIT_TAG v2.13.6)
|
FetchContent_Declare(pybind11 GIT_REPOSITORY https://github.com/pybind/pybind11 GIT_TAG v2.13.6)
|
||||||
FetchContent_GetProperties(pybind11)
|
FetchContent_GetProperties(pybind11)
|
||||||
if(NOT pybind11_POPULATED)
|
if(NOT pybind11_POPULATED)
|
||||||
FetchContent_Populate(pybind11)
|
FetchContent_Populate(pybind11)
|
||||||
add_subdirectory(${pybind11_SOURCE_DIR} ${pybind11_BINARY_DIR})
|
add_subdirectory(${pybind11_SOURCE_DIR} ${pybind11_BINARY_DIR})
|
||||||
endif()
|
endif()
|
||||||
|
|
||||||
include(CMakeRC)
|
include(CMakeRC)
|
||||||
|
|
|
@ -61,9 +61,6 @@ struct ObjectPath
|
||||||
objectName = components.back();
|
objectName = components.back();
|
||||||
components.pop_back();
|
components.pop_back();
|
||||||
}
|
}
|
||||||
|
|
||||||
spdlog::debug("ObjectPath: objectName={}, components={}", objectName,
|
|
||||||
fmt::join(components, ", "));
|
|
||||||
}
|
}
|
||||||
};
|
};
|
||||||
|
|
||||||
|
|
|
@ -344,10 +344,6 @@ struct NngPairStrategy: public ProcessingStrategy
|
||||||
}
|
}
|
||||||
|
|
||||||
report();
|
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
|
void run(ListfileContext &listfileContext, ParserContext &parserContext) override
|
||||||
|
@ -366,6 +362,11 @@ struct NngPairStrategy: public ProcessingStrategy
|
||||||
|
|
||||||
if (producerThread.joinable())
|
if (producerThread.joinable())
|
||||||
producerThread.join();
|
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);
|
||||||
}
|
}
|
||||||
};
|
};
|
||||||
|
|
||||||
|
|
Loading…
Reference in a new issue