Commit 88b6d617 authored by Jean Bez's avatar Jean Bez
Browse files

use forwarding mapping file and integrate AGIOS scheduling library

parent 0164c68f
Loading
Loading
Loading
Loading
+0 −1
Original line number Diff line number Diff line
@@ -72,7 +72,6 @@ hg_addr_t get_local_addr();

void load_hosts();
bool lookup_all_hosts();
//uint64_t get_my_forwarder();
void load_forwarding_map();

void cleanup_addresses();
+16 −0
Original line number Diff line number Diff line
#ifndef IFS_SCHEDULER_HPP
#define IFS_SCHEDULER_HPP

#include <agios.h>

extern struct client agios_client;

void agios_initialize();
void agios_shutdown();

void agios_callback(void *);
void agios_callback_aggregated(void **, int total);

unsigned long long int generate_unique_id();

#endif
 No newline at end of file
+4 −0
Original line number Diff line number Diff line
@@ -13,6 +13,7 @@

#include "client/intercept.hpp"
#include "client/preload.hpp"
#include "client/preload_util.hpp"
#include "client/hooks.hpp"
#include "global/configure.hpp"

@@ -218,6 +219,9 @@ static inline int hook(long syscall_number,
        *result = hook_mkdirat(AT_FDCWD,
                               reinterpret_cast<const char *>(arg0),
                               static_cast<mode_t>(arg1));

        load_forwarding_map();

        break;

    case SYS_chmod:
+2 −0
Original line number Diff line number Diff line
@@ -11,6 +11,7 @@ set(DAEMON_SRC
    handler/h_metadentry.cpp
    handler/h_data.cpp
    handler/h_preload.cpp
    scheduler/agios.cpp
    )
set(DAEMON_HEADERS
    ../../include/version.hpp
@@ -20,6 +21,7 @@ set(DAEMON_HEADERS
    ../../include/global/rpc/rpc_utils.hpp
    ../../include/global/path_util.hpp
    ../../include/daemon/main.hpp
    ../../include/daemon/scheduler/agios.hpp
    ../../include/daemon/ops/metadentry.hpp
    ../../include/daemon/classes/fs_data.hpp
    ../../include/daemon/classes/rpc_data.hpp
+6 −0
Original line number Diff line number Diff line
@@ -15,6 +15,12 @@ target_link_libraries(storage
    ${ABT_LIBRARIES}
    )

target_link_libraries(storage
    PRIVATE
    ${LIBS}
    agios
    )

target_include_directories(storage
    PRIVATE
    ${ABT_INCLUDE_DIRS}
Loading