• Home
  • Features
  • Pricing
  • Docs
  • Announcements
  • Sign In

realm / realm-core / nicola.cabiddu_1040

26 Sep 2023 05:08PM UTC coverage: 91.056% (-1.9%) from 92.915%
nicola.cabiddu_1040

Pull #6766

Evergreen

nicola-cab
several fixes and final client reset algo for collection in mixed
Pull Request #6766: Client Reset for collections in mixed / nested collections

97128 of 178458 branches covered (0.0%)

1524 of 1603 new or added lines in 5 files covered. (95.07%)

4511 existing lines in 109 files now uncovered.

236619 of 259862 relevant lines covered (91.06%)

7169640.31 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

85.04
/src/realm/array_string.cpp
1
/*************************************************************************
2
 *
3
 * Copyright 2016 Realm Inc.
4
 *
5
 * Licensed under the Apache License, Version 2.0 (the "License");
6
 * you may not use this file except in compliance with the License.
7
 * You may obtain a copy of the License at
8
 *
9
 * http://www.apache.org/licenses/LICENSE-2.0
10
 *
11
 * Unless required by applicable law or agreed to in writing, software
12
 * distributed under the License is distributed on an "AS IS" BASIS,
13
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
14
 * See the License for the specific language governing permissions and
15
 * limitations under the License.
16
 *
17
 **************************************************************************/
18

19
#include <realm/array_string.hpp>
20
#include <realm/spec.hpp>
21
#include <realm/mixed.hpp>
22

23
using namespace realm;
24

25
ArrayString::ArrayString(Allocator& a)
26
    : m_alloc(a)
27
{
20,115,033✔
28
    m_arr = new (&m_storage.m_string_short) ArrayStringShort(a, true);
20,115,033✔
29
}
20,115,033✔
30

31
void ArrayString::create()
32
{
367,725✔
33
    static_cast<ArrayStringShort*>(m_arr)->create();
367,725✔
34
}
367,725✔
35

36
void ArrayString::init_from_mem(MemRef mem) noexcept
37
{
17,960,688✔
38
    char* header = mem.get_addr();
17,960,688✔
39

8,939,292✔
40
    ArrayParent* parent = m_arr->get_parent();
17,960,688✔
41
    size_t ndx_in_parent = m_arr->get_ndx_in_parent();
17,960,688✔
42

8,939,292✔
43
    bool long_strings = Array::get_hasrefs_from_header(header);
17,960,688✔
44
    if (!long_strings) {
17,960,688✔
45
        // Small strings
6,643,107✔
46
        bool is_small = Array::get_wtype_from_header(header) == Array::wtype_Multiply;
13,376,496✔
47
        if (is_small) {
13,376,496✔
48
            auto arr = new (&m_storage.m_string_short) ArrayStringShort(m_alloc, m_nullable);
7,758,612✔
49
            arr->init_from_mem(mem);
7,758,612✔
50
            m_type = Type::small_strings;
7,758,612✔
51
        }
7,758,612✔
52
        else {
5,617,884✔
53
            auto arr = new (&m_storage.m_enum) Array(m_alloc);
5,617,884✔
54
            arr->init_from_mem(mem);
5,617,884✔
55
            m_string_enum_values = std::make_unique<ArrayString>(m_alloc);
5,617,884✔
56
            ArrayParent* p;
5,617,884✔
57
            REALM_ASSERT(m_spec != nullptr);
5,617,884✔
58
            REALM_ASSERT(m_col_ndx != realm::npos);
5,617,884✔
59
            ref_type r = m_spec->get_enumkeys_ref(m_col_ndx, p);
5,617,884✔
60
            m_string_enum_values->init_from_ref(r);
5,617,884✔
61
            m_string_enum_values->set_parent(p, m_col_ndx);
5,617,884✔
62
            m_type = Type::enum_strings;
5,617,884✔
63
        }
5,617,884✔
64
    }
13,376,496✔
65
    else {
4,584,192✔
66
        bool is_big = Array::get_context_flag_from_header(header);
4,584,192✔
67
        if (!is_big) {
4,584,192✔
68
            auto arr = new (&m_storage.m_string_long) ArraySmallBlobs(m_alloc);
1,165,284✔
69
            arr->init_from_mem(mem);
1,165,284✔
70
            m_type = Type::medium_strings;
1,165,284✔
71
        }
1,165,284✔
72
        else {
3,418,908✔
73
            auto arr = new (&m_storage.m_big_blobs) ArrayBigBlobs(m_alloc, m_nullable);
3,418,908✔
74
            arr->init_from_mem(mem);
3,418,908✔
75
            m_type = Type::big_strings;
3,418,908✔
76
        }
3,418,908✔
77
    }
4,584,192✔
78
    m_arr->set_parent(parent, ndx_in_parent);
17,960,688✔
79
}
17,960,688✔
80

