Unverified Commit eb706bf2 authored by Tommaso Tocci's avatar Tommaso Tocci
Browse files

better logging on read/write operation

parent 2cce98dd

src/client/rpc/ld_rpc_data_ws.cpp

+2 −0
Original line number Diff line number Diff line
@@ -97,6 +97,8 @@ ssize_t write(const string& path, const void* buf, const bool append_flag, const 
        rpc_in[i].bulk_handle = rpc_bulk_handle;

        margo_create_wrap_helper(rpc_write_data_id, target, rpc_handles[i]);

        // Send RPC

        CTX->log()->trace("{}() host: {}, path: {}, chunks: {}, size: {}, offset: {}", __func__,

                           target, path, rpc_in[i].chunk_n, total_chunk_size, rpc_in[i].offset);

        ret = margo_iforward(rpc_handles[i], &rpc_in[i], &rpc_waiters[i]);

        if (ret != HG_SUCCESS) {

            CTX->log()->error("{}() Unable to send non-blocking rpc for path {} and recipient {}", __func__, path,

src/daemon/handler/h_data.cpp

+4 −6
Original line number Diff line number Diff line
@@ -139,9 +139,8 @@ static hg_return_t rpc_srv_write_data(hg_handle_t handle) { 
    auto hgi = margo_get_info(handle);

    auto mid = margo_hg_info_get_instance(hgi);

    auto bulk_size = margo_bulk_get_size(in.bulk_handle);

    ADAFS_DATA->spdlogger()->debug("{}() Got write RPC (local {}) with path {} size {} offset {}", __func__,

                                   (margo_get_info(handle)->context_id == ADAFS_DATA->host_id()), in.path, bulk_size,

                                   in.offset);

    ADAFS_DATA->spdlogger()->debug("{}() host: {}, path: {}, size: {}, offset: {}", __func__,

                                   hgi->context_id, in.path, bulk_size, in.offset);

    /*

     * 2. Set up buffers for pull bulk transfers

     */
@@ -332,9 +331,8 @@ static hg_return_t rpc_srv_read_data(hg_handle_t handle) { 
    auto hgi = margo_get_info(handle);

    auto mid = margo_hg_info_get_instance(hgi);

    auto bulk_size = margo_bulk_get_size(in.bulk_handle);

    ADAFS_DATA->spdlogger()->debug("{}() Got read RPC (local {}) with path {} size {} offset {}", __func__,

                                   (margo_get_info(handle)->context_id == ADAFS_DATA->host_id()), in.path, bulk_size,

                                   in.offset);

    ADAFS_DATA->spdlogger()->debug("{}() host: {}, path: {}, size: {}, offset: {}", __func__,

                                   hgi->context_id, in.path, bulk_size, in.offset);



    /*

     * 2. Set up buffers for pull bulk transfers