parsec/runtime_locking_shard/messages.hpp

Go to the documentation of this file.

// Copyright (c) 2021 MIT Digital Currency Initiative,
//                    Federal Reserve Bank of Boston
// Distributed under the MIT software license, see the accompanying
// file COPYING or http://www.opensource.org/licenses/mit-license.php.
 
#ifndef OPENCBDC_TX_SRC_PARSEC_RUNTIME_LOCKING_SHARD_MESSAGES_H_
#define OPENCBDC_TX_SRC_PARSEC_RUNTIME_LOCKING_SHARD_MESSAGES_H_
 
#include "interface.hpp"
#include "replicated_shard_interface.hpp"
 
namespace cbdc::parsec::runtime_locking_shard::rpc {
    struct try_lock_request {
        ticket_number_type m_ticket_number{};
        broker_id_type m_broker_id{};
        key_type m_key;
        lock_type m_locktype{};
        bool m_first_lock{false};
    };
 
    struct prepare_request {
        ticket_number_type m_ticket_number;
        state_update_type m_state_updates;
        broker_id_type m_broker_id{};
    };
 
    struct commit_request {
        ticket_number_type m_ticket_number;
    };
 
    struct rollback_request {
        ticket_number_type m_ticket_number;
    };
 
    struct finish_request {
        ticket_number_type m_ticket_number;
    };
 
    struct get_tickets_request {
        broker_id_type m_broker_id;
    };
 
    using request = std::variant<try_lock_request,
                                 prepare_request,
                                 commit_request,
                                 rollback_request,
                                 finish_request,
                                 get_tickets_request>;
    using response = std::variant<interface::try_lock_return_type,
                                  interface::prepare_return_type,
                                  interface::get_tickets_return_type>;
 
    struct replicated_prepare_request {
        ticket_number_type m_ticket_number{};
        broker_id_type m_broker_id{};
        replicated_shard_interface::state_type m_state_update;
    };
 
    struct replicated_get_tickets_request {};
 
    using replicated_request = std::variant<replicated_prepare_request,
                                            commit_request,
                                            finish_request,
                                            replicated_get_tickets_request>;
 
    using replicated_response
        = std::variant<replicated_shard_interface::return_type,
                       replicated_shard_interface::get_tickets_return_type>;
}
 
#endif