librgw_la_LIBADD = librados.la
librgw_la_LDFLAGS = -version-info 1:0:0 $(PTHREAD_LIBS) -lm $(CRYPTO_LIBS) $(EXTRALIBS) -lexpat -lcurl
lib_LTLIBRARIES += librgw.la
+
endif
# librbd
rgw_multiparser_CXXFLAGS = ${CRYPTO_CXXFLAGS} ${AM_CXXFLAGS}
rgw_multiparser_LDADD = $(my_radosgw_ldadd)
bin_DEBUGPROGRAMS += rgw_multiparser
+
+ceph_dencoder_LDADD += $(my_radosgw_ldadd)
+
endif
testcrypto_SOURCES = testcrypto.cc
static RGWFS fs_provider;
static RGWRados rados_provider;
+void RGWObjManifestPart::generate_test_instances(std::list<RGWObjManifestPart*>& o)
+{
+ o.push_back(new RGWObjManifestPart);
+}
+
+void RGWObjManifestPart::dump(Formatter *f) const
+{
+}
+
+void RGWObjManifest::generate_test_instances(std::list<RGWObjManifest*>& o)
+{
+ o.push_back(new RGWObjManifest);
+}
+
+void RGWObjManifest::dump(Formatter *f) const
+{
+}
+
RGWAccess* RGWAccess::store;
RGWAccess::~RGWAccess()
#include <vector>
#include <include/types.h>
+#include "common/Formatter.h"
#include "rgw_common.h"
struct md_config_t;
::decode(size, bl);
DECODE_FINISH(bl);
}
+
+ void dump(Formatter *f) const;
+ static void generate_test_instances(list<RGWObjManifestPart*>& o);
};
WRITE_CLASS_ENCODER(RGWObjManifestPart);
::decode(objs, bl);
DECODE_FINISH(bl);
}
+
+ void dump(Formatter *f) const;
+ static void generate_test_instances(list<RGWObjManifest*>& o);
};
WRITE_CLASS_ENCODER(RGWObjManifest);
using namespace std;
+void ACLPermission::generate_test_instances(list<ACLPermission*>& o)
+{
+ o.push_back(new ACLPermission);
+}
+
+void ACLPermission::dump(Formatter *f) const
+{
+}
+
+void ACLGranteeType::generate_test_instances(list<ACLGranteeType*>& o)
+{
+ o.push_back(new ACLGranteeType);
+}
+
+void ACLGranteeType::dump(Formatter *f) const
+{
+}
+
+void ACLGrant::generate_test_instances(list<ACLGrant*>& o)
+{
+ o.push_back(new ACLGrant);
+}
+
+void ACLGrant::dump(Formatter *f) const
+{
+}
+
+void RGWAccessControlList::generate_test_instances(list<RGWAccessControlList*>& o)
+{
+ o.push_back(new RGWAccessControlList);
+}
+
+void RGWAccessControlList::dump(Formatter *f) const
+{
+}
+
+void ACLOwner::generate_test_instances(list<ACLOwner*>& o)
+{
+ o.push_back(new ACLOwner);
+}
+
+void ACLOwner::dump(Formatter *f) const
+{
+}
+
+void RGWAccessControlPolicy::generate_test_instances(list<RGWAccessControlPolicy*>& o)
+{
+ o.push_back(new RGWAccessControlPolicy);
+}
+
+
+void RGWAccessControlPolicy::dump(Formatter *f) const
+{
+}
+
void RGWAccessControlList::_add_grant(ACLGrant *grant)
{
ACLPermission& perm = grant->get_permission();
::decode(flags, bl);
DECODE_FINISH(bl);
}
+ void dump(Formatter *f) const;
+ static void generate_test_instances(list<ACLPermission*>& o);
};
WRITE_CLASS_ENCODER(ACLPermission)
::decode(type, bl);
DECODE_FINISH(bl);
}
+ void dump(Formatter *f) const;
+ static void generate_test_instances(list<ACLGranteeType*>& o);
};
WRITE_CLASS_ENCODER(ACLGranteeType)
}
DECODE_FINISH(bl);
}
+ void dump(Formatter *f) const;
+ static void generate_test_instances(list<ACLGrant*>& o);
ACLGroupTypeEnum uri_to_group(string& uri);
}
DECODE_FINISH(bl);
}
+ void dump(Formatter *f) const;
+ static void generate_test_instances(list<RGWAccessControlList*>& o);
+
void add_grant(ACLGrant *grant);
multimap<string, ACLGrant>& get_grant_map() { return grant_map; }
::decode(display_name, bl);
DECODE_FINISH(bl);
}
+ void dump(Formatter *f) const;
+ static void generate_test_instances(list<ACLOwner*>& o);
void set_id(string& _id) { id = _id; }
void set_name(string& name) { display_name = name; }
::decode(owner, bl);
::decode(acl, bl);
DECODE_FINISH(bl);
- }
+ }
+ void dump(Formatter *f) const;
+ static void generate_test_instances(list<RGWAccessControlPolicy*>& o);
void decode_owner(bufferlist::iterator& bl) { // sometimes we only need that, should be faster
DECODE_START_LEGACY_COMPAT_LEN(2, 2, 2, bl);
::decode(owner, bl);
using namespace std;
+void ObjectMetaInfo::generate_test_instances(list<ObjectMetaInfo*>& o)
+{
+ o.push_back(new ObjectMetaInfo);
+}
+
+void ObjectMetaInfo::dump(Formatter *f) const
+{
+}
+
+void ObjectCacheInfo::generate_test_instances(list<ObjectCacheInfo*>& o)
+{
+ o.push_back(new ObjectCacheInfo);
+}
+
+void ObjectCacheInfo::dump(Formatter *f) const
+{
+}
+
+void RGWCacheNotifyInfo::generate_test_instances(list<RGWCacheNotifyInfo*>& o)
+{
+ o.push_back(new RGWCacheNotifyInfo);
+}
+
+void RGWCacheNotifyInfo::dump(Formatter *f) const
+{
+}
+
int ObjectCache::get(string& name, ObjectCacheInfo& info, uint32_t mask)
{
Mutex::Locker l(lock);
mtime = t.sec();
DECODE_FINISH(bl);
}
+ void dump(Formatter *f) const;
+ static void generate_test_instances(list<ObjectMetaInfo*>& o);
};
WRITE_CLASS_ENCODER(ObjectMetaInfo)
::decode(rm_xattrs, bl);
DECODE_FINISH(bl);
}
+ void dump(Formatter *f) const;
+ static void generate_test_instances(list<ObjectCacheInfo*>& o);
};
WRITE_CLASS_ENCODER(ObjectCacheInfo)
::decode(ns, ibl);
DECODE_FINISH(ibl);
}
+ void dump(Formatter *f) const;
+ static void generate_test_instances(list<RGWCacheNotifyInfo*>& o);
};
WRITE_CLASS_ENCODER(RGWCacheNotifyInfo)
#include "include/types.h"
#include "include/utime.h"
+#include "common/Formatter.h"
+
#define CEPH_RGW_REMOVE 'r'
#define CEPH_RGW_UPDATE 'u'
::decode(op, bl);
DECODE_FINISH(bl);
}
+ void dump(Formatter *f) const;
+ static void generate_test_instances(list<rgw_bucket_pending_info*>& o);
};
WRITE_CLASS_ENCODER(rgw_bucket_pending_info)
::decode(content_type, bl);
DECODE_FINISH(bl);
}
+ void dump(Formatter *f) const;
+ static void generate_test_instances(list<rgw_bucket_dir_entry_meta*>& o);
};
WRITE_CLASS_ENCODER(rgw_bucket_dir_entry_meta)
}
DECODE_FINISH(bl);
}
+ void dump(Formatter *f) const;
+ static void generate_test_instances(list<rgw_bucket_dir_entry*>& o);
};
WRITE_CLASS_ENCODER(rgw_bucket_dir_entry)
::decode(num_entries, bl);
DECODE_FINISH(bl);
}
+ void dump(Formatter *f) const;
+ static void generate_test_instances(list<rgw_bucket_category_stats*>& o);
};
WRITE_CLASS_ENCODER(rgw_bucket_category_stats)
::decode(stats, bl);
DECODE_FINISH(bl);
}
+ void dump(Formatter *f) const;
+ static void generate_test_instances(list<rgw_bucket_dir_header*>& o);
};
WRITE_CLASS_ENCODER(rgw_bucket_dir_header)
::decode(m, bl);
DECODE_FINISH(bl);
}
+ void dump(Formatter *f) const;
+ static void generate_test_instances(list<rgw_bucket_dir*>& o);
};
WRITE_CLASS_ENCODER(rgw_bucket_dir)
}
DECODE_FINISH(bl);
}
+ void dump(Formatter *f) const;
+ static void generate_test_instances(list<rgw_cls_obj_prepare_op*>& o);
};
WRITE_CLASS_ENCODER(rgw_cls_obj_prepare_op)
}
DECODE_FINISH(bl);
}
+ void dump(Formatter *f) const;
+ static void generate_test_instances(list<rgw_cls_obj_complete_op*>& o);
};
WRITE_CLASS_ENCODER(rgw_cls_obj_complete_op)
::decode(num_entries, bl);
DECODE_FINISH(bl);
}
+ void dump(Formatter *f) const;
+ static void generate_test_instances(list<rgw_cls_list_op*>& o);
};
WRITE_CLASS_ENCODER(rgw_cls_list_op)
::decode(is_truncated, bl);
DECODE_FINISH(bl);
}
+ void dump(Formatter *f) const;
+ static void generate_test_instances(list<rgw_cls_list_ret*>& o);
};
WRITE_CLASS_ENCODER(rgw_cls_list_ret)
delete perfcounter;
}
+void RGWAccessKey::generate_test_instances(list<RGWAccessKey*>& o)
+{
+ o.push_back(new RGWAccessKey);
+}
+
+void RGWAccessKey::dump(Formatter *f) const
+{
+}
+
+void RGWSubUser::generate_test_instances(list<RGWSubUser*>& o)
+{
+ o.push_back(new RGWSubUser);
+}
+
+void RGWSubUser::dump(Formatter *f) const
+{
+}
+
+void RGWUserInfo::generate_test_instances(list<RGWUserInfo*>& o)
+{
+ o.push_back(new RGWUserInfo);
+}
+
+void RGWUserInfo::dump(Formatter *f) const
+{
+}
+
+void rgw_bucket::generate_test_instances(list<rgw_bucket*>& o)
+{
+ o.push_back(new rgw_bucket);
+}
+
+void rgw_bucket::dump(Formatter *f) const
+{
+}
+
+void RGWBucketInfo::generate_test_instances(list<RGWBucketInfo*>& o)
+{
+ o.push_back(new RGWBucketInfo);
+}
+
+void RGWBucketInfo::dump(Formatter *f) const
+{
+}
+
+void RGWBucketEnt::generate_test_instances(list<RGWBucketEnt*>& o)
+{
+ o.push_back(new RGWBucketEnt);
+}
+
+void RGWBucketEnt::dump(Formatter *f) const
+{
+}
+
+void RGWUploadPartInfo::generate_test_instances(list<RGWUploadPartInfo*>& o)
+{
+ o.push_back(new RGWUploadPartInfo);
+}
+
+void RGWUploadPartInfo::dump(Formatter *f) const
+{
+}
+
+void rgw_obj::generate_test_instances(list<rgw_obj*>& o)
+{
+ o.push_back(new rgw_obj);
+}
+
+void rgw_obj::dump(Formatter *f) const
+{
+}
+
using namespace ceph::crypto;
::decode(subuser, bl);
DECODE_FINISH(bl);
}
+ void dump(Formatter *f) const;
+ static void generate_test_instances(list<RGWAccessKey*>& o);
};
WRITE_CLASS_ENCODER(RGWAccessKey);
::decode(perm_mask, bl);
DECODE_FINISH(bl);
}
+ void dump(Formatter *f) const;
+ static void generate_test_instances(list<RGWSubUser*>& o);
};
WRITE_CLASS_ENCODER(RGWSubUser);
}
DECODE_FINISH(bl);
}
+ void dump(Formatter *f) const;
+ static void generate_test_instances(list<RGWUserInfo*>& o);
void clear() {
user_id.clear();
}
DECODE_FINISH(bl);
}
+ void dump(Formatter *f) const;
+ static void generate_test_instances(list<rgw_bucket*>& o);
};
WRITE_CLASS_ENCODER(rgw_bucket)
::decode(flags, bl);
DECODE_FINISH(bl);
}
+ void dump(Formatter *f) const;
+ static void generate_test_instances(list<RGWBucketInfo*>& o);
RGWBucketInfo() : flags(0) {}
};
size_rounded = s;
DECODE_FINISH(bl);
}
+ void dump(Formatter *f) const;
+ static void generate_test_instances(list<RGWBucketEnt*>& o);
void clear() {
bucket.clear();
size = 0;
::decode(modified, bl);
DECODE_FINISH(bl);
}
+ void dump(Formatter *f) const;
+ static void generate_test_instances(list<RGWUploadPartInfo*>& o);
};
WRITE_CLASS_ENCODER(RGWUploadPartInfo)
::decode(bucket, bl);
DECODE_FINISH(bl);
}
+ void dump(Formatter *f) const;
+ static void generate_test_instances(list<rgw_obj*>& o);
bool operator==(const rgw_obj& o) const {
return (object.compare(o.object) == 0) &&
#define DOUT_SUBSYS rgw
+void rgw_log_entry::generate_test_instances(list<rgw_log_entry*>& o)
+{
+ o.push_back(new rgw_log_entry);
+}
+
+void rgw_log_entry::dump(Formatter *f) const
+{
+}
+
+void rgw_intent_log_entry::generate_test_instances(list<rgw_intent_log_entry*>& o)
+{
+ o.push_back(new rgw_intent_log_entry);
+}
+
+void rgw_intent_log_entry::dump(Formatter *f) const
+{
+}
+
static rgw_bucket log_bucket(RGW_LOG_POOL_NAME);
static void set_param_str(struct req_state *s, const char *name, string& str)
bucket_id = -1;
DECODE_FINISH(p);
}
+ void dump(Formatter *f) const;
+ static void generate_test_instances(list<rgw_log_entry*>& o);
};
WRITE_CLASS_ENCODER(rgw_log_entry)
::decode(intent, p);
DECODE_FINISH(p);
}
+ void dump(Formatter *f) const;
+ static void generate_test_instances(list<rgw_intent_log_entry*>& o);
};
WRITE_CLASS_ENCODER(rgw_intent_log_entry)
static RGWObjCategory shadow_category = RGW_OBJ_CATEGORY_SHADOW;
static RGWObjCategory main_category = RGW_OBJ_CATEGORY_MAIN;
+void rgw_bucket_pending_info::generate_test_instances(list<rgw_bucket_pending_info*>& o)
+{
+ o.push_back(new rgw_bucket_pending_info);
+}
+
+void rgw_bucket_pending_info::dump(Formatter *f) const
+{
+}
+
+void rgw_bucket_dir_entry_meta::generate_test_instances(list<rgw_bucket_dir_entry_meta*>& o)
+{
+ o.push_back(new rgw_bucket_dir_entry_meta);
+}
+
+void rgw_bucket_dir_entry_meta::dump(Formatter *f) const
+{
+}
+
+void rgw_bucket_dir_entry::generate_test_instances(list<rgw_bucket_dir_entry*>& o)
+{
+ o.push_back(new rgw_bucket_dir_entry);
+}
+
+void rgw_bucket_dir_entry::dump(Formatter *f) const
+{
+}
+
+void rgw_bucket_category_stats::generate_test_instances(list<rgw_bucket_category_stats*>& o)
+{
+ o.push_back(new rgw_bucket_category_stats);
+}
+
+void rgw_bucket_category_stats::dump(Formatter *f) const
+{
+}
+
+void rgw_bucket_dir_header::generate_test_instances(list<rgw_bucket_dir_header*>& o)
+{
+ o.push_back(new rgw_bucket_dir_header);
+}
+
+void rgw_bucket_dir_header::dump(Formatter *f) const
+{
+}
+
+void rgw_bucket_dir::generate_test_instances(list<rgw_bucket_dir*>& o)
+{
+ o.push_back(new rgw_bucket_dir);
+}
+
+void rgw_bucket_dir::dump(Formatter *f) const
+{
+}
+
+void rgw_cls_obj_prepare_op::generate_test_instances(list<rgw_cls_obj_prepare_op*>& o)
+{
+ o.push_back(new rgw_cls_obj_prepare_op);
+}
+
+void rgw_cls_obj_prepare_op::dump(Formatter *f) const
+{
+}
+
+void rgw_cls_obj_complete_op::generate_test_instances(list<rgw_cls_obj_complete_op*>& o)
+{
+ o.push_back(new rgw_cls_obj_complete_op);
+}
+
+void rgw_cls_obj_complete_op::dump(Formatter *f) const
+{
+}
+
+void rgw_cls_list_op::generate_test_instances(list<rgw_cls_list_op*>& o)
+{
+ o.push_back(new rgw_cls_list_op);
+}
+
+void rgw_cls_list_op::dump(Formatter *f) const
+{
+}
+
+void rgw_cls_list_ret::generate_test_instances(list<rgw_cls_list_ret*>& o)
+{
+ o.push_back(new rgw_cls_list_ret);
+}
+
+void rgw_cls_list_ret::dump(Formatter *f) const
+{
+}
+
+
+
class RGWWatcher : public librados::WatchCtx {
RGWRados *rados;
public:
TYPE(DBObjectMap::_Header)
TYPE(DBObjectMap::State)
+#include "rgw/rgw_access.h"
+TYPE(RGWObjManifestPart);
+TYPE(RGWObjManifest);
+
+#include "rgw/rgw_acl.h"
+TYPE(ACLPermission)
+TYPE(ACLGranteeType)
+TYPE(ACLGrant)
+TYPE(RGWAccessControlList)
+TYPE(ACLOwner)
+TYPE(RGWAccessControlPolicy)
+
+#include "rgw/rgw_cache.h"
+TYPE(ObjectMetaInfo)
+TYPE(ObjectCacheInfo)
+TYPE(RGWCacheNotifyInfo)
+
+#include "rgw/rgw_cls_api.h"
+TYPE(rgw_bucket_pending_info)
+TYPE(rgw_bucket_dir_entry_meta)
+TYPE(rgw_bucket_dir_entry)
+TYPE(rgw_bucket_category_stats)
+TYPE(rgw_bucket_dir_header)
+TYPE(rgw_bucket_dir)
+TYPE(rgw_cls_obj_prepare_op)
+TYPE(rgw_cls_obj_complete_op)
+TYPE(rgw_cls_list_op)
+TYPE(rgw_cls_list_ret)
+
+#include "rgw/rgw_common.h"
+TYPE(RGWAccessKey);
+TYPE(RGWSubUser);
+TYPE(RGWUserInfo)
+TYPE(rgw_bucket)
+TYPE(RGWBucketInfo)
+TYPE(RGWBucketEnt)
+TYPE(RGWUploadPartInfo)
+TYPE(rgw_obj)
+
+#include "rgw/rgw_log.h"
+TYPE(rgw_log_entry)
+TYPE(rgw_intent_log_entry)
+
// --- messages ---
#include "messages/MAuth.h"
MESSAGE(MAuth)