summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorChristian Mollekopf <chrigi_1@fastmail.fm>2018-03-18 14:32:07 +0100
committerChristian Mollekopf <chrigi_1@fastmail.fm>2018-03-18 14:32:07 +0100
commitceac3a797d161c985365b304ae7a15268b90ba09 (patch)
tree3ea49b1f5339bda94d526b2715bff67be9affb80
parent6ba676bdbbcee0a239fb12af66b6a68d5336da03 (diff)
downloadsink-ceac3a797d161c985365b304ae7a15268b90ba09.tar.gz
sink-ceac3a797d161c985365b304ae7a15268b90ba09.zip
Improved debug output
-rw-r--r--common/resourceaccess.cpp11
1 files changed, 6 insertions, 5 deletions
diff --git a/common/resourceaccess.cpp b/common/resourceaccess.cpp
index 66684c3..817b7eb 100644
--- a/common/resourceaccess.cpp
+++ b/common/resourceaccess.cpp
@@ -158,9 +158,10 @@ KAsync::Job<QSharedPointer<QLocalSocket>> ResourceAccess::connectToServer(const
158 future.setValue(s); 158 future.setValue(s);
159 future.setFinished(); 159 future.setFinished();
160 }); 160 });
161 QObject::connect(s.data(), static_cast<void (QLocalSocket::*)(QLocalSocket::LocalSocketError)>(&QLocalSocket::error), context, [&future, context](QLocalSocket::LocalSocketError) { 161 QObject::connect(s.data(), static_cast<void (QLocalSocket::*)(QLocalSocket::LocalSocketError)>(&QLocalSocket::error), context, [&future, &s, context](QLocalSocket::LocalSocketError localSocketError) {
162 const auto errorString = s->errorString();
162 delete context; 163 delete context;
163 future.setError(-1, "Failed to connect to server."); 164 future.setError(localSocketError, "Failed to connect to socket: " + errorString);
164 }); 165 });
165 s->connectToServer(identifier); 166 s->connectToServer(identifier);
166 }); 167 });
@@ -182,7 +183,7 @@ KAsync::Job<void> ResourceAccess::Private::tryToConnect()
182 static int maxRetries = timeout / waitTime; 183 static int maxRetries = timeout / waitTime;
183 if (*counter > maxRetries) { 184 if (*counter > maxRetries) {
184 SinkTrace() << "Giving up after " << *counter << "tries"; 185 SinkTrace() << "Giving up after " << *counter << "tries";
185 return KAsync::error<KAsync::ControlFlowFlag>("Failed to connect to socket"); 186 return KAsync::error<KAsync::ControlFlowFlag>(error);
186 } else { 187 } else {
187 *counter = *counter + 1; 188 *counter = *counter + 1;
188 return KAsync::wait(waitTime).then(KAsync::value(KAsync::Continue)); 189 return KAsync::wait(waitTime).then(KAsync::value(KAsync::Continue));
@@ -226,7 +227,7 @@ KAsync::Job<void> ResourceAccess::Private::initializeSocket()
226 }); 227 });
227 } else { 228 } else {
228 SinkError() << "Failed to start resource"; 229 SinkError() << "Failed to start resource";
229 return KAsync::error(-1, "Failed to start resource."); 230 return KAsync::error("Failed to start resource.");
230 } 231 }
231 } else { 232 } else {
232 SinkTrace() << "Connected to resource, without having to start it."; 233 SinkTrace() << "Connected to resource, without having to start it.";
@@ -429,7 +430,7 @@ void ResourceAccess::open()
429 [this, time](const KAsync::Error &error) { 430 [this, time](const KAsync::Error &error) {
430 d->openingSocket = false; 431 d->openingSocket = false;
431 if (error) { 432 if (error) {
432 SinkError() << "Failed to initialize socket " << error.errorMessage; 433 SinkError() << "Failed to initialize socket " << error;
433 d->abortPendingOperations(); 434 d->abortPendingOperations();
434 } else { 435 } else {
435 SinkTrace() << "Socket is initialized." << Log::TraceTime(time->elapsed()); 436 SinkTrace() << "Socket is initialized." << Log::TraceTime(time->elapsed());