81
void ArrayString::init_from_parent()
82
{
5,322,057✔
83
    ref_type ref = m_arr->get_ref_from_parent();
5,322,057✔
84
    init_from_ref(ref);
5,322,057✔
85
}
5,322,057✔
86

87
void ArrayString::destroy() noexcept
88
{
366✔
89
    if (m_arr->is_attached()) {
366✔
90
        Array::destroy_deep(m_arr->get_ref(), m_alloc);
360✔
91
        detach();
360✔
92
    }
360✔
93
}
366✔
94

95
void ArrayString::detach() noexcept
96
{
336,558✔
97
    m_arr->detach();
336,558✔
98
    // Make sure the object is in a state like right after construction
168,036✔
99
    // Next call must be to create()
168,036✔
100
    m_arr = new (&m_storage.m_string_short) ArrayStringShort(m_alloc, true);
336,558✔
101
    m_type = Type::small_strings;
336,558✔
102
}
336,558✔
103

104
size_t ArrayString::size() const
105
{
15,498,600✔
106
    switch (m_type) {
15,498,600✔
107
        case Type::small_strings:
6,914,964✔
108
            return static_cast<ArrayStringShort*>(m_arr)->size();
6,914,964✔
109
        case Type::medium_strings:
437,799✔
110
            return static_cast<ArraySmallBlobs*>(m_arr)->size();
437,799✔
111
        case Type::big_strings:
8,163,192✔
112
            return static_cast<ArrayBigBlobs*>(m_arr)->size();
8,163,192✔
113
        case Type::enum_strings:
246✔
114
            return static_cast<Array*>(m_arr)->size();
246✔
115
    }
×
116
    return {};
×
117
}
×
118

119
void ArrayString::add(StringData value)
120
{
162,528✔
121
    switch (upgrade_leaf(value.size())) {
162,528✔
122
        case Type::small_strings:
107,223✔
123
            static_cast<ArrayStringShort*>(m_arr)->add(value);
107,223✔
124
            break;
107,223✔
125
        case Type::medium_strings:
27,630✔
126
            static_cast<ArraySmallBlobs*>(m_arr)->add_string(value);
27,630✔
127
            break;
27,630✔
128
        case Type::big_strings:
27,678✔
129
            static_cast<ArrayBigBlobs*>(m_arr)->add_string(value);
27,678✔
130
            break;
27,678✔
131
        case Type::enum_strings: {
✔
132
            auto a = static_cast<Array*>(m_arr);
×
133
            size_t ndx = a->size();
×
134
            a->add(0);
×
135
            set(ndx, value);
×
136
            break;
×
137
        }
×
138
    }
162,528✔
139
}
162,528✔
140

141
void ArrayString::set(size_t ndx, StringData value)
142
{
3,809,799✔
143
    switch (upgrade_leaf(value.size())) {
3,809,799✔
144
        case Type::small_strings:
529,287✔
145
            static_cast<ArrayStringShort*>(m_arr)->set(ndx, value);
529,287✔
146
            break;
529,287✔
147
        case Type::medium_strings:
246,876✔
148
            static_cast<ArraySmallBlobs*>(m_arr)->set_string(ndx, value);
246,876✔
149
            break;
246,876✔
150
        case Type::big_strings:
409,656✔
151
            static_cast<ArrayBigBlobs*>(m_arr)->set_string(ndx, value);
409,656✔
152
            break;
409,656✔
153
        case Type::enum_strings: {
2,625,594✔
154
            size_t sz = m_string_enum_values->size();
2,625,594✔
155
            size_t res = m_string_enum_values->find_first(value, 0, sz);
2,625,594✔
156
            if (res == realm::not_found) {
2,625,594✔
157
                m_string_enum_values->add(value);
9,549✔
158
                res = sz;
9,549✔
159
            }
9,549✔
160
            static_cast<Array*>(m_arr)->set(ndx, res);
2,625,594✔
161
            break;
2,625,594✔
162
        }
×
163
    }
3,809,799✔
164
}
3,809,799✔
165

