[ 7104] Add replica_truncate API

The replica_truncate API is meant to act as a replacement for rcDataObjTruncate. The interface is very similar to rcDataObjTruncate, but the result is different. The API only targets one replica to be truncated, and will trigger fileModified as if the file had been modified via an open/write/close.
alanking · Mar 8, 2024 · 5247888 · 5247888
1 parent 39c113f
commit 5247888
Show file tree

Hide file tree

Showing 12 changed files with 356 additions and 1 deletion.
diff --git a/lib/api/CMakeLists.txt b/lib/api/CMakeLists.txt
@@ -147,6 +147,7 @@ foreach(variant IN ITEMS client server)
     "${CMAKE_CURRENT_SOURCE_DIR}/src/rc_register_physical_path.cpp"
     "${CMAKE_CURRENT_SOURCE_DIR}/src/rc_replica_close.cpp"
     "${CMAKE_CURRENT_SOURCE_DIR}/src/rc_replica_open.cpp"
+    "${CMAKE_CURRENT_SOURCE_DIR}/src/rc_replica_truncate.cpp"
     "${CMAKE_CURRENT_SOURCE_DIR}/src/rc_set_delay_server_migration_info.cpp"
     "${CMAKE_CURRENT_SOURCE_DIR}/src/rc_set_grid_configuration_value.cpp"
     "${CMAKE_CURRENT_SOURCE_DIR}/src/rc_switch_user.cpp"
@@ -314,6 +315,7 @@ install(
   "${CMAKE_CURRENT_SOURCE_DIR}/include/irods/register_physical_path.h"
   "${CMAKE_CURRENT_SOURCE_DIR}/include/irods/replica_close.h"
   "${CMAKE_CURRENT_SOURCE_DIR}/include/irods/replica_open.h"
+  "${CMAKE_CURRENT_SOURCE_DIR}/include/irods/replica_truncate.h"
   "${CMAKE_CURRENT_SOURCE_DIR}/include/irods/rmColl.h"
   "${CMAKE_CURRENT_SOURCE_DIR}/include/irods/ruleExecDel.h"
   "${CMAKE_CURRENT_SOURCE_DIR}/include/irods/ruleExecMod.h"

diff --git a/lib/api/include/irods/apiNumberData.h b/lib/api/include/irods/apiNumberData.h
@@ -145,6 +145,7 @@ API_NUMBER(GET_LIMITED_PASSWORD_AN,                 726)
 
 API_NUMBER(CHECK_AUTH_CREDENTIALS_AN,               800)
 API_NUMBER(GET_LIBRARY_FEATURES_AN,                 801)
+API_NUMBER(REPLICA_TRUNCATE_AN,                     802)
 
 /* 1100 - 1200 - SSL API calls */
 API_NUMBER(SSL_START_AN,                            1100)

diff --git a/lib/api/include/irods/apiTable.hpp b/lib/api/include/irods/apiTable.hpp
@@ -153,6 +153,7 @@
 #  include "irods/rs_check_auth_credentials.hpp"
 #  include "irods/rs_get_library_features.hpp"
 #  include "irods/rs_get_resource_info_for_operation.hpp"
+#  include "irods/rs_replica_truncate.hpp"
 #  define NULLPTR_FOR_CLIENT_TABLE(x) x
 #elif !defined(CREATE_API_TABLE_FOR_SERVER) && defined(CREATE_API_TABLE_FOR_CLIENT)
 #  define NULLPTR_FOR_CLIENT_TABLE(x) nullptr
@@ -264,6 +265,7 @@
 #define RS_REG_COLL                        NULLPTR_FOR_CLIENT_TABLE(rsRegColl)
 #define RS_REG_DATA_OBJ                    NULLPTR_FOR_CLIENT_TABLE(rsRegDataObj)
 #define RS_REG_REPLICA                     NULLPTR_FOR_CLIENT_TABLE(rsRegReplica)
+#define RS_REPLICA_TRUNCATE                NULLPTR_FOR_CLIENT_TABLE(rs_replica_truncate)
 #define RS_RM_COLL                         NULLPTR_FOR_CLIENT_TABLE(rsRmColl)
 #define RS_RULE_EXEC_DEL                   NULLPTR_FOR_CLIENT_TABLE(rsRuleExecDel)
 #define RS_RULE_EXEC_MOD                   NULLPTR_FOR_CLIENT_TABLE(rsRuleExecMod)
@@ -1276,6 +1278,12 @@ static irods::apidef_t client_api_table_inp[] = {
         boost::any(std::function<int(rsComm_t*,dataObjInp_t*,char**)>(RS_GET_RESOURCE_INFO_FOR_OPERATION)),
         "api_get_resource_info_for_operation", clearDataObjInp, irods::clearOutStruct_noop,
         (funcPtr)CALL_GET_RESOURCE_INFO_FOR_OPERATION
+    },
+    {   REPLICA_TRUNCATE_AN, RODS_API_VERSION, REMOTE_USER_AUTH, REMOTE_USER_AUTH,
+        "DataObjInp_PI", 0, NULL, 0,
+        boost::any(std::function<int(rsComm_t*, dataObjInp_t*)>(RS_REPLICA_TRUNCATE)),
+        "api_replica_truncate", clearDataObjInp, irods::clearOutStruct_noop,
+        (funcPtr)CALL_REPLICA_TRUNCATE
     }
     // clang-format on
 }; // _api_table_inp

