thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-11-25 00:52:02 +00:00
Code Issues Packages Projects Releases Wiki Activity

Update ReplxxLineReader.cpp

Browse Source
This commit is contained in:
alexey-milovidov 2020-06-06 12:49:15 +03:00 committed by GitHub
parent d0312bf1fe
commit 7003fe8258
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 13 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
base/common/ReplxxLineReader.cpp
View File

@ -26,24 +26,26 @@ ReplxxLineReader::ReplxxLineReader(
if (!history_file_path.empty()) if (!history_file_path.empty())
{ {
errno = 0;
history_file_fd = open(history_file_path.c_str(), O_RDWR); history_file_fd = open(history_file_path.c_str(), O_RDWR);
if (history_file_fd < 0) if (history_file_fd < 0)
{ {
rx.print("Open of history file failed: %s\n", strerror(errno)); rx.print("Open of history file failed: %s\n", strerror(errno));
} }
else
errno = 0;
if (flock(history_file_fd, LOCK_SH))
{ {
rx.print("Shared lock of history file failed: %s\n", strerror(errno)); if (flock(history_file_fd, LOCK_SH))
} {
rx.history_load(history_file_path); rx.print("Shared lock of history file failed: %s\n", strerror(errno));
}
else
{
rx.history_load(history_file_path);
errno = 0; if (flock(history_file_fd, LOCK_UN))
if (flock(history_file_fd, LOCK_UN)) {
{ rx.print("Unlock of history file failed: %s\n", strerror(errno));
rx.print("Unlock of history file failed: %s\n", strerror(errno)); }
}
} }
} }