From 19fcec84d8d7d21e796c7624e521b60d28ee21ed Mon Sep 17 00:00:00 2001 From: Daniel Baumann Date: Sun, 7 Apr 2024 20:45:59 +0200 Subject: Adding upstream version 16.2.11+ds. Signed-off-by: Daniel Baumann --- src/rgw/rgw_kmip_client.h | 67 +++++++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 67 insertions(+) create mode 100644 src/rgw/rgw_kmip_client.h (limited to 'src/rgw/rgw_kmip_client.h') diff --git a/src/rgw/rgw_kmip_client.h b/src/rgw/rgw_kmip_client.h new file mode 100644 index 000000000..efc7db325 --- /dev/null +++ b/src/rgw/rgw_kmip_client.h @@ -0,0 +1,67 @@ +// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*- +// vim: ts=8 sw=2 smarttab ft=cpp + +#ifndef CEPH_RGW_KMIP_CLIENT_H +#define CEPH_RGW_KMIP_CLIENT_H + +class RGWKMIPManager; + +class RGWKMIPTransceiver { +public: + enum kmip_operation { + CREATE, + LOCATE, + GET, + GET_ATTRIBUTES, + GET_ATTRIBUTE_LIST, + DESTROY + }; + CephContext *cct; + kmip_operation operation; + char *name = 0; + char *unique_id = 0; + // output - must free + char *out = 0; // unique_id, several + struct { // unique_ids, locate + char **strings; + int string_count; + } outlist[1] = {{0, 0}}; + struct { // key, get + unsigned char *data; + int keylen; + } outkey[1] = {0, 0}; + // end must free + int ret; + bool done; + ceph::mutex lock = ceph::make_mutex("rgw_kmip_req::lock"); + ceph::condition_variable cond; + + int wait(optional_yield y); + RGWKMIPTransceiver(CephContext * const cct, + kmip_operation operation) + : cct(cct), + operation(operation), + ret(-EDOM), + done(false) + {} + ~RGWKMIPTransceiver(); + + int send(); + int process(optional_yield y); +}; + +class RGWKMIPManager { +protected: + CephContext *cct; + bool is_started = false; + RGWKMIPManager(CephContext *cct) : cct(cct) {}; +public: + virtual ~RGWKMIPManager() { }; + virtual int start() = 0; + virtual void stop() = 0; + virtual int add_request(RGWKMIPTransceiver*) = 0; +}; + +void rgw_kmip_client_init(RGWKMIPManager &); +void rgw_kmip_client_cleanup(); +#endif -- cgit v1.2.3