Loading ifs/src/daemon/adafs_daemon.cpp +1 −1 Original line number Diff line number Diff line Loading @@ -130,8 +130,8 @@ void destroy_enviroment() { } bool init_io_tasklet_pool() { assert(DAEMON_IO_XSTREAMS >= 0); unsigned int xstreams_num = DAEMON_IO_XSTREAMS; assert(xstreams_num >= 0); //retrieve the pool of the just created scheduler ABT_pool pool; Loading ifs/src/daemon/handler/h_data.cpp +0 −1 Original line number Diff line number Diff line Loading @@ -436,7 +436,6 @@ static hg_return_t rpc_srv_read_data(hg_handle_t handle) { ABT_eventual_wait(task_eventuals[chnk_id_curr], (void**) &task_read_size); assert(task_read_size != nullptr); assert(*task_read_size >= 0); if(*task_read_size == 0){ ADAFS_DATA->spdlogger()->warn("{}() Read task for chunk {} returned 0 bytes", __func__, chnk_id_curr); Loading Loading
ifs/src/daemon/adafs_daemon.cpp +1 −1 Original line number Diff line number Diff line Loading @@ -130,8 +130,8 @@ void destroy_enviroment() { } bool init_io_tasklet_pool() { assert(DAEMON_IO_XSTREAMS >= 0); unsigned int xstreams_num = DAEMON_IO_XSTREAMS; assert(xstreams_num >= 0); //retrieve the pool of the just created scheduler ABT_pool pool; Loading
ifs/src/daemon/handler/h_data.cpp +0 −1 Original line number Diff line number Diff line Loading @@ -436,7 +436,6 @@ static hg_return_t rpc_srv_read_data(hg_handle_t handle) { ABT_eventual_wait(task_eventuals[chnk_id_curr], (void**) &task_read_size); assert(task_read_size != nullptr); assert(*task_read_size >= 0); if(*task_read_size == 0){ ADAFS_DATA->spdlogger()->warn("{}() Read task for chunk {} returned 0 bytes", __func__, chnk_id_curr); Loading