| line |
true |
false |
branch |
|
7
|
151 |
1 |
char errbuf[SHM_ERR_BUFLEN]; const char* path = SvOK(path_sv) ? SvPV_nolen(path_sv) : NULL; ShmHandle* map = shm_ii_create(path, (uint32_t)max_entries, (uint32_t)lru_max, (uint32_t)ttl_default, (uint32_t)lru_skip, errbuf); |
|
8
|
2 |
150 |
if (!map) croak("HashMap::Shared::II: %s", errbuf[0] ? errbuf : "unknown error"); |
|
|
2 |
0 |
if (!map) croak("HashMap::Shared::II: %s", errbuf[0] ? errbuf : "unknown error"); |
|
17
|
0 |
17 |
if (!map) croak("HashMap::Shared::II: %s", errbuf[0] ? errbuf : "unknown error"); |
|
|
0 |
0 |
if (!map) croak("HashMap::Shared::II: %s", errbuf[0] ? errbuf : "unknown error"); |
|
27
|
3 |
0 |
const char* name = SvOK(name_sv) ? SvPV_nolen(name_sv) : NULL; |
|
29
|
0 |
3 |
if (!map) croak("Data::HashMap::Shared::II: %s", errbuf[0] ? errbuf : "unknown error"); |
|
|
0 |
0 |
if (!map) croak("Data::HashMap::Shared::II: %s", errbuf[0] ? errbuf : "unknown error"); |
|
39
|
1 |
1 |
if (!map) croak("Data::HashMap::Shared::II: %s", errbuf[0] ? errbuf : "unknown error"); |
|
|
1 |
0 |
if (!map) croak("Data::HashMap::Shared::II: %s", errbuf[0] ? errbuf : "unknown error"); |
|
47
|
2 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
|
0 |
2 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
|
0 |
2 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
48
|
0 |
2 |
RETVAL = h->backing_fd; |
|
56
|
1 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
|
0 |
1 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
|
0 |
1 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
57
|
0 |
1 |
if (shm_msync(h) != 0) croak("Data::HashMap::Shared::II sync: %s", strerror(errno)); |
|
62
|
0 |
171 |
if (!SvROK(self_sv)) return; |
|
64
|
0 |
171 |
if (!h) return; |
|
71
|
17220 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
|
0 |
17220 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
|
0 |
17220 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
72
|
17151 |
69 |
RETVAL = shm_ii_put(h, key, value); |
|
79
|
6 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
|
0 |
6 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
|
0 |
6 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
80
|
1 |
5 |
if ((items - 1) % 2 != 0) croak("set_multi requires even number of arguments (key, value pairs)"); |
|
82
|
1 |
4 |
if (h->shard_handles) { |
|
83
|
5 |
1 |
for (int i = 1; i < items; i += 2) |
|
89
|
1008 |
4 |
for (int i = 1; i < items; i += 2) |
|
94
|
0 |
5 |
RETVAL = count; |
|
101
|
2 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
|
0 |
2 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
|
0 |
2 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
103
|
0 |
2 |
if (h->shard_handles) { |
|
104
|
0 |
0 |
for (int i = 1; i < items; i++) |
|
110
|
3 |
2 |
for (int i = 1; i < items; i++) |
|
112
|
1 |
1 |
if (count) shm_ii_maybe_shrink(h); |
|
116
|
0 |
2 |
RETVAL = count; |
|
123
|
4 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
|
0 |
4 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
|
0 |
4 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
125
|
1 |
3 |
if (nkeys == 0) XSRETURN_EMPTY; |
|
126
|
3 |
0 |
EXTEND(SP, nkeys); |
|
|
0 |
3 |
EXTEND(SP, nkeys); |
|
127
|
1 |
2 |
if (h->shard_handles) { |
|
128
|
4 |
1 |
for (int i = 0; i < nkeys; i++) { |
|
131
|
3 |
1 |
if (shm_ii_get(h, key, &val)) |
|
140
|
1 |
1 |
uint32_t now = h->expires_at ? shm_now() : 0; |
|
147
|
7 |
2 |
for (int i = 0; i < nkeys; i++) { |
|
153
|
7 |
2 |
for (int i = 0; i < nkeys; i++) { |
|
160
|
9 |
0 |
for (uint32_t j = 0; j <= mask; j++) { |
|
163
|
1 |
8 |
if (st == SHM_EMPTY) break; |
|
164
|
2 |
6 |
if (st != tag) continue; |
|
165
|
6 |
0 |
if (nodes[idx].key == key) { |
|
166
|
3 |
3 |
if (h->expires_at && h->expires_at[idx] && now >= h->expires_at[idx]) break; |
|
|
3 |
0 |
if (h->expires_at && h->expires_at[idx] && now >= h->expires_at[idx]) break; |
|
|
1 |
2 |
if (h->expires_at && h->expires_at[idx] && now >= h->expires_at[idx]) break; |
|
172
|
5 |
2 |
if (found) mPUSHi(val); |
|
175
|
5 |
2 |
if (i + 1 < nkeys) { |
|
186
|
3 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
|
0 |
3 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
|
0 |
3 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
189
|
2 |
1 |
if (!shm_ii_get_with_ttl(h, key, &out_value, &out_ttl)) XSRETURN_EMPTY; |
|
190
|
0 |
1 |
EXTEND(SP, 2); |
|
192
|
1 |
0 |
if (out_ttl < 0) PUSHs(&PL_sv_undef); |
|
198
|
2 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
|
0 |
2 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
|
0 |
2 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
219
|
6 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
|
0 |
6 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
|
0 |
6 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
220
|
3 |
3 |
RETVAL = shm_ii_cas(h, key, expected, desired); |
|
227
|
4 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
|
0 |
4 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
|
0 |
4 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
229
|
2 |
2 |
if (!shm_ii_cas_take(h, key, expected, &out_value)) XSRETURN_UNDEF; |
|
237
|
4 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
|
0 |
4 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
|
0 |
4 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
238
|
3 |
1 |
RETVAL = shm_ii_persist(h, key); |
|
245
|
5 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
|
0 |
5 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
|
0 |
5 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
246
|
4 |
1 |
RETVAL = shm_ii_set_ttl(h, key, (uint32_t)ttl_sec); |
|
253
|
10902 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
|
0 |
10902 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
|
0 |
10902 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
255
|
86 |
10816 |
if (!shm_ii_get(h, key, &value)) XSRETURN_UNDEF; |
|
263
|
12785 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
|
0 |
12785 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
|
0 |
12785 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
264
|
12785 |
0 |
RETVAL = shm_ii_remove(h, key); |
|
271
|
61 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
|
0 |
61 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
|
0 |
61 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
272
|
29 |
32 |
RETVAL = shm_ii_exists(h, key); |
|
279
|
8 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
|
0 |
8 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
|
0 |
8 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
282
|
0 |
8 |
if (!ok) croak("HashMap::Shared::II: increment failed"); |
|
290
|
3 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
|
0 |
3 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
|
0 |
3 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
293
|
0 |
3 |
if (!ok) croak("HashMap::Shared::II: decrement failed"); |
|
301
|
6 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
|
0 |
6 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
|
0 |
6 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
304
|
0 |
6 |
if (!ok) croak("HashMap::Shared::II: incr_by failed"); |
|
312
|
75 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
|
0 |
75 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
|
0 |
75 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
313
|
0 |
75 |
RETVAL = (UV)shm_ii_size(h); |
|
320
|
3 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
|
0 |
3 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
|
0 |
3 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
321
|
0 |
3 |
RETVAL = (UV)shm_ii_max_entries(h); |
|
328
|
3 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
|
0 |
3 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
|
0 |
3 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
329
|
1 |
2 |
uint32_t ns = h->shard_handles ? h->num_shards : 1; |
|
330
|
6 |
3 |
for (uint32_t si = 0; si < ns; si++) { |
|
331
|
4 |
2 |
ShmHandle *sh = h->shard_handles ? h->shard_handles[si] : h; |
|
334
|
1 |
5 |
uint32_t now = sh->expires_at ? shm_now() : 0; |
|
336
|
0 |
6 |
EXTEND(SP, hdr->size); |
|
337
|
128 |
6 |
for (uint32_t i = 0; i < hdr->table_cap; i++) { |
|
338
|
55 |
73 |
if (SHM_IS_LIVE(sh->states[i]) && !SHM_IS_EXPIRED(sh, i, now)) |
|
|
2 |
53 |
if (SHM_IS_LIVE(sh->states[i]) && !SHM_IS_EXPIRED(sh, i, now)) |
|
|
2 |
0 |
if (SHM_IS_LIVE(sh->states[i]) && !SHM_IS_EXPIRED(sh, i, now)) |
|
|
1 |
1 |
if (SHM_IS_LIVE(sh->states[i]) && !SHM_IS_EXPIRED(sh, i, now)) |
|
339
|
0 |
54 |
mXPUSHi(nodes[i].key); |
|
346
|
2 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
|
0 |
2 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
|
0 |
2 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
347
|
1 |
1 |
uint32_t ns = h->shard_handles ? h->num_shards : 1; |
|
348
|
5 |
2 |
for (uint32_t si = 0; si < ns; si++) { |
|
349
|
4 |
1 |
ShmHandle *sh = h->shard_handles ? h->shard_handles[si] : h; |
|
352
|
0 |
5 |
uint32_t now = sh->expires_at ? shm_now() : 0; |
|
354
|
0 |
5 |
EXTEND(SP, hdr->size); |
|
355
|
112 |
5 |
for (uint32_t i = 0; i < hdr->table_cap; i++) { |
|
356
|
53 |
59 |
if (SHM_IS_LIVE(sh->states[i]) && !SHM_IS_EXPIRED(sh, i, now)) |
|
|
0 |
53 |
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)) |
|
357
|
0 |
53 |
mXPUSHi(nodes[i].value); |
|
364
|
2 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
|
0 |
2 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
|
0 |
2 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
365
|
1 |
1 |
uint32_t ns = h->shard_handles ? h->num_shards : 1; |
|
366
|
5 |
2 |
for (uint32_t si = 0; si < ns; si++) { |
|
367
|
4 |
1 |
ShmHandle *sh = h->shard_handles ? h->shard_handles[si] : h; |
|
370
|
0 |
5 |
uint32_t now = sh->expires_at ? shm_now() : 0; |
|
372
|
0 |
5 |
EXTEND(SP, hdr->size * 2); |
|
373
|
112 |
5 |
for (uint32_t i = 0; i < hdr->table_cap; i++) { |
|
374
|
53 |
59 |
if (SHM_IS_LIVE(sh->states[i]) && !SHM_IS_EXPIRED(sh, i, now)) { |
|
|
0 |
53 |
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)) { |
|
375
|
0 |
53 |
mXPUSHi(nodes[i].key); |
|
376
|
0 |
53 |
mXPUSHi(nodes[i].value); |
|
385
|
662 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
|
0 |
662 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
|
0 |
662 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
387
|
649 |
13 |
if (shm_ii_each(h, &out_key, &out_value)) { |
|
388
|
0 |
649 |
EXTEND(SP, 2); |
|
389
|
0 |
649 |
mXPUSHi(out_key); |
|
390
|
0 |
649 |
mXPUSHi(out_value); |
|
399
|
2 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
|
0 |
2 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
|
0 |
2 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
406
|
7 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
|
0 |
7 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
|
0 |
7 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
412
|
2 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
|
0 |
2 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
|
0 |
2 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
414
|
1 |
1 |
uint32_t ns = h->shard_handles ? h->num_shards : 1; |
|
415
|
5 |
2 |
for (uint32_t si = 0; si < ns; si++) { |
|
416
|
4 |
1 |
ShmHandle *sh = h->shard_handles ? h->shard_handles[si] : h; |
|
419
|
0 |
5 |
uint32_t now = sh->expires_at ? shm_now() : 0; |
|
421
|
112 |
5 |
for (uint32_t i = 0; i < hdr->table_cap; i++) { |
|
422
|
52 |
60 |
if (SHM_IS_LIVE(sh->states[i]) && !SHM_IS_EXPIRED(sh, i, now)) { |
|
|
0 |
52 |
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)) { |
|
426
|
0 |
52 |
if (!hv_store(hv, kbuf, klen, val, 0)) SvREFCNT_dec(val); |
|
438
|
7 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
|
0 |
7 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
|
0 |
7 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
441
|
0 |
7 |
if (!rc) XSRETURN_UNDEF; |
|
449
|
23 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
|
0 |
23 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
|
0 |
23 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
450
|
1 |
22 |
REQUIRE_TTL(h); |
|
|
1 |
22 |
REQUIRE_TTL(h); |
|
451
|
22 |
0 |
RETVAL = shm_ii_put_ttl(h, key, value, (uint32_t)ttl_sec); |
|
458
|
5 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
|
0 |
5 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
|
0 |
5 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
459
|
0 |
5 |
RETVAL = (UV)shm_ii_max_size(h); |
|
466
|
5 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
|
0 |
5 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
|
0 |
5 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
467
|
0 |
5 |
RETVAL = (UV)shm_ii_ttl(h); |
|
474
|
5 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
|
0 |
5 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
|
0 |
5 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
476
|
2 |
3 |
if (!shm_ii_take(h, key, &out_value)) XSRETURN_UNDEF; |
|
484
|
12 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
|
0 |
12 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
|
0 |
12 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
487
|
2 |
10 |
if (!shm_ii_pop(h, &out_key, &out_val)) XSRETURN_EMPTY; |
|
488
|
0 |
10 |
EXTEND(SP, 2); |
|
495
|
8 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
|
0 |
8 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
|
0 |
8 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
498
|
1 |
7 |
if (!shm_ii_shift(h, &out_key, &out_val)) XSRETURN_EMPTY; |
|
499
|
0 |
7 |
EXTEND(SP, 2); |
|
506
|
6 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
|
0 |
6 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
|
0 |
6 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
507
|
0 |
6 |
if (limit == 0) XSRETURN_EMPTY; |
|
509
|
0 |
6 |
Newxz(entries, limit, shm_ii_drain_entry); |
|
515
|
0 |
6 |
EXTEND(SP, n * 2); |
|
516
|
15 |
6 |
for (uint32_t i = 0; i < n; i++) { |
|
520
|
0 |
6 |
if (buf) free(buf); |
|
526
|
8 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
|
0 |
8 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
|
0 |
8 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
527
|
0 |
8 |
RETVAL = (UV)shm_ii_flush_expired(h); |
|
534
|
27 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
|
0 |
27 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
|
0 |
27 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
537
|
0 |
27 |
EXTEND(SP, 2); |
|
544
|
4 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
|
0 |
4 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
|
0 |
4 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
552
|
9 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
|
0 |
9 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
|
0 |
9 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
553
|
6 |
3 |
RETVAL = shm_ii_touch(h, key); |
|
560
|
9 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
|
0 |
9 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
|
0 |
9 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
561
|
6 |
3 |
RETVAL = shm_ii_reserve(h, (uint32_t)target); |
|
568
|
11 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
|
0 |
11 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
|
0 |
11 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
576
|
6 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
|
0 |
6 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
|
0 |
6 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
584
|
2 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
|
0 |
2 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
|
0 |
2 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
585
|
0 |
2 |
RETVAL = (UV)shm_ii_stat_recoveries(h); |
|
592
|
2 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
|
0 |
2 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
|
0 |
2 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
600
|
2 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
|
0 |
2 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
|
0 |
2 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
608
|
11 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
|
0 |
11 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
|
0 |
11 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
609
|
8 |
3 |
RETVAL = shm_ii_add(h, key, value); |
|
616
|
6 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
|
0 |
6 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
|
0 |
6 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
617
|
0 |
6 |
REQUIRE_TTL(h); |
|
|
1 |
5 |
REQUIRE_TTL(h); |
|
618
|
4 |
1 |
RETVAL = shm_ii_add_ttl(h, key, value, (uint32_t)ttl_sec); |
|
625
|
6 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
|
0 |
6 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
|
0 |
6 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
626
|
4 |
2 |
RETVAL = shm_ii_update(h, key, value); |
|
633
|
4 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
|
0 |
4 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
|
0 |
4 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
634
|
0 |
4 |
REQUIRE_TTL(h); |
|
|
1 |
3 |
REQUIRE_TTL(h); |
|
635
|
2 |
1 |
RETVAL = shm_ii_update_ttl(h, key, value, (uint32_t)ttl_sec); |
|
642
|
8 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
|
0 |
8 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
|
0 |
8 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
645
|
3 |
5 |
if (rc != 1) XSRETURN_UNDEF; |
|
653
|
4 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
|
0 |
4 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
|
0 |
4 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
654
|
2 |
2 |
RETVAL = h->path ? newSVpv(h->path, 0) : &PL_sv_undef; |
|
662
|
2 |
2 |
if (SvROK(self_or_class) && SvOBJECT(SvRV(self_or_class))) { |
|
|
2 |
0 |
if (SvROK(self_or_class) && SvOBJECT(SvRV(self_or_class))) { |
|
664
|
0 |
2 |
if (!h) croak("Attempted to use a destroyed Data::HashMap::Shared::II object"); |
|
667
|
0 |
2 |
if (items < 2) croak("Usage: Data::HashMap::Shared::II->unlink($path)"); |
|
670
|
2 |
0 |
RETVAL = (SvROK(self_or_class) && SvOBJECT(SvRV(self_or_class))) ? |
|
|
3 |
1 |
RETVAL = (SvROK(self_or_class) && SvOBJECT(SvRV(self_or_class))) ? |
|
671
|
2 |
2 |
shm_unlink_sharded(INT2PTR(ShmHandle*, SvIV(SvRV(self_or_class)))) : |
|
679
|
38 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
|
0 |
38 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
|
0 |
38 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
681
|
2 |
36 |
if (remaining < 0) XSRETURN_UNDEF; |
|
689
|
20 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
|
0 |
20 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
|
0 |
20 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
690
|
0 |
20 |
RETVAL = (UV)shm_ii_capacity(h); |
|
697
|
7 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
|
0 |
7 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
|
0 |
7 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
698
|
0 |
7 |
RETVAL = (UV)shm_ii_tombstones(h); |
|
705
|
18 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
|
0 |
18 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
|
0 |
18 |
EXTRACT_MAP("Data::HashMap::Shared::II", self_sv); |
|
707
|
0 |
18 |
if (!c) croak("Failed to allocate cursor"); |
|
718
|
0 |
18 |
if (!SvROK(self_sv)) return; |
|
720
|
0 |
18 |
if (!c) return; |
|
723
|
18 |
0 |
if (h) shm_ii_flush_deferred(h); |
|
729
|
745 |
0 |
EXTRACT_CURSOR("Data::HashMap::Shared::II::Cursor", self_sv); |
|
|
0 |
745 |
EXTRACT_CURSOR("Data::HashMap::Shared::II::Cursor", self_sv); |
|
|
0 |
745 |
EXTRACT_CURSOR("Data::HashMap::Shared::II::Cursor", self_sv); |
|
731
|
731 |
14 |
if (shm_ii_cursor_next(c, &out_key, &out_value)) { |
|
732
|
0 |
731 |
EXTEND(SP, 2); |
|
733
|
0 |
731 |
mXPUSHi(out_key); |
|
734
|
0 |
731 |
mXPUSHi(out_value); |
|
742
|
2 |
0 |
EXTRACT_CURSOR("Data::HashMap::Shared::II::Cursor", self_sv); |
|
|
0 |
2 |
EXTRACT_CURSOR("Data::HashMap::Shared::II::Cursor", self_sv); |
|
|
0 |
2 |
EXTRACT_CURSOR("Data::HashMap::Shared::II::Cursor", self_sv); |
|
748
|
5 |
0 |
EXTRACT_CURSOR("Data::HashMap::Shared::II::Cursor", self_sv); |
|
|
0 |
5 |
EXTRACT_CURSOR("Data::HashMap::Shared::II::Cursor", self_sv); |
|
|
0 |
5 |
EXTRACT_CURSOR("Data::HashMap::Shared::II::Cursor", self_sv); |
|
749
|
3 |
2 |
RETVAL = shm_ii_cursor_seek(c, key); |