|
9 | 9 |
|
10 | 10 | -include_lib("common_test/include/ct.hrl"). |
11 | 11 | -include_lib("amqp_client/include/amqp_client.hrl"). |
| 12 | +-include_lib("rabbitmq_ct_helpers/include/rabbit_assert.hrl"). |
12 | 13 |
|
13 | 14 | -compile(export_all). |
14 | 15 |
|
@@ -109,23 +110,16 @@ storage_deleted_on_vhost_delete(Config) -> |
109 | 110 | Vhost1 = ?config(vhost1, Config), |
110 | 111 | Channel1 = ?config(channel1, Config), |
111 | 112 | Queue1 = declare_durable_queue(Channel1), |
112 | | - FolderSize = get_global_folder_size(Config), |
| 113 | + FolderSize = get_folder_size(Vhost1, Config), |
113 | 114 |
|
114 | 115 | publish_persistent_messages(index, Channel1, Queue1), |
115 | 116 | publish_persistent_messages(store, Channel1, Queue1), |
116 | | - FolderSizeAfterPublish = get_global_folder_size(Config), |
117 | | - |
118 | | - %% Total storage size increased |
119 | | - true = (FolderSize < FolderSizeAfterPublish), |
| 117 | + ?awaitMatch(true, get_folder_size(Vhost1, Config) > FolderSize, 30000), |
120 | 118 |
|
121 | 119 | ok = rabbit_ct_broker_helpers:delete_vhost(Config, Vhost1), |
122 | 120 |
|
123 | | - %% Total memory reduced |
124 | | - FolderSizeAfterDelete = get_global_folder_size(Config), |
125 | | - true = (FolderSizeAfterPublish > FolderSizeAfterDelete), |
126 | | - |
127 | 121 | %% There is no Vhost1 folder |
128 | | - 0 = get_folder_size(Vhost1, Config). |
| 122 | + ?awaitMatch(0, get_folder_size(Vhost1, Config), 30000). |
129 | 123 |
|
130 | 124 |
|
131 | 125 | single_vhost_storage_delete_is_safe(Config) -> |
@@ -192,10 +186,13 @@ folder_size(Dir) -> |
192 | 186 | filelib:fold_files(Dir, ".*", true, |
193 | 187 | fun(F,Acc) -> filelib:file_size(F) + Acc end, 0). |
194 | 188 |
|
| 189 | +<<<<<<< HEAD |
195 | 190 | get_global_folder_size(Config) -> |
196 | 191 | BaseDir = rabbit_ct_broker_helpers:rpc(Config, 0, rabbit_mnesia, dir, []), |
197 | 192 | folder_size(BaseDir). |
198 | 193 |
|
| 194 | +======= |
| 195 | +>>>>>>> 7f07a9c230 (Test: verify just vhost folder, not whole directory) |
199 | 196 | vhost_dir(Vhost, Config) -> |
200 | 197 | rabbit_ct_broker_helpers:rpc(Config, 0, |
201 | 198 | rabbit_vhost, msg_store_dir_path, [Vhost]). |
|
0 commit comments