diff --git a/lib/api/include/irods/replica_truncate.h b/lib/api/include/irods/replica_truncate.h
@@ -0,0 +1,40 @@
+#ifndef IRODS_REPLICA_TRUNCATE_H
+#define IRODS_REPLICA_TRUNCATE_H
+
+struct RcComm;
+struct DataObjInp;
+
+#ifdef __cplusplus
+extern "C" {
+#endif
+
+/// Truncate a replica for the specified data object to the specified size.
+///
+/// \parblock
+/// This API selects a replica to truncate according to the rules of POSIX truncate(2). The caller may provide keywords
+/// via condInput in order to influence the hierarchy resolution for selecting a replica to truncate.
+/// \endparblock
+///
+/// \param[in] _comm A pointer to a RcComm.
+/// \param[in] _inp \parblock
+/// DataObjInp structure which requires the following inputs:
+///		objPath - The full logical path to the target data object.
+///		dataSize - The desired size of the replica after truncating.
+///
+/// The condInput supports the following keywords for hierarchy resolution for a "write" operation:
+///		replNum - The replica number of the replica to truncate.
+///		rescName / destRescName - The name of the resource with the replica to truncate. Must be a root resource.
+/// \endparblock
+///
+/// \return An integer representing an iRODS error code, or 0.
+/// \retval 0 on success.
+/// \retval <0 on failure; an iRODS error code.
+///
+/// \since 4.3.2
+int rc_replica_truncate(RcComm* _comm, DataObjInp* _inp);
+
+#ifdef __cplusplus
+} // extern "C"
+#endif
+
+#endif // IRODS_REPLICA_TRUNCATE_H
diff --git a/lib/api/src/rc_replica_truncate.cpp b/lib/api/src/rc_replica_truncate.cpp
@@ -0,0 +1,14 @@
+#include "irods/replica_truncate.h"
+
+#include "irods/apiNumber.h"
+#include "irods/procApiRequest.h"
+#include "irods/rodsErrorTable.h"
+
+auto rc_replica_truncate(RcComm* _comm, DataObjInp* _inp) -> int
+{
+    if (!_comm || !_inp) {
+        return SYS_INVALID_INPUT_PARAM;
+    }
+
+    return procApiRequest(_comm, REPLICA_TRUNCATE_AN, _inp, nullptr, nullptr, nullptr);
+} // rc_replica_truncate
diff --git a/lib/core/include/irods/library_features.h b/lib/core/include/irods/library_features.h
@@ -49,4 +49,9 @@
 /// \since 4.3.1
 #define IRODS_HAS_API_ENDPOINT_CHECK_AUTH_CREDENTIALS                        202307L
 
+/// Defined if the development library supports #rc_replica_truncate.
+///
+/// \since 4.3.2
+#define IRODS_HAS_API_ENDPOINT_REPLICA_TRUNCATE                              202403L
+
 #endif // IRODS_LIBRARY_FEATURES_H
