21
21
#include "config.h"
23
#include <boost/bind.hpp>
24
#include <boost/thread/mutex.hpp>
25
#include <boost/thread/shared_mutex.hpp>
23
#include "drizzled/pthread_globals.h"
27
24
#include "drizzled/session.h"
28
25
#include "drizzled/identifier/table.h"
29
#include "drizzled/definition/cache.h"
30
26
#include "drizzled/definition/table.h"
32
28
namespace drizzled {
34
30
namespace definition {
36
TableShare::shared_ptr Cache::find(const TableIdentifier::Key &key)
32
TableSharePtr Cache::find(const TableIdentifier &identifier)
38
boost::mutex::scoped_lock scopedLock(_mutex);
34
//safe_mutex_assert_owner(LOCK_open.native_handle);
40
Map::iterator iter= cache.find(key);
36
CacheMap::iterator iter= cache.find(identifier.getKey());
41
37
if (iter != cache.end())
43
39
return (*iter).second;
46
return TableShare::shared_ptr();
42
return TableSharePtr();
49
void Cache::erase(const TableIdentifier::Key &key)
45
void Cache::erase(const TableIdentifier &identifier)
51
boost::mutex::scoped_lock scopedLock(_mutex);
47
//safe_mutex_assert_owner(LOCK_open.native_handle);
49
cache.erase(identifier.getKey());
56
bool Cache::insert(const TableIdentifier::Key &key, TableShare::shared_ptr share)
52
bool Cache::insert(const TableIdentifier &identifier, TableSharePtr share)
58
boost::mutex::scoped_lock scopedLock(_mutex);
59
std::pair<Map::iterator, bool> ret=
60
cache.insert(std::make_pair(key, share));
54
std::pair<CacheMap::iterator, bool> ret=
55
cache.insert(std::make_pair(identifier.getKey(), share));
65
void Cache::CopyFrom(drizzled::TableShare::vector &vector)
67
boost::mutex::scoped_lock scopedLock(_mutex);
69
vector.reserve(definition::Cache::singleton().size());
71
std::transform(cache.begin(),
73
std::back_inserter(vector),
74
boost::bind(&Map::value_type::second, _1) );
75
assert(vector.size() == cache.size());
78
60
} /* namespace definition */
79
61
} /* namespace drizzled */