Branch Coverage

xs/si.xs
Criterion Covered Total %
branch 183 726 25.2


line true false branch
7 15 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 20 if (!map) croak("HashMap::Shared::SI: %s", errbuf[0] ? errbuf : "unknown error");
0 0 if (!map) croak("HashMap::Shared::SI: %s", errbuf[0] ? errbuf : "unknown error");
17 0 0 if (!map) croak("HashMap::Shared::SI: %s", errbuf[0] ? errbuf : "unknown error");
0 0 if (!map) croak("HashMap::Shared::SI: %s", errbuf[0] ? errbuf : "unknown error");
27 0 0 const char* name = SvOK(name_sv) ? SvPV_nolen(name_sv) : NULL;
29 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");
39 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");
47 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);
48 0 0 RETVAL = h->backing_fd;
56 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);
57 0 0 if (shm_msync(h) != 0) croak("Data::HashMap::Shared::SI sync: %s", strerror(errno));
62 0 20 if (!SvROK(self_sv)) return;
64 0 20 if (!h) return;
71 521 0 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
0 521 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
0 521 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
72 0 521 EXTRACT_STR_KEY(key_sv);
73 521 0 RETVAL = shm_si_put(h, _kstr, (uint32_t)_klen, _kutf8, value);
80 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);
81 0 0 if ((items - 1) % 2 != 0) croak("set_multi requires even number of arguments (key, value pairs)");
83 0 0 if (h->shard_handles) {
84 0 0 for (int i = 1; i < items; i += 2) {
93 0 0 for (int i = 1; i < items; i += 2) {
96 0 0 if (_klen > SHM_MAX_STR_LEN) { shm_seqlock_write_end(&hdr->seq); shm_rwlock_wrunlock(hdr); croak("key too long"); }
102 0 0 RETVAL = count;
109 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);
111 0 0 if (h->shard_handles) {
112 0 0 for (int i = 1; i < items; i++) {
115 0 0 if (_kl > SHM_MAX_STR_LEN) croak("key too long (max 2GB)");
122 0 0 for (int i = 1; i < items; i++) {
125 0 0 if (_kl > SHM_MAX_STR_LEN) { shm_seqlock_write_end(&hdr->seq); shm_rwlock_wrunlock(hdr); croak("key too long (max 2GB)"); }
128 0 0 if (count) shm_si_maybe_shrink(h);
132 0 0 RETVAL = count;
139 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);
141 0 0 if (nkeys == 0) XSRETURN_EMPTY;
142 0 0 EXTEND(SP, nkeys);
0 0 EXTEND(SP, nkeys);
143 0 0 if (h->shard_handles) {
144 0 0 for (int i = 0; i < nkeys; i++) {
148 0 0 if (shm_si_get(h, _ks, (uint32_t)_kl, _ku, &val))
158 0 0 uint32_t now = h->expires_at ? shm_now() : 0;
161 0 0 for (int i = 0; i < nkeys; i++) {
169 0 0 for (uint32_t j = 0; j <= mask; j++) {
172 0 0 if (st == SHM_EMPTY) break;
173 0 0 if (st != tag) continue;
174 0 0 if (shm_si__key_eq_str(&nodes[idx], arena, _ks, (uint32_t)_kl, _ku)) {
175 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;
180 0 0 if (found) mPUSHi(val);
183 0 0 if (i + 1 < nkeys) {
194 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);
195 0 1 EXTRACT_STR_KEY(key_sv);
198 0 1 if (!shm_si_get_with_ttl(h, _kstr, (uint32_t)_klen, _kutf8, &out_value, &out_ttl)) XSRETURN_EMPTY;
199 0 1 EXTEND(SP, 2);
201 0 1 if (out_ttl < 0) PUSHs(&PL_sv_undef);
207 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);
228 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);
229 0 3 EXTRACT_STR_KEY(key_sv);
230 2 1 RETVAL = shm_si_cas(h, _kstr, (uint32_t)_klen, _kutf8, expected, desired);
237 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);
238 0 0 EXTRACT_STR_KEY(key_sv);
240 0 0 if (!shm_si_cas_take(h, _kstr, (uint32_t)_klen, _kutf8, expected, &out_value)) XSRETURN_UNDEF;
248 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);
249 0 0 EXTRACT_STR_KEY(key_sv);
250 0 0 RETVAL = shm_si_persist(h, _kstr, (uint32_t)_klen, _kutf8);
257 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);
258 0 1 EXTRACT_STR_KEY(key_sv);
259 1 0 RETVAL = shm_si_set_ttl(h, _kstr, (uint32_t)_klen, _kutf8, (uint32_t)ttl_sec);
266 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);
267 0 1 EXTRACT_STR_KEY(key_sv);
268 0 1 REQUIRE_TTL(h);
0 1 REQUIRE_TTL(h);
269 1 0 RETVAL = shm_si_put_ttl(h, _kstr, (uint32_t)_klen, _kutf8, value, (uint32_t)ttl_sec);
276 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);
277 0 0 RETVAL = (UV)shm_si_max_size(h);
284 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);
285 0 0 RETVAL = (UV)shm_si_ttl(h);
292 515 0 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
0 515 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
0 515 EXTRACT_MAP("Data::HashMap::Shared::SI", self_sv);
293 0 515 EXTRACT_STR_KEY(key_sv);
295 2 513 if (!shm_si_get(h, _kstr, (uint32_t)_klen, _kutf8, &value)) XSRETURN_UNDEF;
303 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);
304 0 1 EXTRACT_STR_KEY(key_sv);
305 1 0 RETVAL = shm_si_remove(h, _kstr, (uint32_t)_klen, _kutf8);
312 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);
313 0 2 EXTRACT_STR_KEY(key_sv);
314 1 1 RETVAL = shm_si_exists(h, _kstr, (uint32_t)_klen, _kutf8);
321 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);
322 0 2 EXTRACT_STR_KEY(key_sv);
325 0 2 if (!ok) croak("HashMap::Shared::SI: increment failed");
333 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);
334 0 1 EXTRACT_STR_KEY(key_sv);
337 0 1 if (!ok) croak("HashMap::Shared::SI: decrement failed");
345 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);
346 0 1 EXTRACT_STR_KEY(key_sv);
349 0 1 if (!ok) croak("HashMap::Shared::SI: incr_by failed");
357 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);
358 0 3 RETVAL = (UV)shm_si_size(h);
365 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);
366 0 0 RETVAL = (UV)shm_si_max_entries(h);
373 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);
374 0 1 uint32_t ns = h->shard_handles ? h->num_shards : 1;
375 1 1 for (uint32_t si = 0; si < ns; si++) {
376 0 1 ShmHandle *sh = h->shard_handles ? h->shard_handles[si] : h;
379 0 1 uint32_t now = sh->expires_at ? shm_now() : 0;
381 0 1 EXTEND(SP, hdr->size);
382 16 1 for (uint32_t i = 0; i < hdr->table_cap; i++) {
383 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)) {
387 0 2 if (SHM_UNPACK_UTF8(nodes[i].key_len)) SvUTF8_on(sv);
388 0 2 mXPUSHs(sv);
396 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);
397 0 1 uint32_t ns = h->shard_handles ? h->num_shards : 1;
398 1 1 for (uint32_t si = 0; si < ns; si++) {
399 0 1 ShmHandle *sh = h->shard_handles ? h->shard_handles[si] : h;
402 0 1 uint32_t now = sh->expires_at ? shm_now() : 0;
404 0 1 EXTEND(SP, hdr->size);
405 16 1 for (uint32_t i = 0; i < hdr->table_cap; i++) {
406 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))
407 0 2 mXPUSHi(nodes[i].value);
414 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);
415 0 0 uint32_t ns = h->shard_handles ? h->num_shards : 1;
416 0 0 for (uint32_t si = 0; si < ns; si++) {
417 0 0 ShmHandle *sh = h->shard_handles ? h->shard_handles[si] : h;
420 0 0 uint32_t now = sh->expires_at ? shm_now() : 0;
422 0 0 EXTEND(SP, hdr->size * 2);
423 0 0 for (uint32_t i = 0; i < hdr->table_cap; i++) {
424 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)) {
428 0 0 if (SHM_UNPACK_UTF8(nodes[i].key_len)) SvUTF8_on(sv);
429 0 0 mXPUSHs(sv);
430 0 0 mXPUSHi(nodes[i].value);
439 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);
442 0 0 if (shm_si_each(h, &out_key, &out_klen, &out_kutf8, &out_value)) {
443 0 0 EXTEND(SP, 2);
445 0 0 if (out_kutf8) SvUTF8_on(ksv);
446 0 0 mXPUSHs(ksv);
447 0 0 mXPUSHi(out_value);
456 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);
463 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);
469 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);
471 0 1 uint32_t ns = h->shard_handles ? h->num_shards : 1;
472 1 1 for (uint32_t si = 0; si < ns; si++) {
473 0 1 ShmHandle *sh = h->shard_handles ? h->shard_handles[si] : h;
476 0 1 uint32_t now = sh->expires_at ? shm_now() : 0;
478 16 1 for (uint32_t i = 0; i < hdr->table_cap; i++) {
479 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)) {
484 0 2 if (!hv_store(hv, kp,
0 2 if (!hv_store(hv, kp,
497 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);
498 0 0 EXTRACT_STR_KEY(key_sv);
501 0 0 if (!rc) XSRETURN_UNDEF;
509 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);
510 0 2 EXTRACT_STR_KEY(key_sv);
512 0 2 if (!shm_si_take(h, _kstr, (uint32_t)_klen, _kutf8, &out_value)) XSRETURN_UNDEF;
520 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);
523 0 0 if (!shm_si_pop(h, &out_key, &out_klen, &out_kutf8, &out_val)) XSRETURN_EMPTY;
524 0 0 EXTEND(SP, 2);
526 0 0 if (out_kutf8) SvUTF8_on(ksv);
533 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);
536 0 0 if (!shm_si_shift(h, &out_key, &out_klen, &out_kutf8, &out_val)) XSRETURN_EMPTY;
537 0 0 EXTEND(SP, 2);
539 0 0 if (out_kutf8) SvUTF8_on(ksv);
546 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);
547 0 0 if (limit == 0) XSRETURN_EMPTY;
549 0 0 Newxz(entries, limit, shm_si_drain_entry);
555 0 0 EXTEND(SP, n * 2);
556 0 0 for (uint32_t i = 0; i < n; i++) {
558 0 0 if (entries[i].key_utf8) SvUTF8_on(ksv);
562 0 0 if (buf) free(buf);
568 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);
569 0 0 RETVAL = (UV)shm_si_flush_expired(h);
576 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);
579 0 0 EXTEND(SP, 2);
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);
594 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);
595 0 1 EXTRACT_STR_KEY(key_sv);
596 1 0 RETVAL = shm_si_touch(h, _kstr, (uint32_t)_klen, _kutf8);
603 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);
604 0 0 RETVAL = shm_si_reserve(h, (uint32_t)target);
611 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);
619 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);
627 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);
628 0 0 RETVAL = (UV)shm_si_stat_recoveries(h);
635 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);
643 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);
651 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);
652 0 3 EXTRACT_STR_KEY(key_sv);
653 1 2 RETVAL = shm_si_add(h, _kstr, (uint32_t)_klen, _kutf8, value);
660 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);
661 0 2 EXTRACT_STR_KEY(key_sv);
662 0 2 REQUIRE_TTL(h);
0 2 REQUIRE_TTL(h);
663 1 1 RETVAL = shm_si_add_ttl(h, _kstr, (uint32_t)_klen, _kutf8, value, (uint32_t)ttl_sec);
670 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);
671 0 2 EXTRACT_STR_KEY(key_sv);
672 2 0 RETVAL = shm_si_update(h, _kstr, (uint32_t)_klen, _kutf8, value);
679 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);
680 0 0 EXTRACT_STR_KEY(key_sv);
681 0 0 REQUIRE_TTL(h);
0 0 REQUIRE_TTL(h);
682 0 0 RETVAL = shm_si_update_ttl(h, _kstr, (uint32_t)_klen, _kutf8, value, (uint32_t)ttl_sec);
689 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);
690 0 2 EXTRACT_STR_KEY(key_sv);
693 0 2 if (rc != 1) XSRETURN_UNDEF;
701 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);
702 1 1 RETVAL = h->path ? newSVpv(h->path, 0) : &PL_sv_undef;
710 1 0 if (SvROK(self_or_class) && SvOBJECT(SvRV(self_or_class))) {
1 0 if (SvROK(self_or_class) && SvOBJECT(SvRV(self_or_class))) {
712 0 1 if (!h) croak("Attempted to use a destroyed Data::HashMap::Shared::SI object");
715 0 0 if (items < 2) croak("Usage: Data::HashMap::Shared::SI->unlink($path)");
718 1 0 RETVAL = (SvROK(self_or_class) && SvOBJECT(SvRV(self_or_class))) ?
0 1 RETVAL = (SvROK(self_or_class) && SvOBJECT(SvRV(self_or_class))) ?
719 1 0 shm_unlink_sharded(INT2PTR(ShmHandle*, SvIV(SvRV(self_or_class)))) :
727 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);
728 0 1 EXTRACT_STR_KEY(key_sv);
730 0 1 if (remaining < 0) XSRETURN_UNDEF;
738 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);
739 0 0 RETVAL = (UV)shm_si_capacity(h);
746 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);
747 0 0 RETVAL = (UV)shm_si_tombstones(h);
754 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);
756 0 1 if (!c) croak("Failed to allocate cursor");
767 0 1 if (!SvROK(self_sv)) return;
769 0 1 if (!c) return;
772 1 0 if (h) shm_si_flush_deferred(h);
778 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);
781 5 1 if (shm_si_cursor_next(c, &out_key, &out_klen, &out_kutf8, &out_value)) {
782 0 5 EXTEND(SP, 2);
784 0 5 if (out_kutf8) SvUTF8_on(ksv);
785 0 5 mXPUSHs(ksv);
786 0 5 mXPUSHi(out_value);
794 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);
800 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);
801 0 0 EXTRACT_STR_KEY(key_sv);
802 0 0 RETVAL = shm_si_cursor_seek(c, _kstr, (uint32_t)_klen, _kutf8);