diff --git a/server/api/CMakeLists.txt b/server/api/CMakeLists.txt
@@ -13,6 +13,7 @@ add_library(
   "${CMAKE_CURRENT_SOURCE_DIR}/src/rs_register_physical_path.cpp"
   "${CMAKE_CURRENT_SOURCE_DIR}/src/rs_replica_close.cpp"
   "${CMAKE_CURRENT_SOURCE_DIR}/src/rs_replica_open.cpp"
+  "${CMAKE_CURRENT_SOURCE_DIR}/src/rs_replica_truncate.cpp"
   "${CMAKE_CURRENT_SOURCE_DIR}/src/rs_set_delay_server_migration_info.cpp"
   "${CMAKE_CURRENT_SOURCE_DIR}/src/rs_set_grid_configuration_value.cpp"
   "${CMAKE_CURRENT_SOURCE_DIR}/src/rs_touch.cpp"
@@ -211,8 +212,9 @@ install(
   "${CMAKE_CURRENT_SOURCE_DIR}/include/irods/rs_get_library_features.hpp"
   "${CMAKE_CURRENT_SOURCE_DIR}/include/irods/rs_get_resource_info_for_operation.hpp"
   "${CMAKE_CURRENT_SOURCE_DIR}/include/irods/rs_register_physical_path.hpp"
-  "${CMAKE_CURRENT_SOURCE_DIR}/include/irods/rs_replica_open.hpp"
   "${CMAKE_CURRENT_SOURCE_DIR}/include/irods/rs_replica_close.hpp"
+  "${CMAKE_CURRENT_SOURCE_DIR}/include/irods/rs_replica_open.hpp"
+  "${CMAKE_CURRENT_SOURCE_DIR}/include/irods/rs_replica_truncate.hpp"
   "${CMAKE_CURRENT_SOURCE_DIR}/include/irods/rs_set_delay_server_migration_info.hpp"
   "${CMAKE_CURRENT_SOURCE_DIR}/include/irods/rs_set_grid_configuration_value.hpp"
   "${CMAKE_CURRENT_SOURCE_DIR}/include/irods/rs_touch.hpp"

diff --git a/server/api/include/irods/rs_replica_truncate.hpp b/server/api/include/irods/rs_replica_truncate.hpp
@@ -0,0 +1,40 @@
+#ifndef IRODS_RS_REPLICA_TRUNCATE_HPP
+#define IRODS_RS_REPLICA_TRUNCATE_HPP
+
+struct RsComm;
+struct DataObjInp;
+
+#ifdef __cplusplus
+extern "C" {
+#endif
+
+/// Truncate a replica for the specified data object to the specified size.
+///
+/// \parblock
+/// This API selects a replica to truncate according to the rules of POSIX truncate(2). The caller may provide keywords
+/// via condInput in order to influence the hierarchy resolution for selecting a replica to truncate.
+/// \endparblock
+///
+/// \param[in] _comm A pointer to a RsComm.
+/// \param[in] _inp \parblock
+/// DataObjInp structure which requires the following inputs:
+///		objPath - The full logical path to the target data object.
+///		dataSize - The desired size of the replica after truncating. Follows the rules of POSIX truncate(2).
+///
+/// The condInput supports the following keywords for hierarchy resolution for a "write" operation:
+///		replNum - The replica number of the replica to truncate.
+///		rescName / destRescName - The name of the resource with the replica to truncate. Must be a root resource.
+/// \endparblock
+///
+/// \return An integer representing an iRODS error code, or 0.
+/// \retval 0 on success.
+/// \retval <0 on failure; an iRODS error code.
+///
+/// \since 4.3.2
+int rs_replica_truncate(RsComm* _comm, DataObjInp* _inp);
+
+#ifdef __cplusplus
+} // extern "C"
+#endif
+
+#endif // IRODS_RS_REPLICA_TRUNCATE_HPP
diff --git a/server/api/src/rs_get_library_features.cpp b/server/api/src/rs_get_library_features.cpp
@@ -27,6 +27,7 @@ auto rs_get_library_features(RsComm* _comm, char** _features) -> int
         IRODS_FEATURE(IRODS_HAS_LIBRARY_SYSTEM_ERROR)
         IRODS_FEATURE(IRODS_HAS_FEATURE_PROXY_USER_SUPPORT_FOR_CLIENT_CONNECTION_LIBRARIES)
         IRODS_FEATURE(IRODS_HAS_API_ENDPOINT_CHECK_AUTH_CREDENTIALS)
+        IRODS_FEATURE(IRODS_HAS_API_ENDPOINT_REPLICA_TRUNCATE)
     }.dump().c_str());
     // clang-format on