Branch Coverage

xs/si.xs
Criterion Covered Total %
branch 193 744 25.9


line true false branch
7 20 5 char errbuf[SHM_ERR_BUFLEN]; const char* path = SvOK(path_sv) ? SvPV_nolen(path_sv) : NULL; ShmHandle* map = shm_si_create(path, (uint32_t)max_entries, (uint32_t)lru_max, (uint32_t)ttl_default, (uint32_t)lru_skip, errbuf);
8 0 25 if (!map) croak("Data::HashMap::Shared::SI: %s", errbuf[0] ? errbuf : "unknown error");
0 0 if (!map) croak("Data::HashMap::Shared::SI: %s", errbuf[0] ? errbuf : "unknown error");
16 0 0 const char* path_prefix = SvOK(path_prefix_sv) ? SvPV_nolen(path_prefix_sv) : NULL;
18 0 0 if (!map) croak("Data::HashMap::Shared::SI: %s", errbuf[0] ? errbuf : "unknown error");
0 0 if (!map) croak("Data::HashMap::Shared::SI: %s", errbuf[0] ? errbuf : "unknown error");
28 0 0 const char* name = SvOK(name_sv) ? SvPV_nolen(name_sv) : NULL;
30 0 0 if (!map) croak("Data::HashMap::Shared::SI: %s", errbuf[0] ? errbuf : "unknown error");
0 0 if (!map) croak("Data::HashMap::Shared::SI: %s", errbuf[0] ? errbuf : "unknown error");
40 0 0 if (!map) croak("Data::HashMap::Shared::SI: %s", errbuf[0] ? errbuf : "unknown error");
0 0 if (!map) croak("Data::HashMap::Shared::SI: %s", errbuf[0] ? errbuf : "unknown error");
48 0 0 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
0 0 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
0 0 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
49 0 0 RETVAL = h->backing_fd;
57 0 0 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
0 0 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
0 0 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
58 0 0 if (shm_msync(h) != 0) croak("Data::HashMap::Shared::SI sync: %s", strerror(errno));
63 0 25 if (!SvROK(self_sv)) return;
65 0 25 if (!h) return;
72 19 0 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
0 19 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
0 19 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
73 0 19 EXTRACT_STR_KEY(key_sv);
74 19 0 RETVAL = shm_si_put(h, _kstr, (uint32_t)_klen, _kutf8, value);
81 0 0 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
0 0 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
0 0 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
82 0 0 if ((items - 1) % 2 != 0) croak("set_multi requires even number of arguments (key, value pairs)");
84 0 0 if (h->shard_handles) {
85 0 0 for (int i = 1; i < items; i += 2) {
88 0 0 if (_klen > SHM_MAX_STR_LEN) croak("key too long (max 1GB)");
93 0 0 for (int i = 1; i < items; i += 2) {
96 0 0 if (_klen > SHM_MAX_STR_LEN) croak("key too long (max 1GB)");
100 0 0 RETVAL = count;
107 0 0 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
0 0 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
0 0 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
109 0 0 if (h->shard_handles) {
110 0 0 for (int i = 1; i < items; i++) {
113 0 0 if (_kl > SHM_MAX_STR_LEN) croak("key too long (max 1GB)");
118 0 0 for (int i = 1; i < items; i++) {
121 0 0 if (_kl > SHM_MAX_STR_LEN) croak("key too long (max 1GB)");
124 0 0 if (count) shm_si_maybe_shrink(h);
126 0 0 RETVAL = count;
133 0 0 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
0 0 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
0 0 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
135 0 0 if (nkeys == 0) XSRETURN_EMPTY;
136 0 0 EXTEND(SP, nkeys);
0 0 EXTEND(SP, nkeys);
137 0 0 if (h->shard_handles) {
138 0 0 for (int i = 0; i < nkeys; i++) {
142 0 0 if (shm_si_get(h, _ks, (uint32_t)_kl, _ku, &val))
152 0 0 uint32_t now = h->expires_at ? shm_now() : 0;
155 0 0 for (int i = 0; i < nkeys; i++) {
163 0 0 for (uint32_t j = 0; j <= mask; j++) {
166 0 0 if (st == SHM_EMPTY) break;
167 0 0 if (st != tag) continue;
168 0 0 if (shm_si__key_eq_str(&nodes[idx], arena, _ks, (uint32_t)_kl, _ku)) {
169 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;
174 0 0 if (found) mPUSHi(val);
177 0 0 if (i + 1 < nkeys) {
188 1 0 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
0 1 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
0 1 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
189 0 1 EXTRACT_STR_KEY(key_sv);
192 0 1 if (!shm_si_get_with_ttl(h, _kstr, (uint32_t)_klen, _kutf8, &out_value, &out_ttl)) XSRETURN_EMPTY;
193 0 1 EXTEND(SP, 2);
195 0 1 if (out_ttl < 0) PUSHs(&PL_sv_undef);
201 1 0 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
0 1 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
0 1 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
222 3 0 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
0 3 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
0 3 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
223 0 3 EXTRACT_STR_KEY(key_sv);
224 2 1 RETVAL = shm_si_cas(h, _kstr, (uint32_t)_klen, _kutf8, expected, desired);
231 0 0 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
0 0 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
0 0 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
232 0 0 EXTRACT_STR_KEY(key_sv);
234 0 0 if (!shm_si_cas_take(h, _kstr, (uint32_t)_klen, _kutf8, expected, &out_value)) XSRETURN_UNDEF;
242 0 0 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
0 0 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
0 0 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
243 0 0 EXTRACT_STR_KEY(key_sv);
244 0 0 RETVAL = shm_si_persist(h, _kstr, (uint32_t)_klen, _kutf8);
251 1 0 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
0 1 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
0 1 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
252 0 1 EXTRACT_STR_KEY(key_sv);
253 1 0 RETVAL = shm_si_set_ttl(h, _kstr, (uint32_t)_klen, _kutf8, (uint32_t)ttl_sec);
260 1 0 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
0 1 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
0 1 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
261 0 1 EXTRACT_STR_KEY(key_sv);
262 0 1 REQUIRE_TTL(h);
0 1 REQUIRE_TTL(h);
263 1 0 RETVAL = shm_si_put_ttl(h, _kstr, (uint32_t)_klen, _kutf8, value, (uint32_t)ttl_sec);
270 0 0 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
0 0 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
0 0 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
271 0 0 RETVAL = (UV)shm_si_max_size(h);
278 0 0 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
0 0 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
0 0 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
279 0 0 RETVAL = (UV)shm_si_ttl(h);
286 28 0 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
0 28 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
0 28 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
287 0 28 EXTRACT_STR_KEY(key_sv);
289 1 27 if (!shm_si_get(h, _kstr, (uint32_t)_klen, _kutf8, &value)) XSRETURN_UNDEF;
297 1 0 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
0 1 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
0 1 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
298 0 1 EXTRACT_STR_KEY(key_sv);
299 1 0 RETVAL = shm_si_remove(h, _kstr, (uint32_t)_klen, _kutf8);
306 2 0 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
0 2 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
0 2 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
307 0 2 EXTRACT_STR_KEY(key_sv);
308 1 1 RETVAL = shm_si_exists(h, _kstr, (uint32_t)_klen, _kutf8);
315 2 0 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
0 2 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
0 2 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
316 0 2 EXTRACT_STR_KEY(key_sv);
319 0 2 if (!ok) croak("Data::HashMap::Shared::SI: increment failed");
327 1 0 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
0 1 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
0 1 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
328 0 1 EXTRACT_STR_KEY(key_sv);
331 0 1 if (!ok) croak("Data::HashMap::Shared::SI: decrement failed");
339 1 0 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
0 1 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
0 1 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
340 0 1 EXTRACT_STR_KEY(key_sv);
343 0 1 if (!ok) croak("Data::HashMap::Shared::SI: incr_by failed");
351 14 0 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
0 14 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
0 14 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
352 0 14 EXTRACT_STR_KEY(key_sv);
355 0 14 if (!ok) croak("Data::HashMap::Shared::SI: max failed");
363 10 0 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
0 10 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
0 10 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
364 0 10 EXTRACT_STR_KEY(key_sv);
367 0 10 if (!ok) croak("Data::HashMap::Shared::SI: min failed");
375 4 0 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
0 4 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
0 4 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
376 0 4 RETVAL = (UV)shm_si_size(h);
383 0 0 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
0 0 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
0 0 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
384 0 0 RETVAL = (UV)shm_si_max_entries(h);
391 1 0 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
0 1 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
0 1 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
392 0 1 uint32_t ns = h->shard_handles ? h->num_shards : 1;
393 1 1 for (uint32_t si = 0; si < ns; si++) {
394 0 1 ShmHandle *sh = h->shard_handles ? h->shard_handles[si] : h;
397 0 1 uint32_t now = sh->expires_at ? shm_now() : 0;
399 0 1 EXTEND(SP, hdr->size);
400 16 1 for (uint32_t i = 0; i < hdr->table_cap; i++) {
401 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)) {
405 0 2 if (SHM_UNPACK_UTF8(nodes[i].key_len)) SvUTF8_on(sv);
406 0 2 mXPUSHs(sv);
414 1 0 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
0 1 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
0 1 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
415 0 1 uint32_t ns = h->shard_handles ? h->num_shards : 1;
416 1 1 for (uint32_t si = 0; si < ns; si++) {
417 0 1 ShmHandle *sh = h->shard_handles ? h->shard_handles[si] : h;
420 0 1 uint32_t now = sh->expires_at ? shm_now() : 0;
422 0 1 EXTEND(SP, hdr->size);
423 16 1 for (uint32_t i = 0; i < hdr->table_cap; i++) {
424 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))
425 0 2 mXPUSHi(nodes[i].value);
432 0 0 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
0 0 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
0 0 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
433 0 0 uint32_t ns = h->shard_handles ? h->num_shards : 1;
434 0 0 for (uint32_t si = 0; si < ns; si++) {
435 0 0 ShmHandle *sh = h->shard_handles ? h->shard_handles[si] : h;
438 0 0 uint32_t now = sh->expires_at ? shm_now() : 0;
440 0 0 EXTEND(SP, hdr->size * 2);
441 0 0 for (uint32_t i = 0; i < hdr->table_cap; i++) {
442 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)) {
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)) {
446 0 0 if (SHM_UNPACK_UTF8(nodes[i].key_len)) SvUTF8_on(sv);
447 0 0 mXPUSHs(sv);
448 0 0 mXPUSHi(nodes[i].value);
457 0 0 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
0 0 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
0 0 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
460 0 0 if (shm_si_each(h, &out_key, &out_klen, &out_kutf8, &out_value)) {
461 0 0 EXTEND(SP, 2);
463 0 0 if (out_kutf8) SvUTF8_on(ksv);
464 0 0 mXPUSHs(ksv);
465 0 0 mXPUSHi(out_value);
474 0 0 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
0 0 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
0 0 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
481 0 0 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
0 0 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
0 0 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
487 1 0 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
0 1 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
0 1 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
489 0 1 uint32_t ns = h->shard_handles ? h->num_shards : 1;
490 1 1 for (uint32_t si = 0; si < ns; si++) {
491 0 1 ShmHandle *sh = h->shard_handles ? h->shard_handles[si] : h;
494 0 1 uint32_t now = sh->expires_at ? shm_now() : 0;
496 16 1 for (uint32_t i = 0; i < hdr->table_cap; i++) {
497 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)) {
502 0 2 if (!hv_store(hv, kp,
0 2 if (!hv_store(hv, kp,
515 0 0 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
0 0 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
0 0 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
516 0 0 EXTRACT_STR_KEY(key_sv);
519 0 0 if (!rc) XSRETURN_UNDEF;
527 1 0 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
0 1 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
0 1 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
528 0 1 EXTRACT_STR_KEY(key_sv);
530 0 1 if (!shm_si_take(h, _kstr, (uint32_t)_klen, _kutf8, &out_value)) XSRETURN_UNDEF;
538 0 0 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
0 0 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
0 0 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
541 0 0 if (!shm_si_pop(h, &out_key, &out_klen, &out_kutf8, &out_val)) XSRETURN_EMPTY;
542 0 0 EXTEND(SP, 2);
544 0 0 if (out_kutf8) SvUTF8_on(ksv);
551 0 0 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
0 0 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
0 0 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
554 0 0 if (!shm_si_shift(h, &out_key, &out_klen, &out_kutf8, &out_val)) XSRETURN_EMPTY;
555 0 0 EXTEND(SP, 2);
557 0 0 if (out_kutf8) SvUTF8_on(ksv);
564 0 0 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
0 0 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
0 0 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
565 0 0 if (limit == 0) XSRETURN_EMPTY;
567 0 0 Newxz(entries, limit, shm_si_drain_entry);
572 0 0 if (buf) SAVEDESTRUCTOR_X(shm_free_cleanup, buf);
574 0 0 EXTEND(SP, n * 2);
575 0 0 for (uint32_t i = 0; i < n; i++) {
577 0 0 if (entries[i].key_utf8) SvUTF8_on(ksv);
586 0 0 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
0 0 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
0 0 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
587 0 0 RETVAL = (UV)shm_si_flush_expired(h);
594 0 0 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
0 0 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
0 0 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
597 0 0 EXTEND(SP, 2);
604 0 0 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
0 0 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
0 0 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
612 1 0 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
0 1 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
0 1 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
613 0 1 EXTRACT_STR_KEY(key_sv);
614 1 0 RETVAL = shm_si_touch(h, _kstr, (uint32_t)_klen, _kutf8);
621 0 0 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
0 0 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
0 0 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
622 0 0 RETVAL = shm_si_reserve(h, (uint32_t)target);
629 0 0 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
0 0 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
0 0 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
637 0 0 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
0 0 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
0 0 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
645 0 0 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
0 0 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
0 0 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
646 0 0 RETVAL = (UV)shm_si_stat_recoveries(h);
653 0 0 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
0 0 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
0 0 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
661 0 0 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
0 0 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
0 0 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
669 3 0 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
0 3 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
0 3 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
670 0 3 EXTRACT_STR_KEY(key_sv);
671 1 2 RETVAL = shm_si_add(h, _kstr, (uint32_t)_klen, _kutf8, value);
678 2 0 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
0 2 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
0 2 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
679 0 2 EXTRACT_STR_KEY(key_sv);
680 0 2 REQUIRE_TTL(h);
0 2 REQUIRE_TTL(h);
681 1 1 RETVAL = shm_si_add_ttl(h, _kstr, (uint32_t)_klen, _kutf8, value, (uint32_t)ttl_sec);
688 2 0 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
0 2 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
0 2 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
689 0 2 EXTRACT_STR_KEY(key_sv);
690 2 0 RETVAL = shm_si_update(h, _kstr, (uint32_t)_klen, _kutf8, value);
697 0 0 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
0 0 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
0 0 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
698 0 0 EXTRACT_STR_KEY(key_sv);
699 0 0 REQUIRE_TTL(h);
0 0 REQUIRE_TTL(h);
700 0 0 RETVAL = shm_si_update_ttl(h, _kstr, (uint32_t)_klen, _kutf8, value, (uint32_t)ttl_sec);
707 2 0 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
0 2 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
0 2 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
708 0 2 EXTRACT_STR_KEY(key_sv);
711 0 2 if (rc != 1) XSRETURN_UNDEF;
719 2 0 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
0 2 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
0 2 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
720 1 1 RETVAL = h->path ? newSVpv(h->path, 0) : &PL_sv_undef;
727 1 0 if (SvROK(self_or_class) && SvOBJECT(SvRV(self_or_class))) {
1 0 if (SvROK(self_or_class) && SvOBJECT(SvRV(self_or_class))) {
729 0 1 if (!h) croak("Attempted to use a destroyed Data::HashMap::Shared::SI object");
732 0 0 if (items < 2) croak("Usage: Data::HashMap::Shared::SI->unlink($path)");
741 2 0 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
0 2 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
0 2 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
742 0 2 EXTRACT_STR_KEY(key_sv);
744 0 2 if (remaining < 0) XSRETURN_UNDEF;
752 0 0 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
0 0 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
0 0 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
753 0 0 RETVAL = (UV)shm_si_capacity(h);
760 0 0 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
0 0 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
0 0 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
761 0 0 RETVAL = (UV)shm_si_tombstones(h);
768 1 0 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
0 1 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
0 1 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
770 0 1 if (!c) croak("Failed to allocate cursor");
781 0 1 if (!SvROK(self_sv)) return;
783 0 1 if (!c) return;
786 0 1 if (h) shm_si_flush_deferred(h);
792 6 0 EXTRACT_CURSOR("Data::HashMap::Shared::SI::Cursor", self_sv);
0 6 EXTRACT_CURSOR("Data::HashMap::Shared::SI::Cursor", self_sv);
0 6 EXTRACT_CURSOR("Data::HashMap::Shared::SI::Cursor", self_sv);
795 5 1 if (shm_si_cursor_next(c, &out_key, &out_klen, &out_kutf8, &out_value)) {
796 0 5 EXTEND(SP, 2);
798 0 5 if (out_kutf8) SvUTF8_on(ksv);
799 0 5 mXPUSHs(ksv);
800 0 5 mXPUSHi(out_value);
808 0 0 EXTRACT_CURSOR("Data::HashMap::Shared::SI::Cursor", self_sv);
0 0 EXTRACT_CURSOR("Data::HashMap::Shared::SI::Cursor", self_sv);
0 0 EXTRACT_CURSOR("Data::HashMap::Shared::SI::Cursor", self_sv);
814 0 0 EXTRACT_CURSOR("Data::HashMap::Shared::SI::Cursor", self_sv);
0 0 EXTRACT_CURSOR("Data::HashMap::Shared::SI::Cursor", self_sv);
0 0 EXTRACT_CURSOR("Data::HashMap::Shared::SI::Cursor", self_sv);
815 0 0 EXTRACT_STR_KEY(key_sv);
816 0 0 RETVAL = shm_si_cursor_seek(c, _kstr, (uint32_t)_klen, _kutf8);