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 13:31:48 +03:00
parent e7c261e5a2
commit 0748ae3207
1 changed files with 6 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
writeengine/client/we_clients.cpp
View File

@@ -343,16 +343,17 @@ void WEClients::Listen(boost::shared_ptr<MessageQueueClient> client, uint32_t co
{ {
SBS sbs; SBS sbs;
idblog("conn index " << connIndex << ", ip addr " << client->addr2String()); idblog("conn index " << connIndex << ", other end " << client->otherEnd());
try try
{ {
while (Busy()) while (Busy())
{ {
// TODO: This call blocks so setting Busy() in another thread doesn't work here... // TODO: This call blocks so setting Busy() in another thread doesn't work here...
idblog("receiving packet. conn index " << connIndex << ", other end " << client->otherEnd());
sbs = client->read(); sbs = client->read();
idblog("received packet. conn index " << connIndex << ", ip addr " << client->addr2String() << ", length " << sbs->length()); idblog("received packet. conn index " << connIndex << ", other end " << client->otherEnd() << ", length " << sbs->length());
if (sbs->length() != 0) if (sbs->length() != 0)
{ {
// cout << "adding data to connIndex " << endl; // cout << "adding data to connIndex " << endl;
@@ -375,17 +376,20 @@ void WEClients::Listen(boost::shared_ptr<MessageQueueClient> client, uint32_t co
catch (std::exception& e) catch (std::exception& e)
{ {
cerr << "WEC Caught EXCEPTION: " << e.what() << endl; cerr << "WEC Caught EXCEPTION: " << e.what() << endl;
idblog("exception " << e.what());
goto Error; goto Error;
} }
catch (...) catch (...)
{ {
cerr << "WEC Caught UNKNOWN EXCEPT" << endl; cerr << "WEC Caught UNKNOWN EXCEPT" << endl;
idblog("unknown error ");
goto Error; goto Error;
} }
Error: Error:
// error condition! push 0 length bs to messagequeuemap and // error condition! push 0 length bs to messagequeuemap and
// eventually let jobstep error out. // eventually let jobstep error out.
idblog("Error");
boost::mutex::scoped_lock lk(fMlock); boost::mutex::scoped_lock lk(fMlock);
MessageQueueMap::iterator map_tok; MessageQueueMap::iterator map_tok;