| line |
true |
false |
branch |
|
7
|
27 |
5 |
char errbuf[SHM_ERR_BUFLEN]; const char* path = SvOK(path_sv) ? SvPV_nolen(path_sv) : NULL; ShmHandle* map = shm_ss_create(path, (uint32_t)max_entries, (uint32_t)lru_max, (uint32_t)ttl_default, (uint32_t)lru_skip, errbuf); |
|
8
|
1 |
31 |
if (!map) croak("Data::HashMap::Shared::SS: %s", errbuf[0] ? errbuf : "unknown error"); |
|
|
1 |
0 |
if (!map) croak("Data::HashMap::Shared::SS: %s", errbuf[0] ? errbuf : "unknown error"); |
|
16
|
1 |
0 |
const char* path_prefix = SvOK(path_prefix_sv) ? SvPV_nolen(path_prefix_sv) : NULL; |
|
18
|
0 |
1 |
if (!map) croak("Data::HashMap::Shared::SS: %s", errbuf[0] ? errbuf : "unknown error"); |
|
|
0 |
0 |
if (!map) croak("Data::HashMap::Shared::SS: %s", errbuf[0] ? errbuf : "unknown error"); |
|
28
|
1 |
0 |
const char* name = SvOK(name_sv) ? SvPV_nolen(name_sv) : NULL; |
|
30
|
0 |
1 |
if (!map) croak("Data::HashMap::Shared::SS: %s", errbuf[0] ? errbuf : "unknown error"); |
|
|
0 |
0 |
if (!map) croak("Data::HashMap::Shared::SS: %s", errbuf[0] ? errbuf : "unknown error"); |
|
40
|
0 |
1 |
if (!map) croak("Data::HashMap::Shared::SS: %s", errbuf[0] ? errbuf : "unknown error"); |
|
|
0 |
0 |
if (!map) croak("Data::HashMap::Shared::SS: %s", errbuf[0] ? errbuf : "unknown error"); |
|
48
|
1 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
|
0 |
1 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
|
0 |
1 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
49
|
0 |
1 |
RETVAL = h->backing_fd; |
|
57
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
58
|
0 |
0 |
if (shm_msync(h) != 0) croak("Data::HashMap::Shared::SS sync: %s", strerror(errno)); |
|
63
|
0 |
34 |
if (!SvROK(self_sv)) return; |
|
65
|
0 |
34 |
if (!h) return; |
|
72
|
8105 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
|
0 |
8105 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
|
0 |
8105 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
73
|
0 |
8105 |
EXTRACT_STR_KEY(key_sv); |
|
74
|
0 |
8105 |
EXTRACT_STR_VAL(value); |
|
75
|
8105 |
0 |
RETVAL = shm_ss_put(h, _kstr, (uint32_t)_klen, _kutf8, _vstr, (uint32_t)_vlen, _vutf8); |
|
82
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
83
|
0 |
0 |
if ((items - 1) % 2 != 0) croak("set_multi requires even number of arguments (key, value pairs)"); |
|
85
|
0 |
0 |
if (h->shard_handles) { |
|
86
|
0 |
0 |
for (int i = 1; i < items; i += 2) { |
|
91
|
0 |
0 |
if (_kl > SHM_MAX_STR_LEN) croak("key too long (max 1GB)"); |
|
92
|
0 |
0 |
if (_vl > SHM_MAX_STR_LEN) croak("value too long (max 1GB)"); |
|
97
|
0 |
0 |
for (int i = 1; i < items; i += 2) { |
|
100
|
0 |
0 |
if (_kl > SHM_MAX_STR_LEN) croak("key too long (max 1GB)"); |
|
103
|
0 |
0 |
if (_vl > SHM_MAX_STR_LEN) croak("value too long (max 1GB)"); |
|
107
|
0 |
0 |
RETVAL = count; |
|
114
|
1 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
|
0 |
1 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
|
0 |
1 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
116
|
0 |
1 |
if (h->shard_handles) { |
|
117
|
0 |
0 |
for (int i = 1; i < items; i++) { |
|
120
|
0 |
0 |
if (_kl > SHM_MAX_STR_LEN) croak("key too long (max 1GB)"); |
|
125
|
3 |
1 |
for (int i = 1; i < items; i++) { |
|
128
|
0 |
3 |
if (_kl > SHM_MAX_STR_LEN) croak("key too long (max 1GB)"); |
|
131
|
1 |
0 |
if (count) shm_ss_maybe_shrink(h); |
|
133
|
0 |
1 |
RETVAL = count; |
|
140
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
142
|
0 |
0 |
if (nkeys == 0) XSRETURN_EMPTY; |
|
143
|
0 |
0 |
EXTEND(SP, nkeys); |
|
|
0 |
0 |
EXTEND(SP, nkeys); |
|
144
|
0 |
0 |
if (h->shard_handles) { |
|
145
|
0 |
0 |
for (int i = 0; i < nkeys; i++) { |
|
149
|
0 |
0 |
if (shm_ss_get(h, _ks, (uint32_t)_kl, _ku, &out_s, &out_l, &out_u)) { |
|
151
|
0 |
0 |
if (out_u) SvUTF8_on(sv); |
|
160
|
0 |
0 |
uint32_t now = h->expires_at ? shm_now() : 0; |
|
163
|
0 |
0 |
for (int i = 0; i < nkeys; i++) { |
|
171
|
0 |
0 |
for (uint32_t j = 0; j <= mask; j++) { |
|
174
|
0 |
0 |
if (st == SHM_EMPTY) break; |
|
175
|
0 |
0 |
if (st != tag) continue; |
|
176
|
0 |
0 |
if (shm_ss__key_eq_str(&nodes[idx], arena, _ks, (uint32_t)_kl, _ku)) { |
|
177
|
0 |
0 |
if (h->expires_at && h->expires_at[idx] && now >= h->expires_at[idx]) break; |
|
|
0 |
0 |
if (h->expires_at && h->expires_at[idx] && now >= h->expires_at[idx]) break; |
|
|
0 |
0 |
if (h->expires_at && h->expires_at[idx] && now >= h->expires_at[idx]) break; |
|
181
|
0 |
0 |
if (found) { |
|
185
|
0 |
0 |
if (SHM_UNPACK_UTF8(nodes[vidx].val_len)) SvUTF8_on(sv); |
|
189
|
0 |
0 |
if (i + 1 < nkeys) { |
|
200
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
201
|
0 |
0 |
EXTRACT_STR_KEY(key_sv); |
|
204
|
0 |
0 |
if (!shm_ss_get_with_ttl(h, _kstr, (uint32_t)_klen, _kutf8, &out_s, &out_l, &out_u, &out_ttl)) XSRETURN_EMPTY; |
|
205
|
0 |
0 |
EXTEND(SP, 2); |
|
207
|
0 |
0 |
if (out_u) SvUTF8_on(vsv); |
|
209
|
0 |
0 |
if (out_ttl < 0) PUSHs(&PL_sv_undef); |
|
215
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
236
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
237
|
0 |
0 |
EXTRACT_STR_KEY(key_sv); |
|
238
|
0 |
0 |
RETVAL = shm_ss_persist(h, _kstr, (uint32_t)_klen, _kutf8); |
|
245
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
246
|
0 |
0 |
EXTRACT_STR_KEY(key_sv); |
|
247
|
0 |
0 |
RETVAL = shm_ss_set_ttl(h, _kstr, (uint32_t)_klen, _kutf8, (uint32_t)ttl_sec); |
|
254
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
255
|
0 |
0 |
EXTRACT_STR_KEY(key_sv); |
|
256
|
0 |
0 |
EXTRACT_STR_VAL(value); |
|
257
|
0 |
0 |
REQUIRE_TTL(h); |
|
|
0 |
0 |
REQUIRE_TTL(h); |
|
258
|
0 |
0 |
RETVAL = shm_ss_put_ttl(h, _kstr, (uint32_t)_klen, _kutf8, _vstr, (uint32_t)_vlen, _vutf8, (uint32_t)ttl_sec); |
|
265
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
266
|
0 |
0 |
RETVAL = (UV)shm_ss_max_size(h); |
|
273
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
274
|
0 |
0 |
RETVAL = (UV)shm_ss_ttl(h); |
|
281
|
100 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
|
0 |
100 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
|
0 |
100 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
282
|
0 |
100 |
EXTRACT_STR_KEY(key_sv); |
|
284
|
3 |
97 |
if (!shm_ss_get(h, _kstr, (uint32_t)_klen, _kutf8, &val, &val_len, &val_utf8)) |
|
287
|
1 |
96 |
if (val_utf8) SvUTF8_on(RETVAL); |
|
294
|
8022 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
|
0 |
8022 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
|
0 |
8022 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
295
|
0 |
8022 |
EXTRACT_STR_KEY(key_sv); |
|
296
|
8022 |
0 |
RETVAL = shm_ss_remove(h, _kstr, (uint32_t)_klen, _kutf8); |
|
303
|
9 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
|
0 |
9 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
|
0 |
9 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
304
|
0 |
9 |
EXTRACT_STR_KEY(key_sv); |
|
305
|
6 |
3 |
RETVAL = shm_ss_exists(h, _kstr, (uint32_t)_klen, _kutf8); |
|
312
|
9 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
|
0 |
9 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
|
0 |
9 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
313
|
0 |
9 |
RETVAL = (UV)shm_ss_size(h); |
|
320
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
321
|
0 |
0 |
RETVAL = (UV)shm_ss_max_entries(h); |
|
328
|
2 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
|
0 |
2 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
|
0 |
2 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
329
|
0 |
2 |
uint32_t ns = h->shard_handles ? h->num_shards : 1; |
|
330
|
2 |
2 |
for (uint32_t si = 0; si < ns; si++) { |
|
331
|
0 |
2 |
ShmHandle *sh = h->shard_handles ? h->shard_handles[si] : h; |
|
334
|
0 |
2 |
uint32_t now = sh->expires_at ? shm_now() : 0; |
|
336
|
0 |
2 |
EXTEND(SP, hdr->size); |
|
337
|
32 |
2 |
for (uint32_t i = 0; i < hdr->table_cap; i++) { |
|
338
|
4 |
28 |
if (SHM_IS_LIVE(sh->states[i]) && !SHM_IS_EXPIRED(sh, i, now)) { |
|
|
0 |
4 |
if (SHM_IS_LIVE(sh->states[i]) && !SHM_IS_EXPIRED(sh, i, now)) { |
|
|
0 |
0 |
if (SHM_IS_LIVE(sh->states[i]) && !SHM_IS_EXPIRED(sh, i, now)) { |
|
|
0 |
0 |
if (SHM_IS_LIVE(sh->states[i]) && !SHM_IS_EXPIRED(sh, i, now)) { |
|
342
|
1 |
3 |
if (SHM_UNPACK_UTF8(nodes[i].key_len)) SvUTF8_on(sv); |
|
343
|
0 |
4 |
mXPUSHs(sv); |
|
351
|
1 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
|
0 |
1 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
|
0 |
1 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
352
|
0 |
1 |
uint32_t ns = h->shard_handles ? h->num_shards : 1; |
|
353
|
1 |
1 |
for (uint32_t si = 0; si < ns; si++) { |
|
354
|
0 |
1 |
ShmHandle *sh = h->shard_handles ? h->shard_handles[si] : h; |
|
357
|
0 |
1 |
uint32_t now = sh->expires_at ? shm_now() : 0; |
|
359
|
0 |
1 |
EXTEND(SP, hdr->size); |
|
360
|
16 |
1 |
for (uint32_t i = 0; i < hdr->table_cap; i++) { |
|
361
|
3 |
13 |
if (SHM_IS_LIVE(sh->states[i]) && !SHM_IS_EXPIRED(sh, i, now)) { |
|
|
0 |
3 |
if (SHM_IS_LIVE(sh->states[i]) && !SHM_IS_EXPIRED(sh, i, now)) { |
|
|
0 |
0 |
if (SHM_IS_LIVE(sh->states[i]) && !SHM_IS_EXPIRED(sh, i, now)) { |
|
|
0 |
0 |
if (SHM_IS_LIVE(sh->states[i]) && !SHM_IS_EXPIRED(sh, i, now)) { |
|
365
|
0 |
3 |
if (SHM_UNPACK_UTF8(nodes[i].val_len)) SvUTF8_on(sv); |
|
366
|
0 |
3 |
mXPUSHs(sv); |
|
374
|
1 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
|
0 |
1 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
|
0 |
1 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
375
|
0 |
1 |
uint32_t ns = h->shard_handles ? h->num_shards : 1; |
|
376
|
1 |
1 |
for (uint32_t si = 0; si < ns; si++) { |
|
377
|
0 |
1 |
ShmHandle *sh = h->shard_handles ? h->shard_handles[si] : h; |
|
380
|
0 |
1 |
uint32_t now = sh->expires_at ? shm_now() : 0; |
|
382
|
0 |
1 |
EXTEND(SP, hdr->size * 2); |
|
383
|
16 |
1 |
for (uint32_t i = 0; i < hdr->table_cap; i++) { |
|
384
|
3 |
13 |
if (SHM_IS_LIVE(sh->states[i]) && !SHM_IS_EXPIRED(sh, i, now)) { |
|
|
0 |
3 |
if (SHM_IS_LIVE(sh->states[i]) && !SHM_IS_EXPIRED(sh, i, now)) { |
|
|
0 |
0 |
if (SHM_IS_LIVE(sh->states[i]) && !SHM_IS_EXPIRED(sh, i, now)) { |
|
|
0 |
0 |
if (SHM_IS_LIVE(sh->states[i]) && !SHM_IS_EXPIRED(sh, i, now)) { |
|
388
|
0 |
3 |
if (SHM_UNPACK_UTF8(nodes[i].key_len)) SvUTF8_on(ksv); |
|
389
|
0 |
3 |
mXPUSHs(ksv); |
|
393
|
0 |
3 |
if (SHM_UNPACK_UTF8(nodes[i].val_len)) SvUTF8_on(vsv); |
|
394
|
0 |
3 |
mXPUSHs(vsv); |
|
403
|
3 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
|
0 |
3 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
|
0 |
3 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
407
|
2 |
1 |
if (shm_ss_each(h, &out_key, &out_klen, &out_kutf8, &out_val, &out_vlen, &out_vutf8)) { |
|
408
|
0 |
2 |
EXTEND(SP, 2); |
|
410
|
0 |
2 |
if (out_kutf8) SvUTF8_on(ksv); |
|
411
|
0 |
2 |
mXPUSHs(ksv); |
|
413
|
0 |
2 |
if (out_vutf8) SvUTF8_on(vsv); |
|
414
|
0 |
2 |
mXPUSHs(vsv); |
|
423
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
430
|
1 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
|
0 |
1 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
|
0 |
1 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
436
|
1 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
|
0 |
1 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
|
0 |
1 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
438
|
0 |
1 |
uint32_t ns = h->shard_handles ? h->num_shards : 1; |
|
439
|
1 |
1 |
for (uint32_t si = 0; si < ns; si++) { |
|
440
|
0 |
1 |
ShmHandle *sh = h->shard_handles ? h->shard_handles[si] : h; |
|
443
|
0 |
1 |
uint32_t now = sh->expires_at ? shm_now() : 0; |
|
445
|
16 |
1 |
for (uint32_t i = 0; i < hdr->table_cap; i++) { |
|
446
|
2 |
14 |
if (SHM_IS_LIVE(sh->states[i]) && !SHM_IS_EXPIRED(sh, i, now)) { |
|
|
0 |
2 |
if (SHM_IS_LIVE(sh->states[i]) && !SHM_IS_EXPIRED(sh, i, now)) { |
|
|
0 |
0 |
if (SHM_IS_LIVE(sh->states[i]) && !SHM_IS_EXPIRED(sh, i, now)) { |
|
|
0 |
0 |
if (SHM_IS_LIVE(sh->states[i]) && !SHM_IS_EXPIRED(sh, i, now)) { |
|
453
|
0 |
2 |
if (SHM_UNPACK_UTF8(nodes[i].val_len)) SvUTF8_on(val); |
|
454
|
0 |
2 |
if (!hv_store(hv, kp, |
|
|
0 |
2 |
if (!hv_store(hv, kp, |
|
466
|
2 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
|
0 |
2 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
|
0 |
2 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
467
|
0 |
2 |
EXTRACT_STR_KEY(key_sv); |
|
469
|
0 |
2 |
EXTRACT_STR_VAL(default_sv); |
|
471
|
0 |
2 |
if (!rc) XSRETURN_UNDEF; |
|
473
|
0 |
2 |
if (out_utf8) SvUTF8_on(RETVAL); |
|
480
|
6 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
|
0 |
6 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
|
0 |
6 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
481
|
0 |
6 |
EXTRACT_STR_KEY(key_sv); |
|
483
|
1 |
5 |
if (remaining < 0) XSRETURN_UNDEF; |
|
491
|
4 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
|
0 |
4 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
|
0 |
4 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
492
|
3 |
1 |
RETVAL = (UV)shm_ss_capacity(h); |
|
499
|
3 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
|
0 |
3 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
|
0 |
3 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
500
|
3 |
0 |
RETVAL = (UV)shm_ss_tombstones(h); |
|
507
|
2 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
|
0 |
2 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
|
0 |
2 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
509
|
0 |
2 |
if (!c) croak("Failed to allocate cursor"); |
|
517
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
518
|
0 |
0 |
EXTRACT_STR_KEY(key_sv); |
|
520
|
0 |
0 |
if (!shm_ss_take(h, _kstr, (uint32_t)_klen, _kutf8, &out_str, &out_len, &out_utf8)) XSRETURN_UNDEF; |
|
522
|
0 |
0 |
if (out_utf8) SvUTF8_on(RETVAL); |
|
529
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
532
|
0 |
0 |
if (!shm_ss_pop(h, &out_key, &out_klen, &out_kutf8, &out_val, &out_vlen, &out_vutf8)) XSRETURN_EMPTY; |
|
533
|
0 |
0 |
EXTEND(SP, 2); |
|
535
|
0 |
0 |
if (out_kutf8) SvUTF8_on(ksv); |
|
538
|
0 |
0 |
if (out_vutf8) SvUTF8_on(vsv); |
|
544
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
547
|
0 |
0 |
if (!shm_ss_shift(h, &out_key, &out_klen, &out_kutf8, &out_val, &out_vlen, &out_vutf8)) XSRETURN_EMPTY; |
|
548
|
0 |
0 |
EXTEND(SP, 2); |
|
550
|
0 |
0 |
if (out_kutf8) SvUTF8_on(ksv); |
|
553
|
0 |
0 |
if (out_vutf8) SvUTF8_on(vsv); |
|
559
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
560
|
0 |
0 |
if (limit == 0) XSRETURN_EMPTY; |
|
562
|
0 |
0 |
Newxz(entries, limit, shm_ss_drain_entry); |
|
567
|
0 |
0 |
if (buf) SAVEDESTRUCTOR_X(shm_free_cleanup, buf); |
|
569
|
0 |
0 |
EXTEND(SP, n * 2); |
|
570
|
0 |
0 |
for (uint32_t i = 0; i < n; i++) { |
|
572
|
0 |
0 |
if (entries[i].key_utf8) SvUTF8_on(ksv); |
|
575
|
0 |
0 |
if (entries[i].val_utf8) SvUTF8_on(vsv); |
|
583
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
584
|
0 |
0 |
RETVAL = (UV)shm_ss_flush_expired(h); |
|
591
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
594
|
0 |
0 |
EXTEND(SP, 2); |
|
601
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
609
|
2 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
|
0 |
2 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
|
0 |
2 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
610
|
0 |
2 |
EXTRACT_STR_KEY(key_sv); |
|
611
|
1 |
1 |
RETVAL = shm_ss_touch(h, _kstr, (uint32_t)_klen, _kutf8); |
|
618
|
1 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
|
0 |
1 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
|
0 |
1 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
619
|
1 |
0 |
RETVAL = shm_ss_reserve(h, (uint32_t)target); |
|
626
|
1 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
|
0 |
1 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
|
0 |
1 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
634
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
642
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
643
|
0 |
0 |
RETVAL = (UV)shm_ss_stat_recoveries(h); |
|
650
|
2 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
|
0 |
2 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
|
0 |
2 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
658
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
666
|
2 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
|
0 |
2 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
|
0 |
2 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
667
|
0 |
2 |
EXTRACT_STR_KEY(key_sv); |
|
668
|
0 |
2 |
EXTRACT_STR_VAL(val_sv); |
|
669
|
1 |
1 |
RETVAL = shm_ss_add(h, _kstr, (uint32_t)_klen, _kutf8, _vstr, (uint32_t)_vlen, _vutf8); |
|
676
|
2 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
|
0 |
2 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
|
0 |
2 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
677
|
0 |
2 |
EXTRACT_STR_KEY(key_sv); |
|
678
|
0 |
2 |
EXTRACT_STR_VAL(val_sv); |
|
679
|
0 |
2 |
REQUIRE_TTL(h); |
|
|
0 |
2 |
REQUIRE_TTL(h); |
|
680
|
1 |
1 |
RETVAL = shm_ss_add_ttl(h, _kstr, (uint32_t)_klen, _kutf8, |
|
688
|
2 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
|
0 |
2 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
|
0 |
2 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
689
|
0 |
2 |
EXTRACT_STR_KEY(key_sv); |
|
690
|
0 |
2 |
EXTRACT_STR_VAL(val_sv); |
|
691
|
1 |
1 |
RETVAL = shm_ss_update(h, _kstr, (uint32_t)_klen, _kutf8, _vstr, (uint32_t)_vlen, _vutf8); |
|
698
|
2 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
|
0 |
2 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
|
0 |
2 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
699
|
0 |
2 |
EXTRACT_STR_KEY(key_sv); |
|
700
|
0 |
2 |
EXTRACT_STR_VAL(val_sv); |
|
701
|
0 |
2 |
REQUIRE_TTL(h); |
|
|
0 |
2 |
REQUIRE_TTL(h); |
|
702
|
1 |
1 |
RETVAL = shm_ss_update_ttl(h, _kstr, (uint32_t)_klen, _kutf8, _vstr, (uint32_t)_vlen, _vutf8, (uint32_t)ttl_sec); |
|
709
|
1 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
|
0 |
1 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
|
0 |
1 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
710
|
0 |
1 |
EXTRACT_STR_KEY(key_sv); |
|
711
|
0 |
1 |
EXTRACT_STR_VAL(val_sv); |
|
714
|
0 |
1 |
if (rc != 1) XSRETURN_UNDEF; |
|
716
|
0 |
1 |
if (out_u) SvUTF8_on(RETVAL); |
|
723
|
10 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
|
0 |
10 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
|
0 |
10 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
724
|
0 |
10 |
EXTRACT_STR_KEY(key_sv); |
|
725
|
0 |
10 |
EXTRACT_STR_EXPECTED_DESIRED(expected_sv, desired_sv); |
|
|
0 |
10 |
EXTRACT_STR_EXPECTED_DESIRED(expected_sv, desired_sv); |
|
726
|
7 |
3 |
RETVAL = shm_ss_cas(h, _kstr, (uint32_t)_klen, _kutf8, |
|
734
|
3 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
|
0 |
3 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
|
0 |
3 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
735
|
0 |
3 |
EXTRACT_STR_KEY(key_sv); |
|
736
|
0 |
3 |
EXTRACT_STR_EXPECTED(expected_sv); |
|
738
|
1 |
2 |
if (!shm_ss_cas_take(h, _kstr, (uint32_t)_klen, _kutf8, _estr, (uint32_t)_elen, &out_s, &out_l, &out_u)) XSRETURN_UNDEF; |
|
740
|
0 |
2 |
if (out_u) SvUTF8_on(RETVAL); |
|
747
|
2 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
|
0 |
2 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
|
0 |
2 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
748
|
1 |
1 |
RETVAL = h->path ? newSVpv(h->path, 0) : &PL_sv_undef; |
|
755
|
0 |
0 |
if (SvROK(self_or_class) && SvOBJECT(SvRV(self_or_class))) { |
|
|
0 |
0 |
if (SvROK(self_or_class) && SvOBJECT(SvRV(self_or_class))) { |
|
757
|
0 |
0 |
if (!h) croak("Attempted to use a destroyed Data::HashMap::Shared::SS object"); |
|
760
|
0 |
0 |
if (items < 2) croak("Usage: Data::HashMap::Shared::SS->unlink($path)"); |
|
772
|
0 |
2 |
if (!SvROK(self_sv)) return; |
|
774
|
0 |
2 |
if (!c) return; |
|
777
|
1 |
1 |
if (h) shm_ss_flush_deferred(h); |
|
783
|
7 |
0 |
EXTRACT_CURSOR("Data::HashMap::Shared::SS::Cursor", self_sv); |
|
|
0 |
7 |
EXTRACT_CURSOR("Data::HashMap::Shared::SS::Cursor", self_sv); |
|
|
0 |
7 |
EXTRACT_CURSOR("Data::HashMap::Shared::SS::Cursor", self_sv); |
|
787
|
6 |
1 |
if (shm_ss_cursor_next(c, &out_key, &out_klen, &out_kutf8, &out_val, &out_vlen, &out_vutf8)) { |
|
788
|
0 |
6 |
EXTEND(SP, 2); |
|
790
|
0 |
6 |
if (out_kutf8) SvUTF8_on(ksv); |
|
791
|
0 |
6 |
mXPUSHs(ksv); |
|
793
|
0 |
6 |
if (out_vutf8) SvUTF8_on(vsv); |
|
794
|
0 |
6 |
mXPUSHs(vsv); |
|
802
|
0 |
0 |
EXTRACT_CURSOR("Data::HashMap::Shared::SS::Cursor", self_sv); |
|
|
0 |
0 |
EXTRACT_CURSOR("Data::HashMap::Shared::SS::Cursor", self_sv); |
|
|
0 |
0 |
EXTRACT_CURSOR("Data::HashMap::Shared::SS::Cursor", self_sv); |
|
808
|
1 |
0 |
EXTRACT_CURSOR("Data::HashMap::Shared::SS::Cursor", self_sv); |
|
|
0 |
1 |
EXTRACT_CURSOR("Data::HashMap::Shared::SS::Cursor", self_sv); |
|
|
0 |
1 |
EXTRACT_CURSOR("Data::HashMap::Shared::SS::Cursor", self_sv); |
|
809
|
0 |
1 |
EXTRACT_STR_KEY(key_sv); |
|
810
|
1 |
0 |
RETVAL = shm_ss_cursor_seek(c, _kstr, (uint32_t)_klen, _kutf8); |