X-Git-Url: https://gerrit.opnfv.org/gerrit/gitweb?a=blobdiff_plain;f=src%2Fceph%2Fsrc%2Frgw%2Frgw_log.h;fp=src%2Fceph%2Fsrc%2Frgw%2Frgw_log.h;h=0000000000000000000000000000000000000000;hb=7da45d65be36d36b880cc55c5036e96c24b53f00;hp=25e99e096dee3d7a3f1d2a3a72d8bccb4acb7af1;hpb=691462d09d0987b47e112d6ee8740375df3c51b2;p=stor4nfv.git

diff --git a/src/ceph/src/rgw/rgw_log.h b/src/ceph/src/rgw/rgw_log.h
deleted file mode 100644
index 25e99e0..0000000
--- a/src/ceph/src/rgw/rgw_log.h
+++ /dev/null
@@ -1,144 +0,0 @@
-// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
-// vim: ts=8 sw=2 smarttab
-
-#ifndef CEPH_RGW_LOG_H
-#define CEPH_RGW_LOG_H
-#include <boost/container/flat_map.hpp>
-#include "rgw_common.h"
-#include "include/utime.h"
-#include "common/Formatter.h"
-#include "common/OutputDataSocket.h"
-
-class RGWRados;
-
-struct rgw_log_entry {
-
-  using headers_map = boost::container::flat_map<std::string, std::string>;
-
-  rgw_user object_owner;
-  rgw_user bucket_owner;
-  string bucket;
-  utime_t time;
-  string remote_addr;
-  string user;
-  rgw_obj_key obj;
-  string op;
-  string uri;
-  string http_status;
-  string error_code;
-  uint64_t bytes_sent;
-  uint64_t bytes_received;
-  uint64_t obj_size;
-  utime_t total_time;
-  string user_agent;
-  string referrer;
-  string bucket_id;
-  headers_map x_headers;
-
-  void encode(bufferlist &bl) const {
-    ENCODE_START(9, 5, bl);
-    ::encode(object_owner.id, bl);
-    ::encode(bucket_owner.id, bl);
-    ::encode(bucket, bl);
-    ::encode(time, bl);
-    ::encode(remote_addr, bl);
-    ::encode(user, bl);
-    ::encode(obj.name, bl);
-    ::encode(op, bl);
-    ::encode(uri, bl);
-    ::encode(http_status, bl);
-    ::encode(error_code, bl);
-    ::encode(bytes_sent, bl);
-    ::encode(obj_size, bl);
-    ::encode(total_time, bl);
-    ::encode(user_agent, bl);
-    ::encode(referrer, bl);
-    ::encode(bytes_received, bl);
-    ::encode(bucket_id, bl);
-    ::encode(obj, bl);
-    ::encode(object_owner, bl);
-    ::encode(bucket_owner, bl);
-    ::encode(x_headers, bl);
-    ENCODE_FINISH(bl);
-  }
-  void decode(bufferlist::iterator &p) {
-    DECODE_START_LEGACY_COMPAT_LEN(8, 5, 5, p);
-    ::decode(object_owner.id, p);
-    if (struct_v > 3)
-      ::decode(bucket_owner.id, p);
-    ::decode(bucket, p);
-    ::decode(time, p);
-    ::decode(remote_addr, p);
-    ::decode(user, p);
-    ::decode(obj.name, p);
-    ::decode(op, p);
-    ::decode(uri, p);
-    ::decode(http_status, p);
-    ::decode(error_code, p);
-    ::decode(bytes_sent, p);
-    ::decode(obj_size, p);
-    ::decode(total_time, p);
-    ::decode(user_agent, p);
-    ::decode(referrer, p);
-    if (struct_v >= 2)
-      ::decode(bytes_received, p);
-    else
-      bytes_received = 0;
-
-    if (struct_v >= 3) {
-      if (struct_v <= 5) {
-        uint64_t id;
-        ::decode(id, p);
-        char buf[32];
-        snprintf(buf, sizeof(buf), "%llu", (long long)id);
-        bucket_id = buf;
-      } else {
-        ::decode(bucket_id, p);
-      }
-    } else {
-      bucket_id = "";
-    }
-    if (struct_v >= 7) {
-      ::decode(obj, p);
-    }
-    if (struct_v >= 8) {
-      ::decode(object_owner, p);
-      ::decode(bucket_owner, p);
-    }
-    if (struct_v >= 9) {
-      ::decode(x_headers, p);
-    }
-    DECODE_FINISH(p);
-  }
-  void dump(Formatter *f) const;
-  static void generate_test_instances(list<rgw_log_entry*>& o);
-};
-WRITE_CLASS_ENCODER(rgw_log_entry)
-
-class OpsLogSocket : public OutputDataSocket {
-  Formatter *formatter;
-  Mutex lock;
-
-  void formatter_to_bl(bufferlist& bl);
-
-protected:
-  void init_connection(bufferlist& bl) override;
-
-public:
-  OpsLogSocket(CephContext *cct, uint64_t _backlog);
-  ~OpsLogSocket() override;
-
-  void log(struct rgw_log_entry& entry);
-};
-
-class RGWREST;
-
-int rgw_log_op(RGWRados *store, RGWREST* const rest, struct req_state *s,
-	       const string& op_name, OpsLogSocket *olog);
-void rgw_log_usage_init(CephContext *cct, RGWRados *store);
-void rgw_log_usage_finalize();
-void rgw_format_ops_log_entry(struct rgw_log_entry& entry,
-			      Formatter *formatter);
-
-#endif /* CEPH_RGW_LOG_H */
-