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

Fix style and build

Browse Source
This commit is contained in:
Pavel Kruglov 2021-02-06 22:13:50 +03:00
parent 3f87e473be
commit 9048dc43d4
2 changed files with 2 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/Common/Epoll.cpp
View File

@ -8,12 +8,9 @@
namespace DB
{
/// TODO: add appropriate error codes
namespace ErrorCodes
{
extern const int EPOLL_ERROR;
extern const int LOGICAL_ERROR;
}
Epoll::Epoll() : events_count(0)

4
src/DataStreams/RemoteQueryExecutorReadContext.cpp
View File

@ -124,13 +124,13 @@ bool RemoteQueryExecutorReadContext::checkTimeoutImpl() const
epoll_event events[3];
events[0].data.fd = events[1].data.fd = events[2].data.fd = -1;
epoll.getManyReady(3, events,/* blocking = */ false);
int num_events = epoll.getManyReady(3, events,/* blocking = */ false);
bool is_socket_ready = false;
bool is_pipe_alarmed = false;
bool has_timer_alarm = false;
for (int i = 0; i < 3; ++i)
for (int i = 0; i < num_events; ++i)
{
if (events[i].data.fd == connection_fd)
is_socket_ready = true;