166
void ArrayString::insert(size_t ndx, StringData value)
167
{
3,348,162✔
168
    switch (upgrade_leaf(value.size())) {
3,348,162✔
169
        case Type::small_strings:
1,017,249✔
170
            static_cast<ArrayStringShort*>(m_arr)->insert(ndx, value);
1,017,249✔
171
            break;
1,017,249✔
172
        case Type::medium_strings:
281,787✔
173
            static_cast<ArraySmallBlobs*>(m_arr)->insert_string(ndx, value);
281,787✔
174
            break;
281,787✔
175
        case Type::big_strings:
737,553✔
176
            static_cast<ArrayBigBlobs*>(m_arr)->insert_string(ndx, value);
737,553✔
177
            break;
737,553✔
178
        case Type::enum_strings: {
1,312,746✔
179
            static_cast<Array*>(m_arr)->insert(ndx, 0);
1,312,746✔
180
            set(ndx, value);
1,312,746✔
181
        }
1,312,746✔
182
    }
3,348,162✔
183
}
3,348,162✔
184

185
StringData ArrayString::get(size_t ndx) const
186
{
22,303,848✔
187
    switch (m_type) {
22,303,848✔
188
        case Type::small_strings:
9,238,533✔
189
            return static_cast<ArrayStringShort*>(m_arr)->get(ndx);
9,238,533✔
190
        case Type::medium_strings:
1,386,783✔
191
            return static_cast<ArraySmallBlobs*>(m_arr)->get_string(ndx);
1,386,783✔
192
        case Type::big_strings:
8,752,917✔
193
            return static_cast<ArrayBigBlobs*>(m_arr)->get_string(ndx);
8,752,917✔
194
        case Type::enum_strings: {
3,070,674✔
195
            size_t index = size_t(static_cast<Array*>(m_arr)->get(ndx));
3,070,674✔
196
            return m_string_enum_values->get(index);
3,070,674✔
197
        }
×
198
    }
×
199
    return {};
×
200
}
×
201

202
StringData ArrayString::get_legacy(size_t ndx) const
UNCOV
203
{
×
UNCOV
204
    switch (m_type) {
×
UNCOV
205
        case Type::small_strings:
×
UNCOV
206
            return static_cast<ArrayStringShort*>(m_arr)->get(ndx);
×
UNCOV
207
        case Type::medium_strings:
×
UNCOV
208
            return static_cast<ArraySmallBlobs*>(m_arr)->get_string_legacy(ndx);
×
UNCOV
209
        case Type::big_strings:
×
UNCOV
210
            return static_cast<ArrayBigBlobs*>(m_arr)->get_string(ndx);
×
UNCOV
211
        case Type::enum_strings: {
×
UNCOV
212
            size_t index = size_t(static_cast<Array*>(m_arr)->get(ndx));
×
UNCOV
213
            return m_string_enum_values->get(index);
×
214
        }
×
215
    }
×
216
    return {};
×
217
}
×
218

219
Mixed ArrayString::get_any(size_t ndx) const
220
{
132,906✔
221
    return Mixed(get(ndx));
132,906✔
222
}
132,906✔
223

