blob: b868531a72e79d090bcd19721e62da517fdc25a1 (
plain) (
blame)
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
|
#include <Storages/MergeTree/TemporaryParts.h>
#include <Common/Exception.h>
namespace DB
{
namespace ErrorCodes
{
extern const int LOGICAL_ERROR;
}
bool TemporaryParts::contains(const std::string & basename) const
{
std::lock_guard lock(mutex);
return parts.contains(basename);
}
void TemporaryParts::add(const std::string & basename)
{
std::lock_guard lock(mutex);
bool inserted = parts.emplace(basename).second;
if (!inserted)
throw Exception(ErrorCodes::LOGICAL_ERROR, "Temporary part {} already added", basename);
}
void TemporaryParts::remove(const std::string & basename)
{
std::lock_guard lock(mutex);
bool removed = parts.erase(basename);
if (!removed)
throw Exception(ErrorCodes::LOGICAL_ERROR, "Temporary part {} does not exist", basename);
}
}
|
