diff options
-rw-r--r-- | common/resourceaccess.cpp | 11 |
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()); |