224
bool ArrayString::is_null(size_t ndx) const
225
{
3,706,443✔
226
    switch (m_type) {
3,706,443✔
227
        case Type::small_strings:
547,488✔
228
            return static_cast<ArrayStringShort*>(m_arr)->is_null(ndx);
547,488✔
229
        case Type::medium_strings:
17,730✔
230
            return static_cast<ArraySmallBlobs*>(m_arr)->is_null(ndx);
17,730✔
231
        case Type::big_strings:
3,141,225✔
232
            return static_cast<ArrayBigBlobs*>(m_arr)->is_null(ndx);
3,141,225✔
233
        case Type::enum_strings: {
✔
234
            size_t index = size_t(static_cast<Array*>(m_arr)->get(ndx));
×
235
            return m_string_enum_values->is_null(index);
×
236
        }
×
237
    }
×
238
    return {};
×
239
}
×
240

241
void ArrayString::erase(size_t ndx)
242
{
185,196✔
243
    switch (m_type) {
185,196✔
244
        case Type::small_strings:
94,059✔
245
            static_cast<ArrayStringShort*>(m_arr)->erase(ndx);
94,059✔
246
            break;
94,059✔
247
        case Type::medium_strings:
59,100✔
248
            static_cast<ArraySmallBlobs*>(m_arr)->erase(ndx);
59,100✔
249
            break;
59,100✔
250
        case Type::big_strings:
23,799✔
251
            static_cast<ArrayBigBlobs*>(m_arr)->erase(ndx);
23,799✔
252
            break;
23,799✔
253
        case Type::enum_strings:
8,238✔
254
            static_cast<Array*>(m_arr)->erase(ndx);
8,238✔
255
            break;
8,238✔
256
    }
185,196✔
257
}
185,196✔
258

259
void ArrayString::move(ArrayString& dst, size_t ndx)
260
{
66✔
261
    size_t sz = size();
66✔
262
    for (size_t i = ndx; i < sz; i++) {
20,730✔
263
        dst.add(get(i));
20,664✔
264
    }
20,664✔
265

33✔
266
    switch (m_type) {
66✔
267
        case Type::small_strings:
✔
268
            static_cast<ArrayStringShort*>(m_arr)->truncate(ndx);
×
269
            break;
×
270
        case Type::medium_strings:
60✔
271
            static_cast<ArraySmallBlobs*>(m_arr)->truncate(ndx);
60✔
272
            break;
60✔
273
        case Type::big_strings:
6✔
274
            static_cast<ArrayBigBlobs*>(m_arr)->truncate(ndx);
6✔
275
            break;
6✔
276
        case Type::enum_strings:
✔
277
            // this operation will never be called for enumerated columns
278
            REALM_UNREACHABLE();
×
279
            break;
×
280
    }
66✔
281
}
66✔
282

283
void ArrayString::clear()
284
{
339✔
285
    switch (m_type) {
339✔
286
        case Type::small_strings:
285✔
287
            static_cast<ArrayStringShort*>(m_arr)->clear();
285✔
288
            break;
285✔
289
        case Type::medium_strings:
6✔
290
            static_cast<ArraySmallBlobs*>(m_arr)->clear();
6✔
291
            break;
6✔
292
        case Type::big_strings:
48✔
293
            static_cast<ArrayBigBlobs*>(m_arr)->clear();
48✔
294
            break;
48✔
295
        case Type::enum_strings:
✔
296
            static_cast<Array*>(m_arr)->clear();
×
297
            break;
×
298
    }
339✔
299
}
339✔
300

301
size_t ArrayString::find_first(StringData value, size_t begin, size_t end) const noexcept
302
{
4,095,219✔
303
    switch (m_type) {
4,095,219✔
304
        case Type::small_strings:
3,139,368✔
305
            return static_cast<ArrayStringShort*>(m_arr)->find_first(value, begin, end);
3,139,368✔
306
        case Type::medium_strings: {
104,682✔
307
            BinaryData as_binary(value.data(), value.size());
104,682✔
308
            return static_cast<ArraySmallBlobs*>(m_arr)->find_first(as_binary, true, begin, end);
104,682✔
309
            break;
×
310
        }
×
311
        case Type::big_strings: {
254,694✔
312
            BinaryData as_binary(value.data(), value.size());
254,694✔
313
            return static_cast<ArrayBigBlobs*>(m_arr)->find_first(as_binary, true, begin, end);
254,694✔
314
            break;
×
315
        }
×
316
        case Type::enum_strings: {
596,637✔
317
            size_t sz = m_string_enum_values->size();
596,637✔
318
            size_t res = m_string_enum_values->find_first(value, 0, sz);
596,637✔
319
            if (res != realm::not_found) {
596,637✔
320
                return static_cast<Array*>(m_arr)->find_first(res, begin, end);
596,637✔
321
            }
596,637✔
UNCOV
322
            break;
×
UNCOV
323
        }
×
324
    }
×
325
    return not_found;
×
326
}
×
327

