database/mariadb-columnstore-engine
1
0
Fork 0
mirror of https://github.com/mariadb-corporation/mariadb-columnstore-engine.git synced 2025-08-08 14:22:09 +03:00
Code Activity

debug logs

Browse Source
This commit is contained in:
Serguey Zefirov
2025-05-16 12:08:21 +03:00
parent a0b1214fb8
commit e7c261e5a2
1 changed files with 3 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
writeengine/client/we_clients.cpp
View File

@@ -343,6 +343,8 @@ void WEClients::Listen(boost::shared_ptr<MessageQueueClient> client, uint32_t co
{
SBS sbs;
idblog("conn index " << connIndex << ", ip addr " << client->addr2String());
try
{
while (Busy())
@@ -350,6 +352,7 @@ void WEClients::Listen(boost::shared_ptr<MessageQueueClient> client, uint32_t co
// TODO: This call blocks so setting Busy() in another thread doesn't work here...
sbs = client->read();
idblog("received packet. conn index " << connIndex << ", ip addr " << client->addr2String() << ", length " << sbs->length());
if (sbs->length() != 0)
{
// cout << "adding data to connIndex " << endl;