Branch Coverage

xs/ss.xs
Criterion Covered Total %
branch 352 752 46.8


line true false branch
7 56 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 3 58 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 5 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");
27 1 0 const char* name = SvOK(name_sv) ? SvPV_nolen(name_sv) : NULL;
29 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");
39 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");
47 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);
48 0 1 RETVAL = h->backing_fd;
56 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);
57 0 0 if (shm_msync(h) != 0) croak("Data::HashMap::Shared::SS sync: %s", strerror(errno));
62 0 65 if (!SvROK(self_sv)) return;
64 0 65 if (!h) return;
71 8097 0 EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv);
0 8097 EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv);
0 8097 EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv);
72 0 8097 EXTRACT_STR_KEY(key_sv);
73 0 8097 EXTRACT_STR_VAL(value);
74 8095 2 RETVAL = shm_ss_put(h, _kstr, (uint32_t)_klen, _kutf8, _vstr, (uint32_t)_vlen, _vutf8);
81 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);
82 0 3 if ((items - 1) % 2 != 0) croak("set_multi requires even number of arguments (key, value pairs)");
84 1 2 if (h->shard_handles) {
85 3 1 for (int i = 1; i < items; i += 2) {
96 6 2 for (int i = 1; i < items; i += 2) {
99 0 6 if (_kl > SHM_MAX_STR_LEN) { shm_seqlock_write_end(&hdr->seq); shm_rwlock_wrunlock(hdr); croak("key too long"); }
102 0 6 if (_vl > SHM_MAX_STR_LEN) { shm_seqlock_write_end(&hdr->seq); shm_rwlock_wrunlock(hdr); croak("value too long"); }
108 0 3 RETVAL = count;
115 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);
117 0 1 if (h->shard_handles) {
118 0 0 for (int i = 1; i < items; i++) {
121 0 0 if (_kl > SHM_MAX_STR_LEN) croak("key too long (max 2GB)");
128 3 1 for (int i = 1; i < items; i++) {
131 0 3 if (_kl > SHM_MAX_STR_LEN) { shm_seqlock_write_end(&hdr->seq); shm_rwlock_wrunlock(hdr); croak("key too long (max 2GB)"); }
134 1 0 if (count) shm_ss_maybe_shrink(h);
138 0 1 RETVAL = count;
145 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);
147 0 3 if (nkeys == 0) XSRETURN_EMPTY;
148 3 0 EXTEND(SP, nkeys);
0 3 EXTEND(SP, nkeys);
149 1 2 if (h->shard_handles) {
150 4 1 for (int i = 0; i < nkeys; i++) {
154 3 1 if (shm_ss_get(h, _ks, (uint32_t)_kl, _ku, &out_s, &out_l, &out_u)) {
156 0 3 if (out_u) SvUTF8_on(sv);
165 0 2 uint32_t now = h->expires_at ? shm_now() : 0;
168 9 2 for (int i = 0; i < nkeys; i++) {
176 13 0 for (uint32_t j = 0; j <= mask; j++) {
179 2 11 if (st == SHM_EMPTY) break;
180 4 7 if (st != tag) continue;
181 7 0 if (shm_ss__key_eq_str(&nodes[idx], arena, _ks, (uint32_t)_kl, _ku)) {
182 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;
186 7 2 if (found) {
190 0 7 if (SHM_UNPACK_UTF8(nodes[vidx].val_len)) SvUTF8_on(sv);
194 7 2 if (i + 1 < nkeys) {
205 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);
206 0 0 EXTRACT_STR_KEY(key_sv);
209 0 0 if (!shm_ss_get_with_ttl(h, _kstr, (uint32_t)_klen, _kutf8, &out_s, &out_l, &out_u, &out_ttl)) XSRETURN_EMPTY;
210 0 0 EXTEND(SP, 2);
212 0 0 if (out_u) SvUTF8_on(vsv);
214 0 0 if (out_ttl < 0) PUSHs(&PL_sv_undef);
220 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);
241 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);
242 0 0 EXTRACT_STR_KEY(key_sv);
243 0 0 RETVAL = shm_ss_persist(h, _kstr, (uint32_t)_klen, _kutf8);
250 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);
251 0 0 EXTRACT_STR_KEY(key_sv);
252 0 0 RETVAL = shm_ss_set_ttl(h, _kstr, (uint32_t)_klen, _kutf8, (uint32_t)ttl_sec);
259 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);
260 0 1 EXTRACT_STR_KEY(key_sv);
261 0 1 EXTRACT_STR_VAL(value);
262 0 1 REQUIRE_TTL(h);
0 1 REQUIRE_TTL(h);
263 1 0 RETVAL = shm_ss_put_ttl(h, _kstr, (uint32_t)_klen, _kutf8, _vstr, (uint32_t)_vlen, _vutf8, (uint32_t)ttl_sec);
270 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);
271 0 0 RETVAL = (UV)shm_ss_max_size(h);
278 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);
279 0 0 RETVAL = (UV)shm_ss_ttl(h);
286 2561 0 EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv);
0 2561 EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv);
0 2561 EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv);
287 0 2561 EXTRACT_STR_KEY(key_sv);
289 5 2556 if (!shm_ss_get(h, _kstr, (uint32_t)_klen, _kutf8, &val, &val_len, &val_utf8))
292 4 2552 if (val_utf8) SvUTF8_on(RETVAL);
299 5005 0 EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv);
0 5005 EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv);
0 5005 EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv);
300 0 5005 EXTRACT_STR_KEY(key_sv);
301 5005 0 RETVAL = shm_ss_remove(h, _kstr, (uint32_t)_klen, _kutf8);
308 11 0 EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv);
0 11 EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv);
0 11 EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv);
309 0 11 EXTRACT_STR_KEY(key_sv);
310 8 3 RETVAL = shm_ss_exists(h, _kstr, (uint32_t)_klen, _kutf8);
317 19 0 EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv);
0 19 EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv);
0 19 EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv);
318 0 19 RETVAL = (UV)shm_ss_size(h);
325 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);
326 0 0 RETVAL = (UV)shm_ss_max_entries(h);
333 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);
334 1 2 uint32_t ns = h->shard_handles ? h->num_shards : 1;
335 6 3 for (uint32_t si = 0; si < ns; si++) {
336 4 2 ShmHandle *sh = h->shard_handles ? h->shard_handles[si] : h;
339 0 6 uint32_t now = sh->expires_at ? shm_now() : 0;
341 0 6 EXTEND(SP, hdr->size);
342 96 6 for (uint32_t i = 0; i < hdr->table_cap; i++) {
343 34 62 if (SHM_IS_LIVE(sh->states[i]) && !SHM_IS_EXPIRED(sh, i, now)) {
0 34 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)) {
347 1 33 if (SHM_UNPACK_UTF8(nodes[i].key_len)) SvUTF8_on(sv);
348 0 34 mXPUSHs(sv);
356 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);
357 1 1 uint32_t ns = h->shard_handles ? h->num_shards : 1;
358 5 2 for (uint32_t si = 0; si < ns; si++) {
359 4 1 ShmHandle *sh = h->shard_handles ? h->shard_handles[si] : h;
362 0 5 uint32_t now = sh->expires_at ? shm_now() : 0;
364 0 5 EXTEND(SP, hdr->size);
365 80 5 for (uint32_t i = 0; i < hdr->table_cap; i++) {
366 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)) {
370 0 33 if (SHM_UNPACK_UTF8(nodes[i].val_len)) SvUTF8_on(sv);
371 0 33 mXPUSHs(sv);
379 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);
380 0 1 uint32_t ns = h->shard_handles ? h->num_shards : 1;
381 1 1 for (uint32_t si = 0; si < ns; si++) {
382 0 1 ShmHandle *sh = h->shard_handles ? h->shard_handles[si] : h;
385 0 1 uint32_t now = sh->expires_at ? shm_now() : 0;
387 0 1 EXTEND(SP, hdr->size * 2);
388 16 1 for (uint32_t i = 0; i < hdr->table_cap; i++) {
389 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)) {
393 0 3 if (SHM_UNPACK_UTF8(nodes[i].key_len)) SvUTF8_on(ksv);
394 0 3 mXPUSHs(ksv);
398 0 3 if (SHM_UNPACK_UTF8(nodes[i].val_len)) SvUTF8_on(vsv);
399 0 3 mXPUSHs(vsv);
408 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);
412 2 1 if (shm_ss_each(h, &out_key, &out_klen, &out_kutf8, &out_val, &out_vlen, &out_vutf8)) {
413 0 2 EXTEND(SP, 2);
415 0 2 if (out_kutf8) SvUTF8_on(ksv);
416 0 2 mXPUSHs(ksv);
418 0 2 if (out_vutf8) SvUTF8_on(vsv);
419 0 2 mXPUSHs(vsv);
428 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);
435 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);
441 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);
443 1 1 uint32_t ns = h->shard_handles ? h->num_shards : 1;
444 5 2 for (uint32_t si = 0; si < ns; si++) {
445 4 1 ShmHandle *sh = h->shard_handles ? h->shard_handles[si] : h;
448 0 5 uint32_t now = sh->expires_at ? shm_now() : 0;
450 80 5 for (uint32_t i = 0; i < hdr->table_cap; i++) {
451 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)) {
458 0 32 if (SHM_UNPACK_UTF8(nodes[i].val_len)) SvUTF8_on(val);
459 0 32 if (!hv_store(hv, kp,
0 32 if (!hv_store(hv, kp,
471 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);
472 0 8 EXTRACT_STR_KEY(key_sv);
474 0 8 EXTRACT_STR_VAL(default_sv);
476 0 8 if (!rc) XSRETURN_UNDEF;
478 0 8 if (out_utf8) SvUTF8_on(RETVAL);
485 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);
486 0 6 EXTRACT_STR_KEY(key_sv);
488 1 5 if (remaining < 0) XSRETURN_UNDEF;
496 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);
497 0 2 RETVAL = (UV)shm_ss_capacity(h);
504 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);
505 0 0 RETVAL = (UV)shm_ss_tombstones(h);
512 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);
514 0 4 if (!c) croak("Failed to allocate cursor");
522 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);
523 0 6 EXTRACT_STR_KEY(key_sv);
525 1 5 if (!shm_ss_take(h, _kstr, (uint32_t)_klen, _kutf8, &out_str, &out_len, &out_utf8)) XSRETURN_UNDEF;
527 2 3 if (out_utf8) SvUTF8_on(RETVAL);
534 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);
537 0 2 if (!shm_ss_pop(h, &out_key, &out_klen, &out_kutf8, &out_val, &out_vlen, &out_vutf8)) XSRETURN_EMPTY;
538 0 2 EXTEND(SP, 2);
540 0 2 if (out_kutf8) SvUTF8_on(ksv);
543 0 2 if (out_vutf8) SvUTF8_on(vsv);
549 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);
552 0 1 if (!shm_ss_shift(h, &out_key, &out_klen, &out_kutf8, &out_val, &out_vlen, &out_vutf8)) XSRETURN_EMPTY;
553 0 1 EXTEND(SP, 2);
555 0 1 if (out_kutf8) SvUTF8_on(ksv);
558 0 1 if (out_vutf8) SvUTF8_on(vsv);
564 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);
565 0 3 if (limit == 0) XSRETURN_EMPTY;
567 0 3 Newxz(entries, limit, shm_ss_drain_entry);
573 0 3 EXTEND(SP, n * 2);
574 9 3 for (uint32_t i = 0; i < n; i++) {
576 0 9 if (entries[i].key_utf8) SvUTF8_on(ksv);
579 0 9 if (entries[i].val_utf8) SvUTF8_on(vsv);
582 3 0 if (buf) free(buf);
588 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);
589 0 1 RETVAL = (UV)shm_ss_flush_expired(h);
596 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);
599 0 0 EXTEND(SP, 2);
606 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);
614 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);
615 0 2 EXTRACT_STR_KEY(key_sv);
616 1 1 RETVAL = shm_ss_touch(h, _kstr, (uint32_t)_klen, _kutf8);
623 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);
624 1 0 RETVAL = shm_ss_reserve(h, (uint32_t)target);
631 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);
639 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);
647 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);
648 0 0 RETVAL = (UV)shm_ss_stat_recoveries(h);
655 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);
663 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);
671 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);
672 0 2 EXTRACT_STR_KEY(key_sv);
673 0 2 EXTRACT_STR_VAL(val_sv);
674 1 1 RETVAL = shm_ss_add(h, _kstr, (uint32_t)_klen, _kutf8, _vstr, (uint32_t)_vlen, _vutf8);
681 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);
682 0 2 EXTRACT_STR_KEY(key_sv);
683 0 2 EXTRACT_STR_VAL(val_sv);
684 0 2 REQUIRE_TTL(h);
0 2 REQUIRE_TTL(h);
685 1 1 RETVAL = shm_ss_add_ttl(h, _kstr, (uint32_t)_klen, _kutf8,
693 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);
694 0 2 EXTRACT_STR_KEY(key_sv);
695 0 2 EXTRACT_STR_VAL(val_sv);
696 1 1 RETVAL = shm_ss_update(h, _kstr, (uint32_t)_klen, _kutf8, _vstr, (uint32_t)_vlen, _vutf8);
703 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);
704 0 2 EXTRACT_STR_KEY(key_sv);
705 0 2 EXTRACT_STR_VAL(val_sv);
706 0 2 REQUIRE_TTL(h);
0 2 REQUIRE_TTL(h);
707 1 1 RETVAL = shm_ss_update_ttl(h, _kstr, (uint32_t)_klen, _kutf8, _vstr, (uint32_t)_vlen, _vutf8, (uint32_t)ttl_sec);
714 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);
715 0 5 EXTRACT_STR_KEY(key_sv);
716 0 5 EXTRACT_STR_VAL(val_sv);
719 2 3 if (rc != 1) XSRETURN_UNDEF;
721 0 3 if (out_u) SvUTF8_on(RETVAL);
728 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);
729 0 10 EXTRACT_STR_KEY(key_sv);
730 0 10 EXTRACT_STR_EXPECTED_DESIRED(expected_sv, desired_sv);
0 10 EXTRACT_STR_EXPECTED_DESIRED(expected_sv, desired_sv);
731 7 3 RETVAL = shm_ss_cas(h, _kstr, (uint32_t)_klen, _kutf8,
739 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);
740 0 3 EXTRACT_STR_KEY(key_sv);
741 0 3 EXTRACT_STR_EXPECTED(expected_sv);
743 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;
745 0 2 if (out_u) SvUTF8_on(RETVAL);
752 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);
753 1 1 RETVAL = h->path ? newSVpv(h->path, 0) : &PL_sv_undef;
761 0 0 if (SvROK(self_or_class) && SvOBJECT(SvRV(self_or_class))) {
0 0 if (SvROK(self_or_class) && SvOBJECT(SvRV(self_or_class))) {
763 0 0 if (!h) croak("Attempted to use a destroyed Data::HashMap::Shared::SS object");
766 0 0 if (items < 2) croak("Usage: Data::HashMap::Shared::SS->unlink($path)");
769 0 0 RETVAL = (SvROK(self_or_class) && SvOBJECT(SvRV(self_or_class))) ?
0 0 RETVAL = (SvROK(self_or_class) && SvOBJECT(SvRV(self_or_class))) ?
770 0 0 shm_unlink_sharded(INT2PTR(ShmHandle*, SvIV(SvRV(self_or_class)))) :
781 0 4 if (!SvROK(self_sv)) return;
783 0 4 if (!c) return;
786 4 0 if (h) shm_ss_flush_deferred(h);
792 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);
796 27 2 if (shm_ss_cursor_next(c, &out_key, &out_klen, &out_kutf8, &out_val, &out_vlen, &out_vutf8)) {
797 0 27 EXTEND(SP, 2);
799 0 27 if (out_kutf8) SvUTF8_on(ksv);
800 0 27 mXPUSHs(ksv);
802 0 27 if (out_vutf8) SvUTF8_on(vsv);
803 0 27 mXPUSHs(vsv);
811 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);
817 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);
818 0 3 EXTRACT_STR_KEY(key_sv);
819 2 1 RETVAL = shm_ss_cursor_seek(c, _kstr, (uint32_t)_klen, _kutf8);