328
namespace {
329

330
template <class T>
331
inline StringData get_string(const T* arr, size_t ndx)
332
{
437,337✔
333
    return arr->get_string(ndx);
437,337✔
334
}
437,337✔
335

336
template <>
337
inline StringData get_string(const ArrayStringShort* arr, size_t ndx)
338
{
93,681✔
339
    return arr->get(ndx);
93,681✔
340
}
93,681✔
341

342
template <class T, class U>
343
size_t lower_bound_string(const T* arr, U value)
344
{
234,912✔
345
    size_t i = 0;
234,912✔
346
    size_t sz = arr->size();
234,912✔
347
    while (0 < sz) {
765,930✔
348
        size_t half = sz / 2;
531,018✔
349
        size_t mid = i + half;
531,018✔
350
        auto probe = get_string(arr, mid);
531,018✔
351
        if (probe < value) {
531,018✔
352
            i = mid + 1;
190,809✔
353
            sz -= half + 1;
190,809✔
354
        }
190,809✔
355
        else {
340,209✔
356
            sz = half;
340,209✔
357
        }
340,209✔
358
    }
531,018✔
359
    return i;
234,912✔
360
}
234,912✔
361
}
362

363
size_t ArrayString::lower_bound(StringData value)
364
{
234,912✔
365
    switch (m_type) {
234,912✔
366
        case Type::small_strings:
58,434✔
367
            return lower_bound_string(static_cast<ArrayStringShort*>(m_arr), value);
58,434✔
368
        case Type::medium_strings:
68,418✔
369
            return lower_bound_string(static_cast<ArraySmallBlobs*>(m_arr), value);
68,418✔
370
        case Type::big_strings:
108,060✔
371
            return lower_bound_string(static_cast<ArrayBigBlobs*>(m_arr), value);
108,060✔
372
        case Type::enum_strings:
✔
373
            break;
×
374
    }
×
375
    return realm::npos;
×
376
}
×
377

