1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
|
// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
// vim: ts=8 sw=2 smarttab
/*
* Ceph - scalable distributed file system
*
* Copyright (C) 2004-2006 Sage Weil <sage@newdream.net>
*
* This is free software; you can redistribute it and/or
* modify it under the terms of the GNU Lesser General Public
* License version 2.1, as published by the Free Software
* Foundation. See file COPYING.
*
*/
#ifndef OS_INDEXMANAGER_H
#define OS_INDEXMANAGER_H
#include "include/unordered_map.h"
#include "common/ceph_mutex.h"
#include "common/Cond.h"
#include "common/config.h"
#include "common/debug.h"
#include "CollectionIndex.h"
#include "HashIndex.h"
/// Public type for Index
struct Index {
CollectionIndex *index;
Index() : index(NULL) {}
explicit Index(CollectionIndex* index) : index(index) {}
CollectionIndex *operator->() { return index; }
CollectionIndex &operator*() { return *index; }
};
/**
* Encapsulates mutual exclusion for CollectionIndexes.
*
* Allowing a modification (removal or addition of an object) to occur
* while a read is occurring (lookup of an object's path and use of
* that path) may result in the path becoming invalid. Thus, during
* the lifetime of a CollectionIndex object and any paths returned
* by it, no other concurrent accesses may be allowed.
* This is enforced by using CollectionIndex::access_lock
*/
class IndexManager {
CephContext* cct;
/// Lock for Index Manager
ceph::shared_mutex lock = ceph::make_shared_mutex("IndexManager lock");
bool upgrade;
ceph::unordered_map<coll_t, CollectionIndex* > col_indices;
/**
* Index factory
*
* Encapsulates logic for handling legacy FileStore
* layouts
*
* @param [in] c Collection for which to get index
* @param [in] path Path to collection
* @param [out] index Index for c
* @return error code
*/
int build_index(coll_t c, const char *path, CollectionIndex **index);
bool get_index_optimistic(coll_t c, Index *index);
public:
/// Constructor
explicit IndexManager(CephContext* cct,
bool upgrade) : cct(cct),
upgrade(upgrade) {}
~IndexManager();
/**
* Reserve and return index for c
*
* @param [in] c Collection for which to get index
* @param [in] baseDir base directory of collections
* @param [out] index Index for c
* @return error code
*/
int get_index(coll_t c, const std::string& baseDir, Index *index);
/**
* Initialize index for collection c at path
*
* @param [in] c Collection for which to init Index
* @param [in] path Path to collection
* @param [in] filestore_version version of containing FileStore
* @return error code
*/
int init_index(coll_t c, const char *path, uint32_t filestore_version);
};
#endif
|
