blob: ea31da6b19c1504904e905915cce82da7ebe4921 (
plain)
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
|
// Copyright (c) 2010 The Chromium Authors. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
#include "chrome/common/multi_process_lock.h"
#include "base/logging.h"
#include "base/utf_string_conversions.h"
#include "base/win/scoped_handle.h"
class MultiProcessLockWin : public MultiProcessLock {
public:
explicit MultiProcessLockWin(const std::string& name) : name_(name) { }
virtual ~MultiProcessLockWin() {
if (event_.Get() != NULL) {
Unlock();
}
}
virtual bool TryLock() {
if (event_.Get() != NULL) {
DLOG(ERROR) << "MultiProcessLock is already locked - " << name_;
return true;
}
if (name_.length() > MULTI_PROCESS_LOCK_NAME_MAX_LEN) {
LOG(ERROR) << "Socket name too long (" << name_.length()
<< " > " << MULTI_PROCESS_LOCK_NAME_MAX_LEN << ") - " << name_;
return false;
}
string16 wname = UTF8ToUTF16(name_);
event_.Set(CreateEvent(NULL, FALSE, FALSE, wname.c_str()));
if (event_.Get() && GetLastError() != ERROR_ALREADY_EXISTS) {
return true;
} else {
event_.Set(NULL);
return false;
}
}
virtual void Unlock() {
if (event_.Get() == NULL) {
DLOG(ERROR) << "Over-unlocked MultiProcessLock - " << name_;
return;
}
event_.Set(NULL);
}
private:
std::string name_;
base::win::ScopedHandle event_;
DISALLOW_COPY_AND_ASSIGN(MultiProcessLockWin);
};
MultiProcessLock* MultiProcessLock::Create(const std::string &name) {
return new MultiProcessLockWin(name);
}
|
