.. _program_listing_file_src_client_malleability.cpp:

Program Listing for File malleability.cpp
=========================================

|exhale_lsh| :ref:`Return to documentation for file <file_src_client_malleability.cpp>` (``src/client/malleability.cpp``)

.. |exhale_lsh| unicode:: U+021B0 .. UPWARDS ARROW WITH TIP LEFTWARDS

.. code-block:: cpp

   /*
     Copyright 2018-2025, Barcelona Supercomputing Center (BSC), Spain
     Copyright 2015-2025, Johannes Gutenberg Universitaet Mainz, Germany
   
     This software was partially supported by the
     EC H2020 funded project NEXTGenIO (Project ID: 671951, www.nextgenio.eu).
   
     This software was partially supported by the
     ADA-FS project under the SPPEXA project funded by the DFG.
   
     This software was partially supported by the
     the European Union’s Horizon 2020 JTI-EuroHPC research and
     innovation programme, by the project ADMIRE (Project ID: 956748,
     admire-eurohpc.eu)
   
     This project was partially promoted by the Ministry for Digital Transformation
     and the Civil Service, within the framework of the Recovery,
     Transformation and Resilience Plan - Funded by the European Union
     -NextGenerationEU.
   
     This file is part of GekkoFS' POSIX interface.
   
     GekkoFS' POSIX interface is free software: you can redistribute it and/or
     modify it under the terms of the GNU Lesser General Public License as
     published by the Free Software Foundation, either version 3 of the License,
     or (at your option) any later version.
   
     GekkoFS' POSIX interface is distributed in the hope that it will be useful,
     but WITHOUT ANY WARRANTY; without even the implied warranty of
     MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
     GNU Lesser General Public License for more details.
   
     You should have received a copy of the GNU Lesser General Public License
     along with GekkoFS' POSIX interface.  If not, see
     <https://www.gnu.org/licenses/>.
   
     SPDX-License-Identifier: LGPL-3.0-or-later
   */
   
   #include <client/user_functions.hpp>
   #include <client/preload.hpp>
   #include <client/rpc/forward_malleability.hpp>
   #include <client/logging.hpp>
   
   #include <iostream>
   
   using namespace std;
   
   namespace gkfs::malleable {
   
   int
   expand_start(int old_server_conf, int new_server_conf) {
       LOG(INFO, "{}() Expand operation enter", __func__);
       // sanity checks
       if(old_server_conf == new_server_conf) {
           auto err_str =
                   "ERR: Old server configuration is the same as the new one";
           cerr << err_str << endl;
           LOG(ERROR, "{}() {}", __func__, err_str);
           return -1;
       }
       if(CTX->hosts().size() != static_cast<uint64_t>(old_server_conf)) {
           auto err_str =
                   "ERR: Old server configuration does not match the number of hosts in hostsfile";
           cerr << err_str << endl;
           LOG(ERROR, "{}() {}", __func__, err_str);
           return -1;
       }
       // TODO check that hostsfile contains endmarker
       return gkfs::malleable::rpc::forward_expand_start(old_server_conf,
                                                         new_server_conf);
   }
   
   int
   expand_status() {
       LOG(INFO, "{}() enter", __func__);
       auto res = gkfs::malleable::rpc::forward_expand_status();
       LOG(INFO, "{}() '{}' nodes working on extend operation.", __func__, res);
       return res;
   }
   
   int
   expand_finalize() {
       LOG(INFO, "{}() enter", __func__);
       auto res = gkfs::malleable::rpc::forward_expand_finalize();
       LOG(INFO, "{}() extend operation finalized. ", __func__);
       return res;
   }
   
   } // namespace gkfs::malleable