Differential D19476 Diff 53107 autotests/client/test_remote_access.cpp

Changeset View

Standalone View

View Options

autotests/client/test_remote_access.cpp

Show First 20 Lines • Show All 267 Lines • ▼ Show 20 Line(s)247{
268 buf->setFd(tmpFile->handle()); 268​ buf->setFd(tmpFile->handle());
269 buf->setSize(50, 50); 269​ buf->setSize(50, 50);
270 buf->setFormat(100500); 270​ buf->setFormat(100500);
271 buf->setStride(7800); 271​ buf->setStride(7800);
272 m_remoteAccessInterface->sendBufferReady(m_outputInterface[0], buf); 272​ m_remoteAccessInterface->sendBufferReady(m_outputInterface[0], buf);
273 273​
274 // wait for event loop 274​ // wait for event loop
275 QVERIFY(bufferReadySpy1.wait()); 275​ QVERIFY(bufferReadySpy1.wait());
276 if (bufferReadySpy2.size() == 0) { ​
277 QVERIFY(bufferReadySpy2.wait()); ​
278 } ​
279 ​
280 // receive buffer at client 1 276​ // receive buffer at client 1
281 QCOMPARE(bufferReadySpy1.size(), 1); 277​ QCOMPARE(bufferReadySpy1.size(), 1);
282 auto rbuf1 = bufferReadySpy1.takeFirst()[1].value<const RemoteBuffer *>(); 278​ auto rbuf1 = bufferReadySpy1.takeFirst()[1].value<const RemoteBuffer *>();
283 QSignalSpy paramsObtainedSpy1(rbuf1, &RemoteBuffer::parametersObtained); 279​ QSignalSpy paramsObtainedSpy1(rbuf1, &RemoteBuffer::parametersObtained);
284 QVERIFY(paramsObtainedSpy1.isValid()); 280​ QVERIFY(paramsObtainedSpy1.isValid());
285 281​
282​ if (bufferReadySpy2.size() == 0) {
283​ QVERIFY(bufferReadySpy2.wait());
284​ }
286 // receive buffer at client 2 285​ // receive buffer at client 2
287 QCOMPARE(bufferReadySpy2.size(), 1); 286​ QCOMPARE(bufferReadySpy2.size(), 1);
288 auto rbuf2 = bufferReadySpy2.takeFirst()[1].value<const RemoteBuffer *>(); 287​ auto rbuf2 = bufferReadySpy2.takeFirst()[1].value<const RemoteBuffer *>();
289 QSignalSpy paramsObtainedSpy2(rbuf2, &RemoteBuffer::parametersObtained); 288​ QSignalSpy paramsObtainedSpy2(rbuf2, &RemoteBuffer::parametersObtained);
290 QVERIFY(paramsObtainedSpy2.isValid()); 289​ QVERIFY(paramsObtainedSpy2.isValid());
291 290​
292 // wait for event loop 291​ // wait for event loop
293 QVERIFY(paramsObtainedSpy1.wait()); 292​ QVERIFY(paramsObtainedSpy1.size() == 1 || paramsObtainedSpy1.wait());
294 QCOMPARE(paramsObtainedSpy1.size(), 1); 293​ QCOMPARE(paramsObtainedSpy1.size(), 1);
295 if (paramsObtainedSpy2.size() == 0) { 294​ if (paramsObtainedSpy2.size() == 0) {
296 QVERIFY(paramsObtainedSpy2.wait()); 295​ QVERIFY(paramsObtainedSpy2.wait());
297 } 296​ }
298 QCOMPARE(paramsObtainedSpy2.size(), 1); 297​ QCOMPARE(paramsObtainedSpy2.size(), 1);
299 298​
300 // release 299​ // release
301 QSignalSpy bufferReleasedSpy(m_remoteAccessInterface, &RemoteAccessManagerInterface::bufferReleased); 300​ QSignalSpy bufferReleasedSpy(m_remoteAccessInterface, &RemoteAccessManagerInterface::bufferReleased);
▲ Show 20 Lines • Show All 186 Lines • Show Last 20 Lines