378
ArrayString::Type ArrayString::upgrade_leaf(size_t value_size)
379
{
7,316,355✔
380
    if (m_type == Type::big_strings)
7,316,355✔
381
        return Type::big_strings;
1,136,829✔
382

3,044,655✔
383
    if (m_type == Type::enum_strings)
6,179,526✔
384
        return Type::enum_strings;
3,938,283✔
385

1,075,659✔
386
    if (m_type == Type::medium_strings) {
2,241,243✔
387
        if (value_size <= medium_string_max_size)
527,139✔
388
            return Type::medium_strings;
526,626✔
389

267✔
390
        // Upgrade root leaf from medium to big strings
267✔
391
        auto string_medium = static_cast<ArraySmallBlobs*>(m_arr);
513✔
392
        ArrayBigBlobs big_blobs(m_alloc, true);
513✔
393
        big_blobs.create(); // Throws
513✔
394

267✔
395
        size_t n = string_medium->size();
513✔
396
        for (size_t i = 0; i < n; i++) {
9,657✔
397
            big_blobs.add_string(string_medium->get_string(i)); // Throws
9,144✔
398
        }
9,144✔
399
        auto parent = string_medium->get_parent();
513✔
400
        auto ndx_in_parent = string_medium->get_ndx_in_parent();
513✔
401
        string_medium->destroy();
513✔
402

267✔
403
        auto arr = new (&m_storage.m_big_blobs) ArrayBigBlobs(m_alloc, true);
513✔
404
        arr->init_from_mem(big_blobs.get_mem());
513✔
405
        arr->set_parent(parent, ndx_in_parent);
513✔
406
        arr->update_parent();
513✔
407

267✔
408
        m_type = Type::big_strings;
513✔
409
        return Type::big_strings;
513✔
410
    }
513✔
411

811,821✔
412
    // m_type == Type::small
811,821✔
413
    if (value_size <= small_string_max_size)
1,714,104✔
414
        return Type::small_strings;
1,653,369✔
415

27,708✔
416
    if (value_size <= medium_string_max_size) {
60,735✔
417
        // Upgrade root leaf from small to medium strings
14,520✔
418
        auto string_short = static_cast<ArrayStringShort*>(m_arr);
29,574✔
419
        ArraySmallBlobs string_long(m_alloc);
29,574✔
420
        string_long.create(); // Throws
29,574✔
421

14,520✔
422
        size_t n = string_short->size();
29,574✔
423
        for (size_t i = 0; i < n; i++) {
63,771✔
424
            string_long.add_string(string_short->get(i)); // Throws
34,197✔
425
        }
34,197✔
426
        auto parent = string_short->get_parent();
29,574✔
427
        auto ndx_in_parent = string_short->get_ndx_in_parent();
29,574✔
428
        string_short->destroy();
29,574✔
429

14,520✔
430
        auto arr = new (&m_storage.m_string_long) ArraySmallBlobs(m_alloc);
29,574✔
431
        arr->init_from_mem(string_long.get_mem());
29,574✔
432
        arr->set_parent(parent, ndx_in_parent);
29,574✔
433
        arr->update_parent();
29,574✔
434

14,520✔
435
        m_type = Type::medium_strings;
29,574✔
436
    }
29,574✔
437
    else {
31,161✔
438
        // Upgrade root leaf from small to big strings
13,188✔
439
        auto string_short = static_cast<ArrayStringShort*>(m_arr);
31,161✔
440
        ArrayBigBlobs big_blobs(m_alloc, true);
31,161✔
441
        big_blobs.create(); // Throws
31,161✔
442

13,188✔
443
        size_t n = string_short->size();
31,161✔
444
        for (size_t i = 0; i < n; i++) {
69,045✔
445
            big_blobs.add_string(string_short->get(i)); // Throws
37,884✔
446
        }
37,884✔
447
        auto parent = string_short->get_parent();
31,161✔
448
        auto ndx_in_parent = string_short->get_ndx_in_parent();
31,161✔
449
        string_short->destroy();
31,161✔
450

13,188✔
451
        auto arr = new (&m_storage.m_big_blobs) ArrayBigBlobs(m_alloc, true);
31,161✔
452
        arr->init_from_mem(big_blobs.get_mem());
31,161✔
453
        arr->set_parent(parent, ndx_in_parent);
31,161✔
454
        arr->update_parent();
31,161✔
455

13,188✔
456
        m_type = Type::big_strings;
31,161✔
457
    }
31,161✔
458

27,708✔
459
    return m_type;
60,735✔
460
}
60,735✔
461

462
void ArrayString::verify() const
463
{
3,071,181✔
464
#ifdef REALM_DEBUG
3,071,181✔
465
    switch (m_type) {
3,071,181✔
466
        case Type::small_strings:
3,064,716✔
467
            static_cast<ArrayStringShort*>(m_arr)->verify();
3,064,716✔
468
            break;
3,064,716✔
469
        case Type::medium_strings:
843✔
470
            static_cast<ArraySmallBlobs*>(m_arr)->verify();
843✔
471
            break;
843✔
472
        case Type::big_strings:
5,376✔
473
            static_cast<ArrayBigBlobs*>(m_arr)->verify();
5,376✔
474
            break;
5,376✔
475
        case Type::enum_strings:
246✔
476
            static_cast<Array*>(m_arr)->verify();
246✔
477
            break;
246✔
478
    }
3,071,181✔
479
#endif
3,071,181✔
480
}
3,071,181✔
STATUS · Troubleshooting · Open an Issue · Sales · Support · CAREERS · ENTERPRISE · START FREE · SCHEDULE DEMO
ANNOUNCEMENTS · TWITTER · TOS & SLA · Supported CI Services · What's a CI service? · Automated Testing

© 2025 Coveralls, Inc