aboutsummaryrefslogtreecommitdiffstats
path: root/util/system/mlock.cpp
diff options
context:
space:
mode:
authorMaxim Yurchuk <maxim-yurchuk@ydb.tech>2024-11-20 17:37:57 +0000
committerGitHub <noreply@github.com>2024-11-20 17:37:57 +0000
commitf76323e9b295c15751e51e3443aa47a36bee8023 (patch)
tree4113c8cad473a33e0f746966e0cf087252fa1d7a /util/system/mlock.cpp
parent753ecb8d410a4cb459c26f3a0082fb2d1724fe63 (diff)
parenta7b9a6afea2a9d7a7bfac4c5eb4c1a8e60adb9e6 (diff)
downloadydb-f76323e9b295c15751e51e3443aa47a36bee8023.tar.gz
Merge pull request #11788 from ydb-platform/mergelibs-241120-1113
Library import 241120-1113
Diffstat (limited to 'util/system/mlock.cpp')
-rw-r--r--util/system/mlock.cpp18
1 files changed, 12 insertions, 6 deletions
diff --git a/util/system/mlock.cpp b/util/system/mlock.cpp
index 27895bbacc..3205e188a8 100644
--- a/util/system/mlock.cpp
+++ b/util/system/mlock.cpp
@@ -34,12 +34,15 @@ void LockMemory(const void* addr, size_t len) {
#elif defined(_win_)
HANDLE hndl = GetCurrentProcess();
SIZE_T min, max;
- if (!GetProcessWorkingSetSize(hndl, &min, &max))
+ if (!GetProcessWorkingSetSize(hndl, &min, &max)) {
ythrow yexception() << LastSystemErrorText();
- if (!SetProcessWorkingSetSize(hndl, min + len, max + len))
+ }
+ if (!SetProcessWorkingSetSize(hndl, min + len, max + len)) {
ythrow yexception() << LastSystemErrorText();
- if (!VirtualLock((LPVOID)addr, len))
+ }
+ if (!VirtualLock((LPVOID)addr, len)) {
ythrow yexception() << LastSystemErrorText();
+ }
#endif
}
@@ -58,12 +61,15 @@ void UnlockMemory(const void* addr, size_t len) {
#elif defined(_win_)
HANDLE hndl = GetCurrentProcess();
SIZE_T min, max;
- if (!GetProcessWorkingSetSize(hndl, &min, &max))
+ if (!GetProcessWorkingSetSize(hndl, &min, &max)) {
ythrow yexception() << LastSystemErrorText();
- if (!SetProcessWorkingSetSize(hndl, min - len, max - len))
+ }
+ if (!SetProcessWorkingSetSize(hndl, min - len, max - len)) {
ythrow yexception() << LastSystemErrorText();
- if (!VirtualUnlock((LPVOID)addr, len))
+ }
+ if (!VirtualUnlock((LPVOID)addr, len)) {
ythrow yexception() << LastSystemErrorText();
+ }
#endif
}