Commit b9e16540 authored by Marc Vef's avatar Marc Vef
Browse files

ifs: started implementing write ipc

parent 16ea19e6

.gitignore

+2 −0
Original line number Diff line number Diff line
@@ -83,3 +83,5 @@ playground 
ifs/\.hidden_playground/



ifs_test/build/



ifs/build/

ifs/CMakeLists.txt

+2 −1
Original line number Diff line number Diff line
@@ -51,7 +51,8 @@ set(SOURCE_FILES main.cpp main.hpp configure.hpp util.cpp 


        include/rpc/rpc_defs.hpp include/rpc/rpc_types.hpp



        src/daemon/fs_operations.cpp src/daemon/fs_operations.cpp include/daemon/fs_operations.hpp src/adafs_ops/metadentry.cpp

        #src/daemon/fs_operations.cpp include/daemon/fs_operations.hpp

        src/adafs_ops/metadentry.cpp

        include/adafs_ops/metadentry.hpp src/db/db_ops.cpp src/db/db_ops.cpp include/db/db_ops.hpp

        src/rpc/handler/h_metadentry.cpp

        src/adafs_ops/data.cpp include/adafs_ops/data.hpp src/rpc/handler/h_data.cpp

ifs/include/preload/ipc_types.hpp

+18 −0
Original line number Diff line number Diff line
@@ -39,4 +39,22 @@ MERCURY_GEN_PROC(ipc_stat_out_t, ((hg_int32_t) (err)) 


MERCURY_GEN_PROC(ipc_unlink_in_t, ((hg_const_string_t) (path)))



// data

MERCURY_GEN_PROC(ipc_read_data_in_t,

                 ((hg_const_string_t) (path))\

((hg_size_t) (size))\

((int64_t) (offset))\

((hg_bulk_t) (bulk_handle)))



MERCURY_GEN_PROC(ipc_data_out_t,

                 ((int32_t) (res))\

((hg_size_t) (io_size)))



MERCURY_GEN_PROC(ipc_write_data_in_t,

                 ((hg_const_string_t) (path))\

((hg_size_t) (size))\

((int64_t) (offset))\

((hg_bool_t) (append))\

((hg_bulk_t) (bulk_handle)))



#endif //IFS_IPC_TYPES_HPP

ifs/include/preload/margo_ipc.hpp

+3 −0
Original line number Diff line number Diff line
@@ -18,4 +18,7 @@ int ipc_send_stat(const char* path, std::string& attr, const hg_id_t ipc_stat_id 


int ipc_send_unlink(const char* path, const hg_id_t ipc_unlink_id);



int ipc_send_write(const string& path, const size_t in_size, const off_t in_offset,

                   const void* buf, size_t& write_size, const bool append, const hg_id_t ipc_write_id);



#endif //IFS_MARGO_IPC_HPP

ifs/include/rpc/rpc_defs.hpp

+3 −0
Original line number Diff line number Diff line
@@ -36,6 +36,9 @@ DECLARE_MARGO_RPC_HANDLER(ipc_srv_stat) 


DECLARE_MARGO_RPC_HANDLER(ipc_srv_unlink)



DECLARE_MARGO_RPC_HANDLER(ipc_srv_write_data)





/** OLD BELOW

// mdata ops

DECLARE_MARGO_RPC_HANDLER(rpc_srv_create_mdata)