Line data Source code
1 : /* 2 : Copyright 2018-2024, Barcelona Supercomputing Center (BSC), Spain 3 : Copyright 2015-2024, Johannes Gutenberg Universitaet Mainz, Germany 4 : 5 : This software was partially supported by the 6 : EC H2020 funded project NEXTGenIO (Project ID: 671951, www.nextgenio.eu). 7 : 8 : This software was partially supported by the 9 : ADA-FS project under the SPPEXA project funded by the DFG. 10 : 11 : This file is part of GekkoFS. 12 : 13 : GekkoFS is free software: you can redistribute it and/or modify 14 : it under the terms of the GNU General Public License as published by 15 : the Free Software Foundation, either version 3 of the License, or 16 : (at your option) any later version. 17 : 18 : GekkoFS is distributed in the hope that it will be useful, 19 : but WITHOUT ANY WARRANTY; without even the implied warranty of 20 : MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the 21 : GNU General Public License for more details. 22 : 23 : You should have received a copy of the GNU General Public License 24 : along with GekkoFS. If not, see <https://www.gnu.org/licenses/>. 25 : 26 : SPDX-License-Identifier: GPL-3.0-or-later 27 : */ 28 : 29 : #include <daemon/classes/rpc_data.hpp> 30 : 31 : using namespace std; 32 : 33 : namespace gkfs { 34 : 35 : namespace daemon { 36 : 37 : // Getter/Setter 38 : 39 : margo_instance* 40 66 : RPCData::server_rpc_mid() { 41 66 : return server_rpc_mid_; 42 : } 43 : 44 : void 45 33 : RPCData::server_rpc_mid(margo_instance* server_rpc_mid) { 46 33 : RPCData::server_rpc_mid_ = server_rpc_mid; 47 33 : } 48 : 49 : ABT_pool 50 176 : RPCData::io_pool() const { 51 176 : return io_pool_; 52 : } 53 : 54 : void 55 33 : RPCData::io_pool(ABT_pool io_pool) { 56 33 : RPCData::io_pool_ = io_pool; 57 33 : } 58 : 59 : vector<ABT_xstream>& 60 825 : RPCData::io_streams() { 61 825 : return io_streams_; 62 : } 63 : 64 : void 65 33 : RPCData::io_streams(const vector<ABT_xstream>& io_streams) { 66 33 : RPCData::io_streams_ = io_streams; 67 33 : } 68 : 69 : const std::string& 70 33 : RPCData::self_addr_str() const { 71 33 : return self_addr_str_; 72 : } 73 : 74 : void 75 33 : RPCData::self_addr_str(const std::string& addr_str) { 76 33 : self_addr_str_ = addr_str; 77 33 : } 78 : 79 : const std::shared_ptr<gkfs::rpc::Distributor>& 80 0 : RPCData::distributor() const { 81 0 : return distributor_; 82 : } 83 : 84 : void 85 0 : RPCData::distributor( 86 : const std::shared_ptr<gkfs::rpc::Distributor>& distributor) { 87 0 : distributor_ = distributor; 88 0 : } 89 : 90 : 91 : } // namespace daemon 92 : } // namespace gkfs