Loading src/client/CMakeLists.txt +9 −0 Original line number Diff line number Diff line Loading @@ -210,6 +210,15 @@ target_link_libraries( Threads::Threads Microsoft.GSL::GSL ) # Enable MSGPack metrics for intercept only if (GKFS_ENABLE_CLIENT_METRICS) target_link_libraries( gkfs_libc_intercept PUBLIC msgpack_util ) target_compile_definitions(gkfs_libc_intercept PUBLIC GKFS_ENABLE_CLIENT_METRICS) endif () endif () install( Loading src/client/preload.cpp +11 −0 Original line number Diff line number Diff line Loading @@ -526,12 +526,23 @@ init_libc() { } gkfs::preload::init_environment(); CTX->enable_interception(); if(!CTX->init_metrics()) { exit_error_msg(EXIT_FAILURE, "Unable to initialize client metrics. Exiting..."); } } void destroy_libc() { // printf("%d At close library GEKKOFS\n", gettid()); CTX->disable_interception(); #ifdef GKFS_ENABLE_CLIENT_METRICS LOG(INFO, "Flushing final metrics..."); CTX->write_metrics()->flush_msgpack(); CTX->read_metrics()->flush_msgpack(); LOG(INFO, "Metrics flushed. Total flush operations: {}", CTX->write_metrics()->flush_count()); #endif CTX->clear_hosts(); LOG(DEBUG, "Peer information deleted"); Loading Loading
src/client/CMakeLists.txt +9 −0 Original line number Diff line number Diff line Loading @@ -210,6 +210,15 @@ target_link_libraries( Threads::Threads Microsoft.GSL::GSL ) # Enable MSGPack metrics for intercept only if (GKFS_ENABLE_CLIENT_METRICS) target_link_libraries( gkfs_libc_intercept PUBLIC msgpack_util ) target_compile_definitions(gkfs_libc_intercept PUBLIC GKFS_ENABLE_CLIENT_METRICS) endif () endif () install( Loading
src/client/preload.cpp +11 −0 Original line number Diff line number Diff line Loading @@ -526,12 +526,23 @@ init_libc() { } gkfs::preload::init_environment(); CTX->enable_interception(); if(!CTX->init_metrics()) { exit_error_msg(EXIT_FAILURE, "Unable to initialize client metrics. Exiting..."); } } void destroy_libc() { // printf("%d At close library GEKKOFS\n", gettid()); CTX->disable_interception(); #ifdef GKFS_ENABLE_CLIENT_METRICS LOG(INFO, "Flushing final metrics..."); CTX->write_metrics()->flush_msgpack(); CTX->read_metrics()->flush_msgpack(); LOG(INFO, "Metrics flushed. Total flush operations: {}", CTX->write_metrics()->flush_count()); #endif CTX->clear_hosts(); LOG(DEBUG, "Peer information deleted"); Loading