Merge lp:~xavi-garcia-mena/keeper/tests-with-propertieschanged-signal into lp:keeper/devel
- tests-with-propertieschanged-signal
- Merge into devel
Proposed by
Xavi Garcia
| Status: | Merged |
|---|---|
| Merge reported by: | Xavi Garcia |
| Merged at revision: | not available |
| Proposed branch: | lp:~xavi-garcia-mena/keeper/tests-with-propertieschanged-signal |
| Merge into: | lp:keeper/devel |
| Diff against target: |
819 lines (+550/-23) 14 files modified
src/service/keeper-task.cpp (+24/-1) src/service/keeper-task.h (+2/-0) src/service/private/keeper-task_p.h (+2/-0) src/service/task-manager.cpp (+30/-16) src/service/task-manager.h (+5/-0) src/util/dbus-utils.cpp (+6/-1) tests/CMakeLists.txt (+1/-0) tests/integration/helpers/CMakeLists.txt (+3/-0) tests/integration/helpers/helpers-test-failure.cpp (+16/-1) tests/integration/helpers/helpers-test.cc (+14/-0) tests/integration/helpers/test-helpers-base.cpp (+360/-3) tests/integration/helpers/test-helpers-base.h (+7/-1) tests/qdbus-stubs/CMakeLists.txt (+53/-0) tests/qdbus-stubs/org.freedesktop.DBus.Properties.xml (+27/-0) |
| To merge this branch: | bzr merge lp:~xavi-garcia-mena/keeper/tests-with-propertieschanged-signal |
| Related bugs: |
| Reviewer | Review Type | Date Requested | Status |
|---|---|---|---|
| unity-api-1-bot | continuous-integration | Needs Fixing | |
| Charles Kerr (community) | Approve | ||
|
Review via email:
|
|||
Commit message
Improve integration tests to listen to the PropertiesChanged signal from keeper.User dbus interface.
Description of the change
Improve integration tests to listen to the PropertiesChanged signal from keeper.User dbus interface.
The tests now check that the signals progress is correct. It records all the signals until completion of all tasks and checks that things like "action" state makes sense of "percent-done" is always greater or equal than the previous signal.
It also adds some code modifications to emit the PropertiesChanged signal as now the state lives in the TaskManager class.
To post a comment you must log in.
Revision history for this message
| unity-api-1-bot (unity-api-1-bot) wrote : | # |
review:
Needs Fixing
(continuous-integration)
Revision history for this message
| Charles Kerr (charlesk) wrote : | # |
Clean and straightforward. Overall, looks very good!
Several questions and minor/trivial suggestions inline, one borderline needs-fixing.
review:
Needs Information
Revision history for this message
| Xavi Garcia (xavi-garcia-mena) wrote : | # |
Thanks for the review, Charles. I've added some comments inline.
When fixing the issues you found and suggested I realized that we were not sending a lot of PropertiesChanges signal at the beginning because when I did the TaskManager change I forgot to add them.
To fix this I've created a static method in the KeeperTask class that returns an initial state.
The idea would be to set that initial state for all tasks (which should appear as queued for the user) and then emit the PropertiesSignal to notify the state of all tasks all at once.
I also added a new change to detect when the previous state of a task is equal to the current one. In that case we don't emit the PropertiesChanged signal.
We have a big TODO here, though, and it's about i18n as stated in the code... I've created a Trello card for that.
Revision history for this message
| unity-api-1-bot (unity-api-1-bot) wrote : | # |
FAILED: Continuous integration, rev:101
https:/
Executed test runs:
FAILURE: https:/
SUCCESS: https:/
SUCCESS: https:/
deb: https:/
SUCCESS: https:/
deb: https:/
FAILURE: https:/
SUCCESS: https:/
deb: https:/
SUCCESS: https:/
deb: https:/
FAILURE: https:/
SUCCESS: https:/
deb: https:/
SUCCESS: https:/
deb: https:/
FAILURE: https:/
Click here to trigger a rebuild:
https:/
review:
Needs Fixing
(continuous-integration)
Revision history for this message
| Charles Kerr (charlesk) wrote : | # |
LGTM. Thanks for the changes!
review:
Approve
Revision history for this message
| unity-api-1-bot (unity-api-1-bot) wrote : | # |
FAILED: Autolanding.
More details in the following jenkins job:
https:/
Executed test runs:
FAILURE: https:/
SUCCESS: https:/
SUCCESS: https:/
deb: https:/
SUCCESS: https:/
deb: https:/
FAILURE: https:/
SUCCESS: https:/
deb: https:/
SUCCESS: https:/
deb: https:/
FAILURE: https:/
SUCCESS: https:/
deb: https:/
SUCCESS: https:/
deb: https:/
FAILURE: https:/
review:
Needs Fixing
(continuous-integration)
Preview Diff
[H/L] Next/Prev Comment, [J/K] Next/Prev File, [N/P] Next/Prev Hunk
| 1 | === modified file 'src/service/keeper-task.cpp' | |||
| 2 | --- src/service/keeper-task.cpp 2016-08-31 14:40:50 +0000 | |||
| 3 | +++ src/service/keeper-task.cpp 2016-09-06 13:08:57 +0000 | |||
| 4 | @@ -114,7 +114,7 @@ | |||
| 5 | 114 | 114 | ||
| 6 | 115 | void KeeperTaskPrivate::on_helper_percent_done_changed(float /*percent_done*/) | 115 | void KeeperTaskPrivate::on_helper_percent_done_changed(float /*percent_done*/) |
| 7 | 116 | { | 116 | { |
| 9 | 117 | calculate_task_state(); | 117 | calculate_and_notify_state(helper_->state()); |
| 10 | 118 | } | 118 | } |
| 11 | 119 | 119 | ||
| 12 | 120 | QVariantMap KeeperTaskPrivate::calculate_task_state() | 120 | QVariantMap KeeperTaskPrivate::calculate_task_state() |
| 13 | @@ -149,6 +149,24 @@ | |||
| 14 | 149 | Q_EMIT(q_ptr->task_state_changed(state)); | 149 | Q_EMIT(q_ptr->task_state_changed(state)); |
| 15 | 150 | } | 150 | } |
| 16 | 151 | 151 | ||
| 17 | 152 | QVariantMap KeeperTaskPrivate::get_initial_state(KeeperTask::TaskData const &td) | ||
| 18 | 153 | { | ||
| 19 | 154 | QVariantMap ret; | ||
| 20 | 155 | |||
| 21 | 156 | auto const uuid = td.metadata.uuid(); | ||
| 22 | 157 | |||
| 23 | 158 | ret.insert(QStringLiteral("action"), td.action); | ||
| 24 | 159 | |||
| 25 | 160 | // TODO review this when we add the restore tasks. | ||
| 26 | 161 | // TODO we maybe have different fields | ||
| 27 | 162 | ret.insert(QStringLiteral("display-name"), td.metadata.display_name()); | ||
| 28 | 163 | ret.insert(QStringLiteral("speed"), 0); | ||
| 29 | 164 | ret.insert(QStringLiteral("percent-done"), double(0.0)); | ||
| 30 | 165 | ret.insert(QStringLiteral("uuid"), uuid); | ||
| 31 | 166 | |||
| 32 | 167 | return ret; | ||
| 33 | 168 | } | ||
| 34 | 169 | |||
| 35 | 152 | KeeperTask::KeeperTask(TaskData const & task_data, | 170 | KeeperTask::KeeperTask(TaskData const & task_data, |
| 36 | 153 | QSharedPointer<HelperRegistry> const & helper_registry, | 171 | QSharedPointer<HelperRegistry> const & helper_registry, |
| 37 | 154 | QSharedPointer<StorageFrameworkClient> const & storage, | 172 | QSharedPointer<StorageFrameworkClient> const & storage, |
| 38 | @@ -178,3 +196,8 @@ | |||
| 39 | 178 | Q_D(const KeeperTask); | 196 | Q_D(const KeeperTask); |
| 40 | 179 | return d->state(); | 197 | return d->state(); |
| 41 | 180 | } | 198 | } |
| 42 | 199 | |||
| 43 | 200 | QVariantMap KeeperTask::get_initial_state(KeeperTask::TaskData const &td) | ||
| 44 | 201 | { | ||
| 45 | 202 | return KeeperTaskPrivate::get_initial_state(td); | ||
| 46 | 203 | } | ||
| 47 | 181 | 204 | ||
| 48 | === modified file 'src/service/keeper-task.h' | |||
| 49 | --- src/service/keeper-task.h 2016-08-24 11:04:47 +0000 | |||
| 50 | +++ src/service/keeper-task.h 2016-09-06 13:08:57 +0000 | |||
| 51 | @@ -59,6 +59,8 @@ | |||
| 52 | 59 | bool start(); | 59 | bool start(); |
| 53 | 60 | QVariantMap state() const; | 60 | QVariantMap state() const; |
| 54 | 61 | 61 | ||
| 55 | 62 | static QVariantMap get_initial_state(KeeperTask::TaskData const &td); | ||
| 56 | 63 | |||
| 57 | 62 | Q_SIGNALS: | 64 | Q_SIGNALS: |
| 58 | 63 | void task_state_changed(Helper::State state); | 65 | void task_state_changed(Helper::State state); |
| 59 | 64 | void task_socket_ready(int socket_descriptor); | 66 | void task_socket_ready(int socket_descriptor); |
| 60 | 65 | 67 | ||
| 61 | === modified file 'src/service/private/keeper-task_p.h' | |||
| 62 | --- src/service/private/keeper-task_p.h 2016-08-24 11:04:47 +0000 | |||
| 63 | +++ src/service/private/keeper-task_p.h 2016-09-06 13:08:57 +0000 | |||
| 64 | @@ -36,6 +36,8 @@ | |||
| 65 | 36 | QVariantMap state() const; | 36 | QVariantMap state() const; |
| 66 | 37 | void ask_for_storage_framework_socket(quint64 n_bytes); | 37 | void ask_for_storage_framework_socket(quint64 n_bytes); |
| 67 | 38 | 38 | ||
| 68 | 39 | static QVariantMap get_initial_state(KeeperTask::TaskData const &td); | ||
| 69 | 40 | |||
| 70 | 39 | protected: | 41 | protected: |
| 71 | 40 | void set_current_task_action(QString const& action); | 42 | void set_current_task_action(QString const& action); |
| 72 | 41 | void on_helper_percent_done_changed(float percent_done); | 43 | void on_helper_percent_done_changed(float percent_done); |
| 73 | 42 | 44 | ||
| 74 | === modified file 'src/service/task-manager.cpp' | |||
| 75 | --- src/service/task-manager.cpp 2016-08-31 14:56:18 +0000 | |||
| 76 | +++ src/service/task-manager.cpp 2016-09-06 13:08:57 +0000 | |||
| 77 | @@ -79,8 +79,10 @@ | |||
| 78 | 79 | td.type = type; | 79 | td.type = type; |
| 79 | 80 | td.action = QStringLiteral("queued"); // TODO i18n | 80 | td.action = QStringLiteral("queued"); // TODO i18n |
| 80 | 81 | 81 | ||
| 82 | 82 | // update_task_state(td); | 82 | set_initial_task_state(td); |
| 83 | 83 | } | 83 | } |
| 84 | 84 | // notify the initial state once for all tasks | ||
| 85 | 85 | notify_state_changed(); | ||
| 86 | 84 | 86 | ||
| 87 | 85 | start_next_task(); | 87 | start_next_task(); |
| 88 | 86 | } | 88 | } |
| 89 | @@ -222,20 +224,13 @@ | |||
| 90 | 222 | update_task_state(it.value()); | 224 | update_task_state(it.value()); |
| 91 | 223 | } | 225 | } |
| 92 | 224 | 226 | ||
| 107 | 225 | void update_task_state(KeeperTask::KeeperTask::TaskData& td) | 227 | void set_initial_task_state(KeeperTask::KeeperTask::TaskData& td) |
| 108 | 226 | { | 228 | { |
| 109 | 227 | state_[td.metadata.uuid()] = task_->state(); | 229 | state_[td.metadata.uuid()] = KeeperTask::get_initial_state(td); |
| 110 | 228 | 230 | } | |
| 111 | 229 | #if 0 | 231 | |
| 112 | 230 | // FIXME: we don't need this to work correctly for the sprint because Marcus is polling in a loop | 232 | void notify_state_changed() |
| 113 | 231 | // but we will need this in order for him to stop doing that | 233 | { |
| 100 | 232 | |||
| 101 | 233 | // TODO: compare old and new and decide if it's worth emitting a PropertyChanged signal; | ||
| 102 | 234 | // eg don't contribute to dbus noise for minor speed fluctuations | ||
| 103 | 235 | |||
| 104 | 236 | // TODO: this function is called inside a loop when initializing the state | ||
| 105 | 237 | // after start_tasks(), so also ensure we don't have a notify flood here | ||
| 106 | 238 | |||
| 114 | 239 | DBusUtils::notifyPropertyChanged( | 234 | DBusUtils::notifyPropertyChanged( |
| 115 | 240 | QDBusConnection::sessionBus(), | 235 | QDBusConnection::sessionBus(), |
| 116 | 241 | *q_ptr, | 236 | *q_ptr, |
| 117 | @@ -243,7 +238,26 @@ | |||
| 118 | 243 | DBusTypes::KEEPER_USER_INTERFACE, | 238 | DBusTypes::KEEPER_USER_INTERFACE, |
| 119 | 244 | QStringList(QStringLiteral("State")) | 239 | QStringList(QStringLiteral("State")) |
| 120 | 245 | ); | 240 | ); |
| 122 | 246 | #endif | 241 | |
| 123 | 242 | Q_EMIT(q_ptr->state_changed()); | ||
| 124 | 243 | } | ||
| 125 | 244 | |||
| 126 | 245 | void update_task_state(KeeperTask::KeeperTask::TaskData& td) | ||
| 127 | 246 | { | ||
| 128 | 247 | auto task_state = task_->state(); | ||
| 129 | 248 | |||
| 130 | 249 | // avoid sending repeated states to minimize the use of the bus | ||
| 131 | 250 | if (task_state != state_[td.metadata.uuid()] && !task_state.isEmpty()) | ||
| 132 | 251 | { | ||
| 133 | 252 | state_[td.metadata.uuid()] = task_state; | ||
| 134 | 253 | |||
| 135 | 254 | // FIXME: we don't need this to work correctly for the sprint because Marcus is polling in a loop | ||
| 136 | 255 | // but we will need this in order for him to stop doing that | ||
| 137 | 256 | |||
| 138 | 257 | // TODO: compare old and new and decide if it's worth emitting a PropertyChanged signal; | ||
| 139 | 258 | // eg don't contribute to dbus noise for minor speed fluctuations | ||
| 140 | 259 | notify_state_changed(); | ||
| 141 | 260 | } | ||
| 142 | 247 | } | 261 | } |
| 143 | 248 | 262 | ||
| 144 | 249 | void set_current_task_action(QString const& action) | 263 | void set_current_task_action(QString const& action) |
| 145 | 250 | 264 | ||
| 146 | === modified file 'src/service/task-manager.h' | |||
| 147 | --- src/service/task-manager.h 2016-08-24 11:04:47 +0000 | |||
| 148 | +++ src/service/task-manager.h 2016-09-06 13:08:57 +0000 | |||
| 149 | @@ -46,6 +46,10 @@ | |||
| 150 | 46 | 46 | ||
| 151 | 47 | Q_DISABLE_COPY(TaskManager) | 47 | Q_DISABLE_COPY(TaskManager) |
| 152 | 48 | 48 | ||
| 153 | 49 | Q_PROPERTY(QVariantDictMap State | ||
| 154 | 50 | READ get_state | ||
| 155 | 51 | NOTIFY state_changed) | ||
| 156 | 52 | |||
| 157 | 49 | void start_tasks(QStringList const & task_uuids); | 53 | void start_tasks(QStringList const & task_uuids); |
| 158 | 50 | 54 | ||
| 159 | 51 | QVariantDictMap get_state() const; | 55 | QVariantDictMap get_state() const; |
| 160 | @@ -54,6 +58,7 @@ | |||
| 161 | 54 | 58 | ||
| 162 | 55 | Q_SIGNALS: | 59 | Q_SIGNALS: |
| 163 | 56 | void socket_ready(int reply); | 60 | void socket_ready(int reply); |
| 164 | 61 | void state_changed(); | ||
| 165 | 57 | 62 | ||
| 166 | 58 | private: | 63 | private: |
| 167 | 59 | QScopedPointer<TaskManagerPrivate> const d_ptr; | 64 | QScopedPointer<TaskManagerPrivate> const d_ptr; |
| 168 | 60 | 65 | ||
| 169 | === modified file 'src/util/dbus-utils.cpp' | |||
| 170 | --- src/util/dbus-utils.cpp 2016-05-26 21:33:18 +0000 | |||
| 171 | +++ src/util/dbus-utils.cpp 2016-09-06 13:08:57 +0000 | |||
| 172 | @@ -65,7 +65,12 @@ | |||
| 173 | 65 | signal << it.key().second; | 65 | signal << it.key().second; |
| 174 | 66 | // Changed properties (name, value) | 66 | // Changed properties (name, value) |
| 175 | 67 | signal << it.value().second; | 67 | signal << it.value().second; |
| 177 | 68 | signal << QStringList(); | 68 | QStringList properties_changed; |
| 178 | 69 | for (auto iter_props = it.value().second.begin(); iter_props != it.value().second.end(); ++iter_props) | ||
| 179 | 70 | { | ||
| 180 | 71 | properties_changed << iter_props.key(); | ||
| 181 | 72 | } | ||
| 182 | 73 | signal << properties_changed; | ||
| 183 | 69 | // Connection | 74 | // Connection |
| 184 | 70 | it.value().first.send(signal); | 75 | it.value().first.send(signal); |
| 185 | 71 | } | 76 | } |
| 186 | 72 | 77 | ||
| 187 | === modified file 'tests/CMakeLists.txt' | |||
| 188 | --- tests/CMakeLists.txt 2016-08-31 14:40:50 +0000 | |||
| 189 | +++ tests/CMakeLists.txt 2016-09-06 13:08:57 +0000 | |||
| 190 | @@ -99,6 +99,7 @@ | |||
| 191 | 99 | add_subdirectory(utils) | 99 | add_subdirectory(utils) |
| 192 | 100 | add_subdirectory(fakes) | 100 | add_subdirectory(fakes) |
| 193 | 101 | add_subdirectory(integration) | 101 | add_subdirectory(integration) |
| 194 | 102 | add_subdirectory(qdbus-stubs) | ||
| 195 | 102 | 103 | ||
| 196 | 103 | set( | 104 | set( |
| 197 | 104 | COVERAGE_TEST_TARGETS | 105 | COVERAGE_TEST_TARGETS |
| 198 | 105 | 106 | ||
| 199 | === modified file 'tests/integration/helpers/CMakeLists.txt' | |||
| 200 | --- tests/integration/helpers/CMakeLists.txt 2016-08-30 12:50:46 +0000 | |||
| 201 | +++ tests/integration/helpers/CMakeLists.txt 2016-09-06 13:08:57 +0000 | |||
| 202 | @@ -23,6 +23,7 @@ | |||
| 203 | 23 | ${UAL_INCLUDE_DIRS} | 23 | ${UAL_INCLUDE_DIRS} |
| 204 | 24 | ${PROP-CPP_INCLUDE_DIRS} | 24 | ${PROP-CPP_INCLUDE_DIRS} |
| 205 | 25 | ${HELPERS_TEST_DEPS_INCLUDE_DIRS} | 25 | ${HELPERS_TEST_DEPS_INCLUDE_DIRS} |
| 206 | 26 | "${CMAKE_BINARY_DIR}/tests/qdbus-stubs" | ||
| 207 | 26 | ) | 27 | ) |
| 208 | 27 | 28 | ||
| 209 | 28 | set( | 29 | set( |
| 210 | @@ -48,6 +49,7 @@ | |||
| 211 | 48 | ${HELPERS_TEST} | 49 | ${HELPERS_TEST} |
| 212 | 49 | ${HELPERS_TEST_DEPS_LDFLAGS} | 50 | ${HELPERS_TEST_DEPS_LDFLAGS} |
| 213 | 50 | ${INTEGRATION_TEST_LIBRARIES} | 51 | ${INTEGRATION_TEST_LIBRARIES} |
| 214 | 52 | qdbus-stubs-tests | ||
| 215 | 51 | Qt5::Core | 53 | Qt5::Core |
| 216 | 52 | Qt5::DBus | 54 | Qt5::DBus |
| 217 | 53 | Qt5::Test | 55 | Qt5::Test |
| 218 | @@ -113,6 +115,7 @@ | |||
| 219 | 113 | ${HELPERS_TEST_FAILURE} | 115 | ${HELPERS_TEST_FAILURE} |
| 220 | 114 | ${HELPERS_TEST_DEPS_LDFLAGS} | 116 | ${HELPERS_TEST_DEPS_LDFLAGS} |
| 221 | 115 | ${INTEGRATION_TEST_LIBRARIES} | 117 | ${INTEGRATION_TEST_LIBRARIES} |
| 222 | 118 | qdbus-stubs-tests | ||
| 223 | 116 | Qt5::Core | 119 | Qt5::Core |
| 224 | 117 | Qt5::DBus | 120 | Qt5::DBus |
| 225 | 118 | Qt5::Test | 121 | Qt5::Test |
| 226 | 119 | 122 | ||
| 227 | === modified file 'tests/integration/helpers/helpers-test-failure.cpp' | |||
| 228 | --- tests/integration/helpers/helpers-test-failure.cpp 2016-09-01 12:55:19 +0000 | |||
| 229 | +++ tests/integration/helpers/helpers-test-failure.cpp 2016-09-06 13:08:57 +0000 | |||
| 230 | @@ -67,11 +67,26 @@ | |||
| 231 | 67 | QFile helper_mark(SIMPLE_HELPER_MARK_FILE_PATH); | 67 | QFile helper_mark(SIMPLE_HELPER_MARK_FILE_PATH); |
| 232 | 68 | qDebug() << "Helper mark exists before calling StartBackup..." << helper_mark.exists(); | 68 | qDebug() << "Helper mark exists before calling StartBackup..." << helper_mark.exists(); |
| 233 | 69 | 69 | ||
| 234 | 70 | QSharedPointer<DBusPropertiesInterface> properties_interface(new DBusPropertiesInterface( | ||
| 235 | 71 | DBusTypes::KEEPER_SERVICE, | ||
| 236 | 72 | DBusTypes::KEEPER_USER_PATH, | ||
| 237 | 73 | dbus_test_runner.sessionConnection() | ||
| 238 | 74 | ) ); | ||
| 239 | 75 | |||
| 240 | 76 | ASSERT_TRUE(properties_interface->isValid()) << qPrintable(QDBusConnection::sessionBus().lastError().message()); | ||
| 241 | 77 | |||
| 242 | 78 | QSignalSpy spy(properties_interface.data(),&DBusPropertiesInterface::PropertiesChanged); | ||
| 243 | 79 | |||
| 244 | 70 | // Now we know the music folder uuid, let's start the backup for it. | 80 | // Now we know the music folder uuid, let's start the backup for it. |
| 245 | 71 | QDBusReply<void> backup_reply = user_iface->call("StartBackup", QStringList{user_folder_uuid}); | 81 | QDBusReply<void> backup_reply = user_iface->call("StartBackup", QStringList{user_folder_uuid}); |
| 246 | 72 | ASSERT_TRUE(backup_reply.isValid()) << qPrintable(dbus_test_runner.sessionConnection().lastError().message()); | 82 | ASSERT_TRUE(backup_reply.isValid()) << qPrintable(dbus_test_runner.sessionConnection().lastError().message()); |
| 247 | 73 | 83 | ||
| 249 | 74 | // wait until all the tasks have the action state "failed" | 84 | // waits until all tasks are complete, recording PropertiesChanged signals |
| 250 | 85 | // and checks all the recorded values | ||
| 251 | 86 | EXPECT_TRUE(capture_and_check_state_until_all_tasks_complete(spy, {user_folder_uuid}, "failed")); | ||
| 252 | 87 | |||
| 253 | 88 | // wait until all the tasks have the action state "complete" | ||
| 254 | 89 | // this one uses pooling so it should just call Get once | ||
| 255 | 75 | EXPECT_TRUE(wait_for_all_tasks_have_action_state({user_folder_uuid}, "failed", user_iface)); | 90 | EXPECT_TRUE(wait_for_all_tasks_have_action_state({user_folder_uuid}, "failed", user_iface)); |
| 256 | 76 | 91 | ||
| 257 | 77 | // check that the content of the file is the expected | 92 | // check that the content of the file is the expected |
| 258 | 78 | 93 | ||
| 259 | === modified file 'tests/integration/helpers/helpers-test.cc' | |||
| 260 | --- tests/integration/helpers/helpers-test.cc 2016-09-01 12:55:19 +0000 | |||
| 261 | +++ tests/integration/helpers/helpers-test.cc 2016-09-06 13:08:57 +0000 | |||
| 262 | @@ -104,12 +104,26 @@ | |||
| 263 | 104 | ASSERT_FALSE(user_folder_uuid_2.isEmpty()); | 104 | ASSERT_FALSE(user_folder_uuid_2.isEmpty()); |
| 264 | 105 | qDebug() << "User folder 2 UUID is:" << user_folder_uuid_2; | 105 | qDebug() << "User folder 2 UUID is:" << user_folder_uuid_2; |
| 265 | 106 | 106 | ||
| 266 | 107 | QSharedPointer<DBusPropertiesInterface> properties_interface(new DBusPropertiesInterface( | ||
| 267 | 108 | DBusTypes::KEEPER_SERVICE, | ||
| 268 | 109 | DBusTypes::KEEPER_USER_PATH, | ||
| 269 | 110 | dbus_test_runner.sessionConnection() | ||
| 270 | 111 | ) ); | ||
| 271 | 112 | |||
| 272 | 113 | ASSERT_TRUE(properties_interface->isValid()) << qPrintable(QDBusConnection::sessionBus().lastError().message()); | ||
| 273 | 114 | |||
| 274 | 115 | QSignalSpy spy(properties_interface.data(),&DBusPropertiesInterface::PropertiesChanged); | ||
| 275 | 107 | 116 | ||
| 276 | 108 | // Now we know the music folder uuid, let's start the backup for it. | 117 | // Now we know the music folder uuid, let's start the backup for it. |
| 277 | 109 | QDBusReply<void> backup_reply = user_iface->call("StartBackup", QStringList{user_folder_uuid, user_folder_uuid_2}); | 118 | QDBusReply<void> backup_reply = user_iface->call("StartBackup", QStringList{user_folder_uuid, user_folder_uuid_2}); |
| 278 | 110 | ASSERT_TRUE(backup_reply.isValid()) << qPrintable(dbus_test_runner.sessionConnection().lastError().message()); | 119 | ASSERT_TRUE(backup_reply.isValid()) << qPrintable(dbus_test_runner.sessionConnection().lastError().message()); |
| 279 | 111 | 120 | ||
| 280 | 121 | // waits until all tasks are complete, recording PropertiesChanged signals | ||
| 281 | 122 | // and checks all the recorded values | ||
| 282 | 123 | EXPECT_TRUE(capture_and_check_state_until_all_tasks_complete(spy, {user_folder_uuid, user_folder_uuid_2}, "complete")); | ||
| 283 | 124 | |||
| 284 | 112 | // wait until all the tasks have the action state "complete" | 125 | // wait until all the tasks have the action state "complete" |
| 285 | 126 | // this one uses pooling so it should just call Get once | ||
| 286 | 113 | EXPECT_TRUE(wait_for_all_tasks_have_action_state({user_folder_uuid, user_folder_uuid_2}, "complete", user_iface)); | 127 | EXPECT_TRUE(wait_for_all_tasks_have_action_state({user_folder_uuid, user_folder_uuid_2}, "complete", user_iface)); |
| 287 | 114 | 128 | ||
| 288 | 115 | // check that the content of the file is the expected | 129 | // check that the content of the file is the expected |
| 289 | 116 | 130 | ||
| 290 | === modified file 'tests/integration/helpers/test-helpers-base.cpp' | |||
| 291 | --- tests/integration/helpers/test-helpers-base.cpp 2016-08-31 14:48:23 +0000 | |||
| 292 | +++ tests/integration/helpers/test-helpers-base.cpp 2016-09-06 13:08:57 +0000 | |||
| 293 | @@ -26,6 +26,242 @@ | |||
| 294 | 26 | using namespace QtDBusTest; | 26 | using namespace QtDBusTest; |
| 295 | 27 | using namespace QtDBusMock; | 27 | using namespace QtDBusMock; |
| 296 | 28 | 28 | ||
| 297 | 29 | /// | ||
| 298 | 30 | /// State helpers | ||
| 299 | 31 | // | ||
| 300 | 32 | |||
| 301 | 33 | bool qvariant_to_map(QVariant const& variant, QVariantMap& map) | ||
| 302 | 34 | { | ||
| 303 | 35 | if (variant.type() == QMetaType::QVariantMap) | ||
| 304 | 36 | { | ||
| 305 | 37 | map = variant.toMap(); | ||
| 306 | 38 | return true; | ||
| 307 | 39 | } | ||
| 308 | 40 | qWarning() << Q_FUNC_INFO << ": Could not convert variant to QVariantMap. Variant received has type " << variant.typeName(); | ||
| 309 | 41 | |||
| 310 | 42 | return false; | ||
| 311 | 43 | } | ||
| 312 | 44 | |||
| 313 | 45 | bool qdbus_argument_to_variant_dict_map(QVariant const& variant, QVariantDictMap& map) | ||
| 314 | 46 | { | ||
| 315 | 47 | if (variant.canConvert<QDBusArgument>()) | ||
| 316 | 48 | { | ||
| 317 | 49 | QDBusArgument value(variant.value<QDBusArgument>()); | ||
| 318 | 50 | if (value.currentType() == QDBusArgument::MapType) | ||
| 319 | 51 | { | ||
| 320 | 52 | value >> map; | ||
| 321 | 53 | return true; | ||
| 322 | 54 | } | ||
| 323 | 55 | else | ||
| 324 | 56 | { | ||
| 325 | 57 | qWarning() << Q_FUNC_INFO << ": Could not convert variant to QVariantDictMap. Variant received has type " << value.currentType(); | ||
| 326 | 58 | } | ||
| 327 | 59 | } | ||
| 328 | 60 | else | ||
| 329 | 61 | { | ||
| 330 | 62 | qWarning() << Q_FUNC_INFO << ": Could not convert variant to QDBusArgument."; | ||
| 331 | 63 | } | ||
| 332 | 64 | return false; | ||
| 333 | 65 | } | ||
| 334 | 66 | |||
| 335 | 67 | bool get_property_qvariant_dict_map(QString const & property, QVariant const &variant, QVariantDictMap & map) | ||
| 336 | 68 | { | ||
| 337 | 69 | QVariantMap properties_map; | ||
| 338 | 70 | if (!qvariant_to_map(variant, properties_map)) | ||
| 339 | 71 | { | ||
| 340 | 72 | qWarning() << Q_FUNC_INFO << ": Error converting variant in PropertiesChanged signal to QVariantMap"; | ||
| 341 | 73 | return false; | ||
| 342 | 74 | } | ||
| 343 | 75 | |||
| 344 | 76 | auto iter = properties_map.find(property); | ||
| 345 | 77 | if (iter == properties_map.end()) | ||
| 346 | 78 | { | ||
| 347 | 79 | qWarning() << Q_FUNC_INFO << ": Property [" << property << "] was not found in PropertiesChanged"; | ||
| 348 | 80 | return false; | ||
| 349 | 81 | } | ||
| 350 | 82 | |||
| 351 | 83 | if(!qdbus_argument_to_variant_dict_map((*iter), map)) | ||
| 352 | 84 | { | ||
| 353 | 85 | qWarning() << Q_FUNC_INFO << ": Error converting property [" << property << "] to QVariantDictMap"; | ||
| 354 | 86 | return false; | ||
| 355 | 87 | } | ||
| 356 | 88 | |||
| 357 | 89 | return true; | ||
| 358 | 90 | } | ||
| 359 | 91 | |||
| 360 | 92 | bool all_tasks_has_state(QMap<QString, QString> const & tasks_state, QString const & state) | ||
| 361 | 93 | { | ||
| 362 | 94 | for (auto iter = tasks_state.begin(); iter != tasks_state.end(); ++iter ) | ||
| 363 | 95 | { | ||
| 364 | 96 | if ((*iter) != state) | ||
| 365 | 97 | { | ||
| 366 | 98 | return false; | ||
| 367 | 99 | } | ||
| 368 | 100 | } | ||
| 369 | 101 | return true; | ||
| 370 | 102 | } | ||
| 371 | 103 | |||
| 372 | 104 | bool get_task_property(QString const &property, QVariantMap const &values, QVariant &value) | ||
| 373 | 105 | { | ||
| 374 | 106 | auto iter = values.find(property); | ||
| 375 | 107 | if (iter == values.end()) | ||
| 376 | 108 | { | ||
| 377 | 109 | qWarning() << Q_FUNC_INFO << ": Property [" << property << "] was not found."; | ||
| 378 | 110 | return false; | ||
| 379 | 111 | } | ||
| 380 | 112 | value = (*iter); | ||
| 381 | 113 | return true; | ||
| 382 | 114 | } | ||
| 383 | 115 | |||
| 384 | 116 | bool analyze_task_percentage_values(QString const & uuid, QList<QVariantMap> const & recorded_values) | ||
| 385 | 117 | { | ||
| 386 | 118 | double previous_percentage = -1.0; | ||
| 387 | 119 | for (auto iter = recorded_values.begin(); iter != recorded_values.end(); ++iter) | ||
| 388 | 120 | { | ||
| 389 | 121 | QVariant percentage; | ||
| 390 | 122 | if (!get_task_property("percent-done", (*iter), percentage)) | ||
| 391 | 123 | { | ||
| 392 | 124 | qWarning() << Q_FUNC_INFO << ": Percentage was not found for task: " << uuid; | ||
| 393 | 125 | return false; | ||
| 394 | 126 | } | ||
| 395 | 127 | bool ok_double; | ||
| 396 | 128 | auto percentage_double = percentage.toDouble(&ok_double); | ||
| 397 | 129 | if (!ok_double) | ||
| 398 | 130 | { | ||
| 399 | 131 | qWarning() << Q_FUNC_INFO << ": Error converting percent-done to double for uuid: " << uuid << ". State: " << (*iter); | ||
| 400 | 132 | return false; | ||
| 401 | 133 | } | ||
| 402 | 134 | if (percentage_double < previous_percentage) | ||
| 403 | 135 | { | ||
| 404 | 136 | qWarning() << Q_FUNC_INFO << ": Eror, current percentage is less than previous: current=" << percentage_double << ", previous=" << previous_percentage; | ||
| 405 | 137 | return false; | ||
| 406 | 138 | } | ||
| 407 | 139 | previous_percentage = percentage_double; | ||
| 408 | 140 | } | ||
| 409 | 141 | return true; | ||
| 410 | 142 | } | ||
| 411 | 143 | |||
| 412 | 144 | bool check_valid_action_state_step(QString const &previous, QString const ¤t) | ||
| 413 | 145 | { | ||
| 414 | 146 | if (current == "queued") | ||
| 415 | 147 | { | ||
| 416 | 148 | return previous == "none" || previous == "queued"; | ||
| 417 | 149 | } | ||
| 418 | 150 | else if (current == "saving") | ||
| 419 | 151 | { | ||
| 420 | 152 | return previous == "saving" || previous == "queued"; | ||
| 421 | 153 | } | ||
| 422 | 154 | else if (current == "finishing") | ||
| 423 | 155 | { | ||
| 424 | 156 | return previous == "finishing" || previous == "saving"; | ||
| 425 | 157 | } | ||
| 426 | 158 | else if (current == "complete") | ||
| 427 | 159 | { | ||
| 428 | 160 | // we may pass from "saving" to "complete" if we don't have enough time | ||
| 429 | 161 | // to emit the "finishing" state change | ||
| 430 | 162 | return previous == "complete" || previous == "finishing" || previous == "saving"; | ||
| 431 | 163 | } | ||
| 432 | 164 | else if (current == "failed") | ||
| 433 | 165 | { | ||
| 434 | 166 | // we can get to failed from any state except complete | ||
| 435 | 167 | return previous != "complete"; | ||
| 436 | 168 | } | ||
| 437 | 169 | else | ||
| 438 | 170 | { | ||
| 439 | 171 | // for possible new states, please add your code here | ||
| 440 | 172 | qWarning() << "Unhandled state: " << current; | ||
| 441 | 173 | return false; | ||
| 442 | 174 | } | ||
| 443 | 175 | } | ||
| 444 | 176 | |||
| 445 | 177 | bool analyze_task_action_values(QString const & uuid, QList<QVariantMap> const & recorded_values) | ||
| 446 | 178 | { | ||
| 447 | 179 | QString previous_action = "none"; | ||
| 448 | 180 | for (auto iter = recorded_values.begin(); iter != recorded_values.end(); ++iter) | ||
| 449 | 181 | { | ||
| 450 | 182 | QVariant action; | ||
| 451 | 183 | if (!get_task_property("action", (*iter), action)) | ||
| 452 | 184 | { | ||
| 453 | 185 | qWarning() << Q_FUNC_INFO << ": Action was not found for task: " << uuid; | ||
| 454 | 186 | return false; | ||
| 455 | 187 | } | ||
| 456 | 188 | auto current_action = action.toString(); | ||
| 457 | 189 | |||
| 458 | 190 | if (!check_valid_action_state_step(previous_action, action.toString())) | ||
| 459 | 191 | { | ||
| 460 | 192 | qWarning() << Q_FUNC_INFO << ": Bad action state step: previous state=" << previous_action << ", current=" << action.toString(); | ||
| 461 | 193 | return false; | ||
| 462 | 194 | } | ||
| 463 | 195 | previous_action = action.toString(); | ||
| 464 | 196 | } | ||
| 465 | 197 | return true; | ||
| 466 | 198 | } | ||
| 467 | 199 | |||
| 468 | 200 | bool analyze_task_display_name_values(QString const & uuid, QList<QVariantMap> const & recorded_values) | ||
| 469 | 201 | { | ||
| 470 | 202 | QString previous_name; | ||
| 471 | 203 | // check that the display name never changes between recorded states | ||
| 472 | 204 | for (auto iter = recorded_values.begin(); iter != recorded_values.end(); ++iter) | ||
| 473 | 205 | { | ||
| 474 | 206 | QVariant name; | ||
| 475 | 207 | if (!get_task_property("display-name", (*iter), name)) | ||
| 476 | 208 | { | ||
| 477 | 209 | qWarning() << Q_FUNC_INFO << ": display-name was not found for task: " << uuid; | ||
| 478 | 210 | return false; | ||
| 479 | 211 | } | ||
| 480 | 212 | auto current_name = name.toString(); | ||
| 481 | 213 | |||
| 482 | 214 | if (previous_name.isEmpty()) | ||
| 483 | 215 | { | ||
| 484 | 216 | previous_name = name.toString(); | ||
| 485 | 217 | } | ||
| 486 | 218 | else if(name.toString() != previous_name) | ||
| 487 | 219 | { | ||
| 488 | 220 | qWarning() << Q_FUNC_INFO << "ERROR: display-name for uuid: " << uuid << " changed from " << previous_name << " to " << name.toString(); | ||
| 489 | 221 | return false; | ||
| 490 | 222 | } | ||
| 491 | 223 | } | ||
| 492 | 224 | return true; | ||
| 493 | 225 | } | ||
| 494 | 226 | |||
| 495 | 227 | bool analyze_tasks_values(QMap<QString, QList<QVariantMap>> const &uuids_state) | ||
| 496 | 228 | { | ||
| 497 | 229 | for (auto iter = uuids_state.begin(); iter != uuids_state.end(); ++iter) | ||
| 498 | 230 | { | ||
| 499 | 231 | if(!analyze_task_display_name_values(iter.key(), (*iter))) | ||
| 500 | 232 | return false; | ||
| 501 | 233 | if(!analyze_task_action_values(iter.key(), (*iter))) | ||
| 502 | 234 | return false; | ||
| 503 | 235 | if(!analyze_task_percentage_values(iter.key(), (*iter))) | ||
| 504 | 236 | return false; | ||
| 505 | 237 | } | ||
| 506 | 238 | return true; | ||
| 507 | 239 | } | ||
| 508 | 240 | |||
| 509 | 241 | bool verify_signal_interface_and_invalidated_properties(QVariant const &interface, | ||
| 510 | 242 | QVariant const &invalidated_properties, | ||
| 511 | 243 | QString const & expected_interface, | ||
| 512 | 244 | QString const & expected_property) | ||
| 513 | 245 | { | ||
| 514 | 246 | auto props_list = invalidated_properties.toStringList(); | ||
| 515 | 247 | if (!props_list.contains(expected_property)) | ||
| 516 | 248 | { | ||
| 517 | 249 | qWarning() << Q_FUNC_INFO << "ERROR: PropertiesChanged signal did not include the property: " << expected_property << " as the ones invalidated"; | ||
| 518 | 250 | return false; | ||
| 519 | 251 | } | ||
| 520 | 252 | |||
| 521 | 253 | if (interface.toString() != expected_interface) | ||
| 522 | 254 | { | ||
| 523 | 255 | qWarning() << Q_FUNC_INFO << "ERROR: Interface: [" << interface.toString() << "] is not valid. Expecting: [" << expected_interface << "]"; | ||
| 524 | 256 | return false; | ||
| 525 | 257 | } | ||
| 526 | 258 | return true; | ||
| 527 | 259 | } | ||
| 528 | 260 | |||
| 529 | 261 | /// | ||
| 530 | 262 | /// | ||
| 531 | 263 | /// | ||
| 532 | 264 | |||
| 533 | 29 | TestHelpersBase::TestHelpersBase() | 265 | TestHelpersBase::TestHelpersBase() |
| 534 | 30 | :dbus_mock(dbus_test_runner) | 266 | :dbus_mock(dbus_test_runner) |
| 535 | 31 | { | 267 | { |
| 536 | @@ -63,7 +299,13 @@ | |||
| 537 | 63 | throw; | 299 | throw; |
| 538 | 64 | } | 300 | } |
| 539 | 65 | 301 | ||
| 541 | 66 | system("dbus-send --session --dest=org.freedesktop.DBus --type=method_call --print-reply /org/freedesktop/DBus org.freedesktop.DBus.ListNames"); | 302 | #if 0 |
| 542 | 303 | // Enable this to get extra dbus information. | ||
| 543 | 304 | if (!start_dbus_monitor()) | ||
| 544 | 305 | { | ||
| 545 | 306 | throw std::logic_error("Error starting dbus-monitor process."); | ||
| 546 | 307 | } | ||
| 547 | 308 | #endif | ||
| 548 | 67 | } | 309 | } |
| 549 | 68 | 310 | ||
| 550 | 69 | void TestHelpersBase::SetUp() | 311 | void TestHelpersBase::SetUp() |
| 551 | @@ -243,12 +485,12 @@ | |||
| 552 | 243 | : -1; | 485 | : -1; |
| 553 | 244 | } | 486 | } |
| 554 | 245 | 487 | ||
| 556 | 246 | bool TestHelpersBase::wait_for_all_tasks_have_action_state(QStringList const & uuids, QString const & action_state, QSharedPointer<DBusInterfaceKeeperUser> const & keeper_user_iface, int max_timeout) | 488 | bool TestHelpersBase::wait_for_all_tasks_have_action_state(QStringList const & uuids, QString const & action_state, QSharedPointer<DBusInterfaceKeeperUser> const & keeper_user_iface, int max_timeout_msec) |
| 557 | 247 | { | 489 | { |
| 558 | 248 | QElapsedTimer timer; | 490 | QElapsedTimer timer; |
| 559 | 249 | timer.start(); | 491 | timer.start(); |
| 560 | 250 | bool finished = false; | 492 | bool finished = false; |
| 562 | 251 | while (!timer.hasExpired(max_timeout) && !finished) | 493 | while (!timer.hasExpired(max_timeout_msec) && !finished) |
| 563 | 252 | { | 494 | { |
| 564 | 253 | auto state = keeper_user_iface->state(); | 495 | auto state = keeper_user_iface->state(); |
| 565 | 254 | auto all_helpers_finished = true; | 496 | auto all_helpers_finished = true; |
| 566 | @@ -278,6 +520,98 @@ | |||
| 567 | 278 | return (*iter_props).toString() == action_state; | 520 | return (*iter_props).toString() == action_state; |
| 568 | 279 | } | 521 | } |
| 569 | 280 | 522 | ||
| 570 | 523 | bool TestHelpersBase::capture_and_check_state_until_all_tasks_complete(QSignalSpy & spy, QStringList const & uuids, QString const & action_state, int max_timeout_msec) | ||
| 571 | 524 | { | ||
| 572 | 525 | QMap<QString, QList<QVariantMap>> uuids_state; | ||
| 573 | 526 | QMap<QString, QString> uuids_current_state; | ||
| 574 | 527 | |||
| 575 | 528 | // initialize the current state map to wait for all expected uuids | ||
| 576 | 529 | for (auto const& uuid : uuids) | ||
| 577 | 530 | { | ||
| 578 | 531 | uuids_current_state[uuid] = "none"; | ||
| 579 | 532 | uuids_state[uuid] = QList<QVariantMap>(); | ||
| 580 | 533 | } | ||
| 581 | 534 | |||
| 582 | 535 | QElapsedTimer timer; | ||
| 583 | 536 | timer.start(); | ||
| 584 | 537 | bool finished = false; | ||
| 585 | 538 | while (!timer.hasExpired(max_timeout_msec) && !finished) | ||
| 586 | 539 | { | ||
| 587 | 540 | spy.wait(); | ||
| 588 | 541 | |||
| 589 | 542 | qDebug() << "PropertiesChanged SIGNALS RECEIVED: " << spy.count(); | ||
| 590 | 543 | while (spy.count()) | ||
| 591 | 544 | { | ||
| 592 | 545 | auto arguments = spy.takeFirst(); | ||
| 593 | 546 | |||
| 594 | 547 | if (arguments.size() != 3) | ||
| 595 | 548 | { | ||
| 596 | 549 | qWarning() << "Bad number of arguments in PropertiesChanged signal"; | ||
| 597 | 550 | return false; | ||
| 598 | 551 | } | ||
| 599 | 552 | |||
| 600 | 553 | // verify interface and invalidated_properties arguments | ||
| 601 | 554 | if(!verify_signal_interface_and_invalidated_properties(arguments.at(0), arguments.at(2), DBusTypes::KEEPER_USER_INTERFACE, "State")) | ||
| 602 | 555 | { | ||
| 603 | 556 | return false; | ||
| 604 | 557 | } | ||
| 605 | 558 | QVariantDictMap keeper_state; | ||
| 606 | 559 | if (!get_property_qvariant_dict_map("State", arguments.at(1), keeper_state)) | ||
| 607 | 560 | { | ||
| 608 | 561 | return false; | ||
| 609 | 562 | } | ||
| 610 | 563 | for (auto iter = keeper_state.begin(); iter != keeper_state.end(); ++iter ) | ||
| 611 | 564 | { | ||
| 612 | 565 | // check for unexpected uuids | ||
| 613 | 566 | if (!uuids.contains(iter.key())) | ||
| 614 | 567 | { | ||
| 615 | 568 | qWarning() << "State contains unexpected uuid: " << iter.key(); | ||
| 616 | 569 | return false; | ||
| 617 | 570 | } | ||
| 618 | 571 | |||
| 619 | 572 | QVariantMap task_state; | ||
| 620 | 573 | if (!qvariant_to_map((*iter), task_state)) | ||
| 621 | 574 | { | ||
| 622 | 575 | qWarning() << "Error converting second argument in PropertiesChanged signal to QVariantMap for uuid: " << iter.key(); | ||
| 623 | 576 | return false; | ||
| 624 | 577 | } | ||
| 625 | 578 | qDebug() << "State for uuid: " << iter.key() << " : " << task_state; | ||
| 626 | 579 | |||
| 627 | 580 | QVariant action; | ||
| 628 | 581 | if (get_task_property("action", task_state, action)) | ||
| 629 | 582 | { | ||
| 630 | 583 | if (action.type() != QVariant::String) | ||
| 631 | 584 | { | ||
| 632 | 585 | qWarning() << "Property [action] is not a string"; | ||
| 633 | 586 | return false; | ||
| 634 | 587 | } | ||
| 635 | 588 | // store the current action state | ||
| 636 | 589 | uuids_current_state[iter.key()] = action.toString(); | ||
| 637 | 590 | |||
| 638 | 591 | bool store = true; | ||
| 639 | 592 | if (action.toString() == action_state) | ||
| 640 | 593 | { | ||
| 641 | 594 | // check if it worths storing this new event | ||
| 642 | 595 | store = uuids_state[iter.key()].last() != task_state; | ||
| 643 | 596 | } | ||
| 644 | 597 | if (store) | ||
| 645 | 598 | { | ||
| 646 | 599 | // store the current state for later inspection | ||
| 647 | 600 | uuids_state[iter.key()].push_back(task_state); | ||
| 648 | 601 | } | ||
| 649 | 602 | } | ||
| 650 | 603 | } | ||
| 651 | 604 | } | ||
| 652 | 605 | finished = all_tasks_has_state(uuids_current_state, action_state); | ||
| 653 | 606 | if (finished) | ||
| 654 | 607 | { | ||
| 655 | 608 | qDebug() << "ALL TASKS FINISHED ========================================="; | ||
| 656 | 609 | } | ||
| 657 | 610 | } | ||
| 658 | 611 | // check for the recorded values | ||
| 659 | 612 | return analyze_tasks_values(uuids_state); | ||
| 660 | 613 | } | ||
| 661 | 614 | |||
| 662 | 281 | QString TestHelpersBase::get_uuid_for_xdg_folder_path(QString const &path, QVariantDictMap const & choices) const | 615 | QString TestHelpersBase::get_uuid_for_xdg_folder_path(QString const &path, QVariantDictMap const & choices) const |
| 663 | 282 | { | 616 | { |
| 664 | 283 | for(auto iter = choices.begin(); iter != choices.end(); ++iter) | 617 | for(auto iter = choices.begin(); iter != choices.end(); ++iter) |
| 665 | @@ -296,3 +630,26 @@ | |||
| 666 | 296 | 630 | ||
| 667 | 297 | return QString(); | 631 | return QString(); |
| 668 | 298 | } | 632 | } |
| 669 | 633 | |||
| 670 | 634 | bool TestHelpersBase::start_dbus_monitor() | ||
| 671 | 635 | { | ||
| 672 | 636 | if (!dbus_monitor_process) | ||
| 673 | 637 | { | ||
| 674 | 638 | dbus_monitor_process.reset(new QProcess()); | ||
| 675 | 639 | |||
| 676 | 640 | dbus_monitor_process->setProcessChannelMode(QProcess::ForwardedChannels); | ||
| 677 | 641 | |||
| 678 | 642 | dbus_monitor_process->start("dbus-monitor", QStringList() << "--session"); | ||
| 679 | 643 | if (!dbus_monitor_process->waitForStarted()) | ||
| 680 | 644 | { | ||
| 681 | 645 | qWarning() << "Error, starting dbus-monitor: " << dbus_monitor_process->errorString(); | ||
| 682 | 646 | return false; | ||
| 683 | 647 | } | ||
| 684 | 648 | } | ||
| 685 | 649 | else | ||
| 686 | 650 | { | ||
| 687 | 651 | qWarning() << "Error, dbus-monitor should be called one time per test."; | ||
| 688 | 652 | return false; | ||
| 689 | 653 | } | ||
| 690 | 654 | return true; | ||
| 691 | 655 | } | ||
| 692 | 299 | 656 | ||
| 693 | === modified file 'tests/integration/helpers/test-helpers-base.h' | |||
| 694 | --- tests/integration/helpers/test-helpers-base.h 2016-08-30 12:50:46 +0000 | |||
| 695 | +++ tests/integration/helpers/test-helpers-base.h 2016-09-06 13:08:57 +0000 | |||
| 696 | @@ -22,6 +22,7 @@ | |||
| 697 | 22 | 22 | ||
| 698 | 23 | #include <helper/backup-helper.h> | 23 | #include <helper/backup-helper.h> |
| 699 | 24 | #include <qdbus-stubs/dbus-types.h> | 24 | #include <qdbus-stubs/dbus-types.h> |
| 700 | 25 | #include "DBusPropertiesInterface.h" | ||
| 701 | 25 | #include "qdbus-stubs/keeper_user_interface.h" | 26 | #include "qdbus-stubs/keeper_user_interface.h" |
| 702 | 26 | 27 | ||
| 703 | 27 | #include "tests/fakes/fake-backup-helper.h" | 28 | #include "tests/fakes/fake-backup-helper.h" |
| 704 | @@ -73,6 +74,7 @@ | |||
| 705 | 73 | QtDBusMock::DBusMock dbus_mock; | 74 | QtDBusMock::DBusMock dbus_mock; |
| 706 | 74 | QSharedPointer<QtDBusTest::QProcessDBusService> keeper_service; | 75 | QSharedPointer<QtDBusTest::QProcessDBusService> keeper_service; |
| 707 | 75 | QSharedPointer<QtDBusTest::QProcessDBusService> upstart_service; | 76 | QSharedPointer<QtDBusTest::QProcessDBusService> upstart_service; |
| 708 | 77 | QScopedPointer<QProcess> dbus_monitor_process; | ||
| 709 | 76 | 78 | ||
| 710 | 77 | protected: | 79 | protected: |
| 711 | 78 | void start_tasks(); | 80 | void start_tasks(); |
| 712 | @@ -93,11 +95,15 @@ | |||
| 713 | 93 | 95 | ||
| 714 | 94 | QString get_last_storage_framework_file(); | 96 | QString get_last_storage_framework_file(); |
| 715 | 95 | 97 | ||
| 717 | 96 | bool wait_for_all_tasks_have_action_state(QStringList const & uuids, QString const & action_state, QSharedPointer<DBusInterfaceKeeperUser> const & keeper_user_iface, int max_timeout = 15000); | 98 | bool wait_for_all_tasks_have_action_state(QStringList const & uuids, QString const & action_state, QSharedPointer<DBusInterfaceKeeperUser> const & keeper_user_iface, int max_timeout_msec = 15000); |
| 718 | 97 | 99 | ||
| 719 | 98 | bool check_task_has_action_state(QVariantDictMap const & state, QString const & uuid, QString const & action_state); | 100 | bool check_task_has_action_state(QVariantDictMap const & state, QString const & uuid, QString const & action_state); |
| 720 | 99 | 101 | ||
| 721 | 102 | bool capture_and_check_state_until_all_tasks_complete(QSignalSpy & spy, QStringList const & uuids, QString const & action_state, int max_timeout_msec = 15000); | ||
| 722 | 103 | |||
| 723 | 100 | QString get_uuid_for_xdg_folder_path(QString const &path, QVariantDictMap const & choices) const; | 104 | QString get_uuid_for_xdg_folder_path(QString const &path, QVariantDictMap const & choices) const; |
| 724 | 105 | |||
| 725 | 106 | bool start_dbus_monitor(); | ||
| 726 | 101 | }; | 107 | }; |
| 727 | 102 | 108 | ||
| 728 | 103 | #define EXPECT_ENV(expected, envvars, key) EXPECT_EQ(expected, get_env(envvars, key)) << "for key " << key | 109 | #define EXPECT_ENV(expected, envvars, key) EXPECT_EQ(expected, get_env(envvars, key)) << "for key " << key |
| 729 | 104 | 110 | ||
| 730 | === added directory 'tests/qdbus-stubs' | |||
| 731 | === added file 'tests/qdbus-stubs/CMakeLists.txt' | |||
| 732 | --- tests/qdbus-stubs/CMakeLists.txt 1970-01-01 00:00:00 +0000 | |||
| 733 | +++ tests/qdbus-stubs/CMakeLists.txt 2016-09-06 13:08:57 +0000 | |||
| 734 | @@ -0,0 +1,53 @@ | |||
| 735 | 1 | # Copyright © 2015 Canonical Ltd. | ||
| 736 | 2 | # | ||
| 737 | 3 | # This program is free software: you can redistribute it and/or modify it | ||
| 738 | 4 | # under the terms of the GNU Lesser General Public License version 3, | ||
| 739 | 5 | # as published by the Free Software Foundation. | ||
| 740 | 6 | # | ||
| 741 | 7 | # This program is distributed in the hope that it will be useful, | ||
| 742 | 8 | # but WITHOUT ANY WARRANTY; without even the implied warranty of | ||
| 743 | 9 | # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the | ||
| 744 | 10 | # GNU Lesser General Public License for more details. | ||
| 745 | 11 | # | ||
| 746 | 12 | # You should have received a copy of the GNU Lesser General Public License | ||
| 747 | 13 | # along with this program. If not, see <http://www.gnu.org/licenses/>. | ||
| 748 | 14 | # | ||
| 749 | 15 | # Authors: | ||
| 750 | 16 | # Xavi Garcia <marcus.tomlinson@canonical.com> | ||
| 751 | 17 | |||
| 752 | 18 | # disable compilier warnings in machine-generated code | ||
| 753 | 19 | add_compile_options(-w) | ||
| 754 | 20 | |||
| 755 | 21 | # XML | ||
| 756 | 22 | |||
| 757 | 23 | set( | ||
| 758 | 24 | properties_xml | ||
| 759 | 25 | "org.freedesktop.DBus.Properties.xml" | ||
| 760 | 26 | ) | ||
| 761 | 27 | |||
| 762 | 28 | set_source_files_properties( | ||
| 763 | 29 | "${properties_xml}" | ||
| 764 | 30 | PROPERTIES | ||
| 765 | 31 | NO_NAMESPACE YES | ||
| 766 | 32 | CLASSNAME DBusPropertiesInterface | ||
| 767 | 33 | ) | ||
| 768 | 34 | |||
| 769 | 35 | qt5_add_dbus_interface( | ||
| 770 | 36 | interface_files | ||
| 771 | 37 | ${properties_xml} | ||
| 772 | 38 | DBusPropertiesInterface | ||
| 773 | 39 | ) | ||
| 774 | 40 | |||
| 775 | 41 | # | ||
| 776 | 42 | # | ||
| 777 | 43 | |||
| 778 | 44 | set( | ||
| 779 | 45 | STUBS_LIB | ||
| 780 | 46 | qdbus-stubs-tests | ||
| 781 | 47 | ) | ||
| 782 | 48 | |||
| 783 | 49 | add_library( | ||
| 784 | 50 | ${STUBS_LIB} | ||
| 785 | 51 | STATIC | ||
| 786 | 52 | ${interface_files} | ||
| 787 | 53 | ) | ||
| 788 | 0 | 54 | ||
| 789 | === added file 'tests/qdbus-stubs/org.freedesktop.DBus.Properties.xml' | |||
| 790 | --- tests/qdbus-stubs/org.freedesktop.DBus.Properties.xml 1970-01-01 00:00:00 +0000 | |||
| 791 | +++ tests/qdbus-stubs/org.freedesktop.DBus.Properties.xml 2016-09-06 13:08:57 +0000 | |||
| 792 | @@ -0,0 +1,27 @@ | |||
| 793 | 1 | <!DOCTYPE node PUBLIC "-//freedesktop//DTD D-BUS Object Introspection 1.0//EN" | ||
| 794 | 2 | "http://www.freedesktop.org/standards/dbus/1.0/introspect.dtd"> | ||
| 795 | 3 | <node> | ||
| 796 | 4 | <interface name="org.freedesktop.DBus.Properties"> | ||
| 797 | 5 | <method name="Get"> | ||
| 798 | 6 | <arg type="s" name="interface_name" direction="in"/> | ||
| 799 | 7 | <arg type="s" name="property_name" direction="in"/> | ||
| 800 | 8 | <arg type="v" name="value" direction="out"/> | ||
| 801 | 9 | </method> | ||
| 802 | 10 | <method name="GetAll"> | ||
| 803 | 11 | <arg type="s" name="interface_name" direction="in"/> | ||
| 804 | 12 | <arg type="a{sv}" name="properties" direction="out"/> | ||
| 805 | 13 | <annotation name="org.qtproject.QtDBus.QtTypeName.Out0" value="QVariantMap"/> | ||
| 806 | 14 | </method> | ||
| 807 | 15 | <method name="Set"> | ||
| 808 | 16 | <arg type="s" name="interface_name" direction="in"/> | ||
| 809 | 17 | <arg type="s" name="property_name" direction="in"/> | ||
| 810 | 18 | <arg type="v" name="value" direction="in"/> | ||
| 811 | 19 | </method> | ||
| 812 | 20 | <signal name="PropertiesChanged"> | ||
| 813 | 21 | <arg type="s" name="interface_name"/> | ||
| 814 | 22 | <arg type="a{sv}" name="changed_properties"/> | ||
| 815 | 23 | <annotation name="org.qtproject.QtDBus.QtTypeName.In1" value="QVariantMap"/> | ||
| 816 | 24 | <arg type="as" name="invalidated_properties"/> | ||
| 817 | 25 | </signal> | ||
| 818 | 26 | </interface> | ||
| 819 | 27 | </node> | ||
FAILED: Continuous integration, rev:100
https:/
Executed test runs:
FAILURE: https:/
FAILURE: https:/
Click here to trigger a rebuild:
https:/