| line |
true |
false |
branch |
|
8
|
3 |
44 |
if (!map) croak("HashMap::Shared::SS: %s", errbuf[0] ? errbuf : "unknown error"); |
|
|
3 |
0 |
if (!map) croak("HashMap::Shared::SS: %s", errbuf[0] ? errbuf : "unknown error"); |
|
17
|
0 |
4 |
if (!map) croak("HashMap::Shared::SS: %s", errbuf[0] ? errbuf : "unknown error"); |
|
|
0 |
0 |
if (!map) croak("HashMap::Shared::SS: %s", errbuf[0] ? errbuf : "unknown error"); |
|
25
|
0 |
48 |
if (!SvROK(self_sv)) return; |
|
27
|
0 |
48 |
if (!h) return; |
|
34
|
3072 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
|
0 |
3072 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
|
0 |
3072 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
35
|
0 |
3072 |
EXTRACT_STR_KEY(key_sv); |
|
36
|
0 |
3072 |
EXTRACT_STR_VAL(value); |
|
37
|
3070 |
2 |
RETVAL = shm_ss_put(h, _kstr, (uint32_t)_klen, _kutf8, _vstr, (uint32_t)_vlen, _vutf8); |
|
44
|
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); |
|
45
|
0 |
3 |
if ((items - 1) % 2 != 0) croak("set_multi requires even number of arguments (key, value pairs)"); |
|
47
|
1 |
2 |
if (h->shard_handles) { |
|
48
|
3 |
1 |
for (int i = 1; i < items; i += 2) { |
|
59
|
6 |
2 |
for (int i = 1; i < items; i += 2) { |
|
62
|
0 |
6 |
if (_kl > SHM_MAX_STR_LEN) { shm_seqlock_write_end(&hdr->seq); shm_rwlock_wrunlock(hdr); croak("key too long"); } |
|
65
|
0 |
6 |
if (_vl > SHM_MAX_STR_LEN) { shm_seqlock_write_end(&hdr->seq); shm_rwlock_wrunlock(hdr); croak("value too long"); } |
|
71
|
0 |
3 |
RETVAL = count; |
|
78
|
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); |
|
80
|
0 |
3 |
if (nkeys == 0) XSRETURN_EMPTY; |
|
81
|
3 |
0 |
EXTEND(SP, nkeys); |
|
|
0 |
3 |
EXTEND(SP, nkeys); |
|
82
|
1 |
2 |
if (h->shard_handles) { |
|
83
|
4 |
1 |
for (int i = 0; i < nkeys; i++) { |
|
87
|
3 |
1 |
if (shm_ss_get(h, _ks, (uint32_t)_kl, _ku, &out_s, &out_l, &out_u)) { |
|
89
|
0 |
3 |
if (out_u) SvUTF8_on(sv); |
|
98
|
0 |
2 |
uint32_t now = h->expires_at ? shm_now() : 0; |
|
101
|
9 |
2 |
for (int i = 0; i < nkeys; i++) { |
|
109
|
13 |
0 |
for (uint32_t j = 0; j <= mask; j++) { |
|
112
|
2 |
11 |
if (st == SHM_EMPTY) break; |
|
113
|
4 |
7 |
if (st != tag) continue; |
|
114
|
7 |
0 |
if (shm_ss__key_eq_str(&nodes[idx], arena, _ks, (uint32_t)_kl, _ku)) { |
|
115
|
0 |
7 |
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; |
|
119
|
7 |
2 |
if (found) { |
|
123
|
0 |
7 |
if (SHM_UNPACK_UTF8(nodes[vidx].val_len)) SvUTF8_on(sv); |
|
127
|
7 |
2 |
if (i + 1 < nkeys) { |
|
138
|
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); |
|
159
|
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); |
|
160
|
0 |
0 |
EXTRACT_STR_KEY(key_sv); |
|
161
|
0 |
0 |
RETVAL = shm_ss_persist(h, _kstr, (uint32_t)_klen, _kutf8); |
|
168
|
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); |
|
169
|
0 |
0 |
EXTRACT_STR_KEY(key_sv); |
|
170
|
0 |
0 |
RETVAL = shm_ss_set_ttl(h, _kstr, (uint32_t)_klen, _kutf8, (uint32_t)ttl_sec); |
|
177
|
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); |
|
178
|
0 |
1 |
EXTRACT_STR_KEY(key_sv); |
|
179
|
0 |
1 |
EXTRACT_STR_VAL(value); |
|
180
|
0 |
1 |
REQUIRE_TTL(h); |
|
|
0 |
1 |
REQUIRE_TTL(h); |
|
181
|
1 |
0 |
RETVAL = shm_ss_put_ttl(h, _kstr, (uint32_t)_klen, _kutf8, _vstr, (uint32_t)_vlen, _vutf8, (uint32_t)ttl_sec); |
|
188
|
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); |
|
189
|
0 |
0 |
RETVAL = (UV)shm_ss_max_size(h); |
|
196
|
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); |
|
197
|
0 |
0 |
RETVAL = (UV)shm_ss_ttl(h); |
|
204
|
2535 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
|
0 |
2535 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
|
0 |
2535 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
205
|
0 |
2535 |
EXTRACT_STR_KEY(key_sv); |
|
207
|
5 |
2530 |
if (!shm_ss_get(h, _kstr, (uint32_t)_klen, _kutf8, &val, &val_len, &val_utf8)) |
|
210
|
4 |
2526 |
if (val_utf8) SvUTF8_on(RETVAL); |
|
217
|
5 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
|
0 |
5 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
|
0 |
5 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
218
|
0 |
5 |
EXTRACT_STR_KEY(key_sv); |
|
219
|
5 |
0 |
RETVAL = shm_ss_remove(h, _kstr, (uint32_t)_klen, _kutf8); |
|
226
|
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); |
|
227
|
0 |
3 |
EXTRACT_STR_KEY(key_sv); |
|
228
|
3 |
0 |
RETVAL = shm_ss_exists(h, _kstr, (uint32_t)_klen, _kutf8); |
|
235
|
13 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
|
0 |
13 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
|
0 |
13 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
236
|
0 |
13 |
RETVAL = (UV)shm_ss_size(h); |
|
243
|
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); |
|
244
|
0 |
0 |
RETVAL = (UV)shm_ss_max_entries(h); |
|
251
|
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); |
|
252
|
1 |
1 |
uint32_t ns = h->shard_handles ? h->num_shards : 1; |
|
253
|
5 |
2 |
for (uint32_t si = 0; si < ns; si++) { |
|
254
|
4 |
1 |
ShmHandle *sh = h->shard_handles ? h->shard_handles[si] : h; |
|
257
|
0 |
5 |
uint32_t now = sh->expires_at ? shm_now() : 0; |
|
259
|
0 |
5 |
EXTEND(SP, hdr->size); |
|
260
|
80 |
5 |
for (uint32_t i = 0; i < hdr->table_cap; i++) { |
|
261
|
33 |
47 |
if (SHM_IS_LIVE(sh->states[i]) && !SHM_IS_EXPIRED(sh, i, now)) { |
|
|
0 |
33 |
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)) { |
|
265
|
0 |
33 |
if (SHM_UNPACK_UTF8(nodes[i].key_len)) SvUTF8_on(sv); |
|
266
|
0 |
33 |
mXPUSHs(sv); |
|
274
|
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); |
|
275
|
1 |
1 |
uint32_t ns = h->shard_handles ? h->num_shards : 1; |
|
276
|
5 |
2 |
for (uint32_t si = 0; si < ns; si++) { |
|
277
|
4 |
1 |
ShmHandle *sh = h->shard_handles ? h->shard_handles[si] : h; |
|
280
|
0 |
5 |
uint32_t now = sh->expires_at ? shm_now() : 0; |
|
282
|
0 |
5 |
EXTEND(SP, hdr->size); |
|
283
|
80 |
5 |
for (uint32_t i = 0; i < hdr->table_cap; i++) { |
|
284
|
33 |
47 |
if (SHM_IS_LIVE(sh->states[i]) && !SHM_IS_EXPIRED(sh, i, now)) { |
|
|
0 |
33 |
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)) { |
|
288
|
0 |
33 |
if (SHM_UNPACK_UTF8(nodes[i].val_len)) SvUTF8_on(sv); |
|
289
|
0 |
33 |
mXPUSHs(sv); |
|
297
|
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); |
|
298
|
0 |
1 |
uint32_t ns = h->shard_handles ? h->num_shards : 1; |
|
299
|
1 |
1 |
for (uint32_t si = 0; si < ns; si++) { |
|
300
|
0 |
1 |
ShmHandle *sh = h->shard_handles ? h->shard_handles[si] : h; |
|
303
|
0 |
1 |
uint32_t now = sh->expires_at ? shm_now() : 0; |
|
305
|
0 |
1 |
EXTEND(SP, hdr->size * 2); |
|
306
|
16 |
1 |
for (uint32_t i = 0; i < hdr->table_cap; i++) { |
|
307
|
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)) { |
|
311
|
0 |
3 |
if (SHM_UNPACK_UTF8(nodes[i].key_len)) SvUTF8_on(ksv); |
|
312
|
0 |
3 |
mXPUSHs(ksv); |
|
316
|
0 |
3 |
if (SHM_UNPACK_UTF8(nodes[i].val_len)) SvUTF8_on(vsv); |
|
317
|
0 |
3 |
mXPUSHs(vsv); |
|
326
|
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); |
|
330
|
2 |
1 |
if (shm_ss_each(h, &out_key, &out_klen, &out_kutf8, &out_val, &out_vlen, &out_vutf8)) { |
|
331
|
0 |
2 |
EXTEND(SP, 2); |
|
333
|
0 |
2 |
if (out_kutf8) SvUTF8_on(ksv); |
|
334
|
0 |
2 |
mXPUSHs(ksv); |
|
336
|
0 |
2 |
if (out_vutf8) SvUTF8_on(vsv); |
|
337
|
0 |
2 |
mXPUSHs(vsv); |
|
346
|
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); |
|
353
|
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); |
|
359
|
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); |
|
361
|
1 |
1 |
uint32_t ns = h->shard_handles ? h->num_shards : 1; |
|
362
|
5 |
2 |
for (uint32_t si = 0; si < ns; si++) { |
|
363
|
4 |
1 |
ShmHandle *sh = h->shard_handles ? h->shard_handles[si] : h; |
|
366
|
0 |
5 |
uint32_t now = sh->expires_at ? shm_now() : 0; |
|
368
|
80 |
5 |
for (uint32_t i = 0; i < hdr->table_cap; i++) { |
|
369
|
32 |
48 |
if (SHM_IS_LIVE(sh->states[i]) && !SHM_IS_EXPIRED(sh, i, now)) { |
|
|
0 |
32 |
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)) { |
|
376
|
0 |
32 |
if (SHM_UNPACK_UTF8(nodes[i].val_len)) SvUTF8_on(val); |
|
377
|
0 |
32 |
if (!hv_store(hv, kp, |
|
|
0 |
32 |
if (!hv_store(hv, kp, |
|
389
|
8 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
|
0 |
8 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
|
0 |
8 |
EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv); |
|
390
|
0 |
8 |
EXTRACT_STR_KEY(key_sv); |
|
392
|
0 |
8 |
EXTRACT_STR_VAL(default_sv); |
|
394
|
0 |
8 |
if (!rc) XSRETURN_UNDEF; |
|
396
|
0 |
8 |
if (out_utf8) SvUTF8_on(RETVAL); |
|
403
|
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); |
|
404
|
0 |
2 |
EXTRACT_STR_KEY(key_sv); |
|
406
|
1 |
1 |
if (remaining < 0) XSRETURN_UNDEF; |
|
414
|
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); |
|
415
|
0 |
2 |
RETVAL = (UV)shm_ss_capacity(h); |
|
422
|
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); |
|
423
|
0 |
0 |
RETVAL = (UV)shm_ss_tombstones(h); |
|
430
|
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); |
|
432
|
0 |
4 |
if (!c) croak("Failed to allocate cursor"); |
|
440
|
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); |
|
441
|
0 |
6 |
EXTRACT_STR_KEY(key_sv); |
|
443
|
1 |
5 |
if (!shm_ss_take(h, _kstr, (uint32_t)_klen, _kutf8, &out_str, &out_len, &out_utf8)) XSRETURN_UNDEF; |
|
445
|
2 |
3 |
if (out_utf8) SvUTF8_on(RETVAL); |
|
452
|
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); |
|
455
|
0 |
2 |
if (!shm_ss_pop(h, &out_key, &out_klen, &out_kutf8, &out_val, &out_vlen, &out_vutf8)) XSRETURN_EMPTY; |
|
456
|
0 |
2 |
EXTEND(SP, 2); |
|
458
|
0 |
2 |
if (out_kutf8) SvUTF8_on(ksv); |
|
461
|
0 |
2 |
if (out_vutf8) SvUTF8_on(vsv); |
|
467
|
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); |
|
470
|
0 |
1 |
if (!shm_ss_shift(h, &out_key, &out_klen, &out_kutf8, &out_val, &out_vlen, &out_vutf8)) XSRETURN_EMPTY; |
|
471
|
0 |
1 |
EXTEND(SP, 2); |
|
473
|
0 |
1 |
if (out_kutf8) SvUTF8_on(ksv); |
|
476
|
0 |
1 |
if (out_vutf8) SvUTF8_on(vsv); |
|
482
|
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); |
|
483
|
0 |
3 |
if (limit == 0) XSRETURN_EMPTY; |
|
485
|
0 |
3 |
if (!entries) croak("drain: out of memory"); |
|
489
|
3 |
0 |
if (buf) SAVEFREEPV(buf); |
|
490
|
0 |
3 |
EXTEND(SP, n * 2); |
|
491
|
9 |
3 |
for (uint32_t i = 0; i < n; i++) { |
|
493
|
0 |
9 |
if (entries[i].key_utf8) SvUTF8_on(ksv); |
|
496
|
0 |
9 |
if (entries[i].val_utf8) SvUTF8_on(vsv); |
|
504
|
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); |
|
505
|
0 |
1 |
RETVAL = (UV)shm_ss_flush_expired(h); |
|
512
|
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); |
|
515
|
0 |
0 |
EXTEND(SP, 2); |
|
522
|
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); |
|
530
|
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); |
|
531
|
0 |
2 |
EXTRACT_STR_KEY(key_sv); |
|
532
|
1 |
1 |
RETVAL = shm_ss_touch(h, _kstr, (uint32_t)_klen, _kutf8); |
|
539
|
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); |
|
540
|
1 |
0 |
RETVAL = shm_ss_reserve(h, (uint32_t)target); |
|
547
|
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); |
|
555
|
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); |
|
563
|
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); |
|
564
|
0 |
0 |
RETVAL = (UV)shm_ss_stat_recoveries(h); |
|
571
|
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); |
|
579
|
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); |
|
587
|
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); |
|
588
|
0 |
0 |
EXTRACT_STR_KEY(key_sv); |
|
589
|
0 |
0 |
EXTRACT_STR_VAL(val_sv); |
|
590
|
0 |
0 |
RETVAL = shm_ss_add(h, _kstr, (uint32_t)_klen, _kutf8, _vstr, (uint32_t)_vlen, _vutf8); |
|
597
|
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); |
|
598
|
0 |
0 |
EXTRACT_STR_KEY(key_sv); |
|
599
|
0 |
0 |
EXTRACT_STR_VAL(val_sv); |
|
600
|
0 |
0 |
RETVAL = shm_ss_update(h, _kstr, (uint32_t)_klen, _kutf8, _vstr, (uint32_t)_vlen, _vutf8); |
|
607
|
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); |
|
608
|
0 |
4 |
EXTRACT_STR_KEY(key_sv); |
|
609
|
0 |
4 |
EXTRACT_STR_VAL(val_sv); |
|
612
|
2 |
2 |
if (rc != 1) XSRETURN_UNDEF; |
|
614
|
0 |
2 |
if (out_u) SvUTF8_on(RETVAL); |
|
621
|
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); |
|
630
|
0 |
0 |
if (SvROK(self_or_class) && SvOBJECT(SvRV(self_or_class))) { |
|
|
0 |
0 |
if (SvROK(self_or_class) && SvOBJECT(SvRV(self_or_class))) { |
|
632
|
0 |
0 |
if (!h) croak("Attempted to use a destroyed Data::HashMap::Shared::SS object"); |
|
635
|
0 |
0 |
if (items < 2) croak("Usage: Data::HashMap::Shared::SS->unlink($path)"); |
|
638
|
0 |
0 |
RETVAL = (SvROK(self_or_class) && SvOBJECT(SvRV(self_or_class))) ? |
|
|
0 |
0 |
RETVAL = (SvROK(self_or_class) && SvOBJECT(SvRV(self_or_class))) ? |
|
639
|
0 |
0 |
shm_unlink_sharded(INT2PTR(ShmHandle*, SvIV(SvRV(self_or_class)))) : |
|
650
|
0 |
4 |
if (!SvROK(self_sv)) return; |
|
652
|
0 |
4 |
if (!c) return; |
|
655
|
4 |
0 |
if (h) shm_ss_flush_deferred(h); |
|
661
|
29 |
0 |
EXTRACT_CURSOR("Data::HashMap::Shared::SS::Cursor", self_sv); |
|
|
0 |
29 |
EXTRACT_CURSOR("Data::HashMap::Shared::SS::Cursor", self_sv); |
|
|
0 |
29 |
EXTRACT_CURSOR("Data::HashMap::Shared::SS::Cursor", self_sv); |
|
665
|
27 |
2 |
if (shm_ss_cursor_next(c, &out_key, &out_klen, &out_kutf8, &out_val, &out_vlen, &out_vutf8)) { |
|
666
|
0 |
27 |
EXTEND(SP, 2); |
|
668
|
0 |
27 |
if (out_kutf8) SvUTF8_on(ksv); |
|
669
|
0 |
27 |
mXPUSHs(ksv); |
|
671
|
0 |
27 |
if (out_vutf8) SvUTF8_on(vsv); |
|
672
|
0 |
27 |
mXPUSHs(vsv); |
|
680
|
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); |
|
686
|
3 |
0 |
EXTRACT_CURSOR("Data::HashMap::Shared::SS::Cursor", self_sv); |
|
|
0 |
3 |
EXTRACT_CURSOR("Data::HashMap::Shared::SS::Cursor", self_sv); |
|
|
0 |
3 |
EXTRACT_CURSOR("Data::HashMap::Shared::SS::Cursor", self_sv); |
|
687
|
0 |
3 |
EXTRACT_STR_KEY(key_sv); |
|
688
|
2 |
1 |
RETVAL = shm_ss_cursor_seek(c, _kstr, (uint32_t)_klen, _kutf8); |