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

WIP

parent fc670f6b

src/scord/internal_types.cpp

+35 −0
Original line number Diff line number Diff line
@@ -131,4 +131,39 @@ pfs_storage_metadata::update(scord::pfs_storage::ctx pfs_context) { 
    m_pfs_storage.update(std::move(pfs_context));

}





transfer_info::transfer_info(scord::transfer transfer, float qos,

                             std::string contact_point, float obtained_bw)

    : m_transfer(transfer), m_qos(qos),

      m_contact_point(std::move(contact_point)), m_obtained_bw(obtained_bw) {}



void

transfer_info::update(float obtained_bw) {

    m_obtained_bw = obtained_bw;

}



scord::transfer

transfer_info::transfer() const {

    return m_transfer;

}



std::string const&

transfer_info::contact_point() const {

    return m_contact_point;

}



float

transfer_info::qos() const {

    return m_qos;

}



float

transfer_info::obtained_bw() const {

    return m_obtained_bw;

}



void

transfer_info::obtained_bw(float const obtained_bw) {

    m_obtained_bw = obtained_bw;

}

} // namespace scord::internal

src/scord/transfer_manager.hpp

+1 −1
Original line number Diff line number Diff line
@@ -49,7 +49,7 @@ struct transfer_manager { 


        abt::unique_lock lock(m_transfer_mutex);



        if(const auto it = m_transfer.find(id); it == m_transfer.end()) {

        if(const auto it = m_transfer.find(tx_id); it == m_transfer.end()) {

            const auto& [it_transfer, inserted] = m_transfer.emplace(

                    id, std::make_shared<

                                internal::transfer_metadata<TransferHandle>>(