Commit bc712175 authored by Ramon Nou's avatar Ramon Nou
Browse files

Arithmetic bug in the worker

parent 83748e29

lib/libcargo.cpp

+3 −3
Original line number Diff line number Diff line
@@ -22,9 +22,9 @@ 
 * SPDX-License-Identifier: GPL-3.0-or-later

 *****************************************************************************/



#include <cargo.hpp>

#include <fmt_formatters.hpp>

#include <net/serialization.hpp>

#include "cargo.hpp"

#include "fmt_formatters.hpp"

#include "net/serialization.hpp"

#include <iomanip>

#include <logger/logger.hpp>

#include <net/client.hpp>

src/worker/worker.cpp

+1 −1
Original line number Diff line number Diff line
@@ -194,7 +194,7 @@ worker::run() { 
                    if(size <= m_block_size * 1024) {

                        // Optimize and process only to one worker

                        // the one that is processing is i%worker == 0

                        if(i % (world.rank() - 1) == 0) {

                        if(((i%workers.size()) == (unsigned int)workers.rank())) {

                            update_state(msg->source(), m.tid(), i, output_path,

                                     transfer_state::pending, -1.0f);