Branch Coverage

xs/ss.xs
Criterion Covered Total %
branch 255 752 33.9


line true false branch
7 27 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 1 31 if (!map) croak("Data::HashMap::Shared::SS: %s", errbuf[0] ? errbuf : "unknown error");
1 0 if (!map) croak("Data::HashMap::Shared::SS: %s", errbuf[0] ? errbuf : "unknown error");
16 1 0 const char* path_prefix = SvOK(path_prefix_sv) ? SvPV_nolen(path_prefix_sv) : NULL;
18 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");
28 1 0 const char* name = SvOK(name_sv) ? SvPV_nolen(name_sv) : NULL;
30 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");
40 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");
48 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);
49 0 1 RETVAL = h->backing_fd;
57 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);
58 0 0 if (shm_msync(h) != 0) croak("Data::HashMap::Shared::SS sync: %s", strerror(errno));
63 0 34 if (!SvROK(self_sv)) return;
65 0 34 if (!h) return;
72 8105 0 EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv);
0 8105 EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv);
0 8105 EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv);
73 0 8105 EXTRACT_STR_KEY(key_sv);
74 0 8105 EXTRACT_STR_VAL(value);
75 8105 0 RETVAL = shm_ss_put(h, _kstr, (uint32_t)_klen, _kutf8, _vstr, (uint32_t)_vlen, _vutf8);
82 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);
83 0 0 if ((items - 1) % 2 != 0) croak("set_multi requires even number of arguments (key, value pairs)");
85 0 0 if (h->shard_handles) {
86 0 0 for (int i = 1; i < items; i += 2) {
91 0 0 if (_kl > SHM_MAX_STR_LEN) croak("key too long (max 1GB)");
92 0 0 if (_vl > SHM_MAX_STR_LEN) croak("value too long (max 1GB)");
97 0 0 for (int i = 1; i < items; i += 2) {
100 0 0 if (_kl > SHM_MAX_STR_LEN) croak("key too long (max 1GB)");
103 0 0 if (_vl > SHM_MAX_STR_LEN) croak("value too long (max 1GB)");
107 0 0 RETVAL = count;
114 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);
116 0 1 if (h->shard_handles) {
117 0 0 for (int i = 1; i < items; i++) {
120 0 0 if (_kl > SHM_MAX_STR_LEN) croak("key too long (max 1GB)");
125 3 1 for (int i = 1; i < items; i++) {
128 0 3 if (_kl > SHM_MAX_STR_LEN) croak("key too long (max 1GB)");
131 1 0 if (count) shm_ss_maybe_shrink(h);
133 0 1 RETVAL = count;
140 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);
142 0 0 if (nkeys == 0) XSRETURN_EMPTY;
143 0 0 EXTEND(SP, nkeys);
0 0 EXTEND(SP, nkeys);
144 0 0 if (h->shard_handles) {
145 0 0 for (int i = 0; i < nkeys; i++) {
149 0 0 if (shm_ss_get(h, _ks, (uint32_t)_kl, _ku, &out_s, &out_l, &out_u)) {
151 0 0 if (out_u) SvUTF8_on(sv);
160 0 0 uint32_t now = h->expires_at ? shm_now() : 0;
163 0 0 for (int i = 0; i < nkeys; i++) {
171 0 0 for (uint32_t j = 0; j <= mask; j++) {
174 0 0 if (st == SHM_EMPTY) break;
175 0 0 if (st != tag) continue;
176 0 0 if (shm_ss__key_eq_str(&nodes[idx], arena, _ks, (uint32_t)_kl, _ku)) {
177 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;
181 0 0 if (found) {
185 0 0 if (SHM_UNPACK_UTF8(nodes[vidx].val_len)) SvUTF8_on(sv);
189 0 0 if (i + 1 < nkeys) {
200 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);
201 0 0 EXTRACT_STR_KEY(key_sv);
204 0 0 if (!shm_ss_get_with_ttl(h, _kstr, (uint32_t)_klen, _kutf8, &out_s, &out_l, &out_u, &out_ttl)) XSRETURN_EMPTY;
205 0 0 EXTEND(SP, 2);
207 0 0 if (out_u) SvUTF8_on(vsv);
209 0 0 if (out_ttl < 0) PUSHs(&PL_sv_undef);
215 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);
236 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);
237 0 0 EXTRACT_STR_KEY(key_sv);
238 0 0 RETVAL = shm_ss_persist(h, _kstr, (uint32_t)_klen, _kutf8);
245 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);
246 0 0 EXTRACT_STR_KEY(key_sv);
247 0 0 RETVAL = shm_ss_set_ttl(h, _kstr, (uint32_t)_klen, _kutf8, (uint32_t)ttl_sec);
254 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);
255 0 0 EXTRACT_STR_KEY(key_sv);
256 0 0 EXTRACT_STR_VAL(value);
257 0 0 REQUIRE_TTL(h);
0 0 REQUIRE_TTL(h);
258 0 0 RETVAL = shm_ss_put_ttl(h, _kstr, (uint32_t)_klen, _kutf8, _vstr, (uint32_t)_vlen, _vutf8, (uint32_t)ttl_sec);
265 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);
266 0 0 RETVAL = (UV)shm_ss_max_size(h);
273 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);
274 0 0 RETVAL = (UV)shm_ss_ttl(h);
281 100 0 EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv);
0 100 EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv);
0 100 EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv);
282 0 100 EXTRACT_STR_KEY(key_sv);
284 3 97 if (!shm_ss_get(h, _kstr, (uint32_t)_klen, _kutf8, &val, &val_len, &val_utf8))
287 1 96 if (val_utf8) SvUTF8_on(RETVAL);
294 8022 0 EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv);
0 8022 EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv);
0 8022 EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv);
295 0 8022 EXTRACT_STR_KEY(key_sv);
296 8022 0 RETVAL = shm_ss_remove(h, _kstr, (uint32_t)_klen, _kutf8);
303 9 0 EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv);
0 9 EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv);
0 9 EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv);
304 0 9 EXTRACT_STR_KEY(key_sv);
305 6 3 RETVAL = shm_ss_exists(h, _kstr, (uint32_t)_klen, _kutf8);
312 9 0 EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv);
0 9 EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv);
0 9 EXTRACT_MAP("Data::HashMap::Shared::SS", self_sv);
313 0 9 RETVAL = (UV)shm_ss_size(h);
320 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);
321 0 0 RETVAL = (UV)shm_ss_max_entries(h);
328 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);
329 0 2 uint32_t ns = h->shard_handles ? h->num_shards : 1;
330 2 2 for (uint32_t si = 0; si < ns; si++) {
331 0 2 ShmHandle *sh = h->shard_handles ? h->shard_handles[si] : h;
334 0 2 uint32_t now = sh->expires_at ? shm_now() : 0;
336 0 2 EXTEND(SP, hdr->size);
337 32 2 for (uint32_t i = 0; i < hdr->table_cap; i++) {
338 4 28 if (SHM_IS_LIVE(sh->states[i]) && !SHM_IS_EXPIRED(sh, i, now)) {
0 4 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)) {
342 1 3 if (SHM_UNPACK_UTF8(nodes[i].key_len)) SvUTF8_on(sv);
343 0 4 mXPUSHs(sv);
351 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);
352 0 1 uint32_t ns = h->shard_handles ? h->num_shards : 1;
353 1 1 for (uint32_t si = 0; si < ns; si++) {
354 0 1 ShmHandle *sh = h->shard_handles ? h->shard_handles[si] : h;
357 0 1 uint32_t now = sh->expires_at ? shm_now() : 0;
359 0 1 EXTEND(SP, hdr->size);
360 16 1 for (uint32_t i = 0; i < hdr->table_cap; i++) {
361 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)) {
365 0 3 if (SHM_UNPACK_UTF8(nodes[i].val_len)) SvUTF8_on(sv);
366 0 3 mXPUSHs(sv);
374 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);
375 0 1 uint32_t ns = h->shard_handles ? h->num_shards : 1;
376 1 1 for (uint32_t si = 0; si < ns; si++) {
377 0 1 ShmHandle *sh = h->shard_handles ? h->shard_handles[si] : h;
380 0 1 uint32_t now = sh->expires_at ? shm_now() : 0;
382 0 1 EXTEND(SP, hdr->size * 2);
383 16 1 for (uint32_t i = 0; i < hdr->table_cap; i++) {
384 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)) {
388 0 3 if (SHM_UNPACK_UTF8(nodes[i].key_len)) SvUTF8_on(ksv);
389 0 3 mXPUSHs(ksv);
393 0 3 if (SHM_UNPACK_UTF8(nodes[i].val_len)) SvUTF8_on(vsv);
394 0 3 mXPUSHs(vsv);
403 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);
407 2 1 if (shm_ss_each(h, &out_key, &out_klen, &out_kutf8, &out_val, &out_vlen, &out_vutf8)) {
408 0 2 EXTEND(SP, 2);
410 0 2 if (out_kutf8) SvUTF8_on(ksv);
411 0 2 mXPUSHs(ksv);
413 0 2 if (out_vutf8) SvUTF8_on(vsv);
414 0 2 mXPUSHs(vsv);
423 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);
430 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);
436 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);
438 0 1 uint32_t ns = h->shard_handles ? h->num_shards : 1;
439 1 1 for (uint32_t si = 0; si < ns; si++) {
440 0 1 ShmHandle *sh = h->shard_handles ? h->shard_handles[si] : h;
443 0 1 uint32_t now = sh->expires_at ? shm_now() : 0;
445 16 1 for (uint32_t i = 0; i < hdr->table_cap; i++) {
446 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)) {
453 0 2 if (SHM_UNPACK_UTF8(nodes[i].val_len)) SvUTF8_on(val);
454 0 2 if (!hv_store(hv, kp,
0 2 if (!hv_store(hv, kp,
466 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);
467 0 2 EXTRACT_STR_KEY(key_sv);
469 0 2 EXTRACT_STR_VAL(default_sv);
471 0 2 if (!rc) XSRETURN_UNDEF;
473 0 2 if (out_utf8) SvUTF8_on(RETVAL);
480 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);
481 0 6 EXTRACT_STR_KEY(key_sv);
483 1 5 if (remaining < 0) XSRETURN_UNDEF;
491 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);
492 3 1 RETVAL = (UV)shm_ss_capacity(h);
499 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);
500 3 0 RETVAL = (UV)shm_ss_tombstones(h);
507 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);
509 0 2 if (!c) croak("Failed to allocate cursor");
517 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);
518 0 0 EXTRACT_STR_KEY(key_sv);
520 0 0 if (!shm_ss_take(h, _kstr, (uint32_t)_klen, _kutf8, &out_str, &out_len, &out_utf8)) XSRETURN_UNDEF;
522 0 0 if (out_utf8) SvUTF8_on(RETVAL);
529 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);
532 0 0 if (!shm_ss_pop(h, &out_key, &out_klen, &out_kutf8, &out_val, &out_vlen, &out_vutf8)) XSRETURN_EMPTY;
533 0 0 EXTEND(SP, 2);
535 0 0 if (out_kutf8) SvUTF8_on(ksv);
538 0 0 if (out_vutf8) SvUTF8_on(vsv);
544 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);
547 0 0 if (!shm_ss_shift(h, &out_key, &out_klen, &out_kutf8, &out_val, &out_vlen, &out_vutf8)) XSRETURN_EMPTY;
548 0 0 EXTEND(SP, 2);
550 0 0 if (out_kutf8) SvUTF8_on(ksv);
553 0 0 if (out_vutf8) SvUTF8_on(vsv);
559 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);
560 0 0 if (limit == 0) XSRETURN_EMPTY;
562 0 0 Newxz(entries, limit, shm_ss_drain_entry);
567 0 0 if (buf) SAVEDESTRUCTOR_X(shm_free_cleanup, buf);
569 0 0 EXTEND(SP, n * 2);
570 0 0 for (uint32_t i = 0; i < n; i++) {
572 0 0 if (entries[i].key_utf8) SvUTF8_on(ksv);
575 0 0 if (entries[i].val_utf8) SvUTF8_on(vsv);
583 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);
584 0 0 RETVAL = (UV)shm_ss_flush_expired(h);
591 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);
594 0 0 EXTEND(SP, 2);
601 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);
609 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);
610 0 2 EXTRACT_STR_KEY(key_sv);
611 1 1 RETVAL = shm_ss_touch(h, _kstr, (uint32_t)_klen, _kutf8);
618 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);
619 1 0 RETVAL = shm_ss_reserve(h, (uint32_t)target);
626 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);
634 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);
642 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);
643 0 0 RETVAL = (UV)shm_ss_stat_recoveries(h);
650 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);
658 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);
666 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);
667 0 2 EXTRACT_STR_KEY(key_sv);
668 0 2 EXTRACT_STR_VAL(val_sv);
669 1 1 RETVAL = shm_ss_add(h, _kstr, (uint32_t)_klen, _kutf8, _vstr, (uint32_t)_vlen, _vutf8);
676 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);
677 0 2 EXTRACT_STR_KEY(key_sv);
678 0 2 EXTRACT_STR_VAL(val_sv);
679 0 2 REQUIRE_TTL(h);
0 2 REQUIRE_TTL(h);
680 1 1 RETVAL = shm_ss_add_ttl(h, _kstr, (uint32_t)_klen, _kutf8,
688 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);
689 0 2 EXTRACT_STR_KEY(key_sv);
690 0 2 EXTRACT_STR_VAL(val_sv);
691 1 1 RETVAL = shm_ss_update(h, _kstr, (uint32_t)_klen, _kutf8, _vstr, (uint32_t)_vlen, _vutf8);
698 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);
699 0 2 EXTRACT_STR_KEY(key_sv);
700 0 2 EXTRACT_STR_VAL(val_sv);
701 0 2 REQUIRE_TTL(h);
0 2 REQUIRE_TTL(h);
702 1 1 RETVAL = shm_ss_update_ttl(h, _kstr, (uint32_t)_klen, _kutf8, _vstr, (uint32_t)_vlen, _vutf8, (uint32_t)ttl_sec);
709 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);
710 0 1 EXTRACT_STR_KEY(key_sv);
711 0 1 EXTRACT_STR_VAL(val_sv);
714 0 1 if (rc != 1) XSRETURN_UNDEF;
716 0 1 if (out_u) SvUTF8_on(RETVAL);
723 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);
724 0 10 EXTRACT_STR_KEY(key_sv);
725 0 10 EXTRACT_STR_EXPECTED_DESIRED(expected_sv, desired_sv);
0 10 EXTRACT_STR_EXPECTED_DESIRED(expected_sv, desired_sv);
726 7 3 RETVAL = shm_ss_cas(h, _kstr, (uint32_t)_klen, _kutf8,
734 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);
735 0 3 EXTRACT_STR_KEY(key_sv);
736 0 3 EXTRACT_STR_EXPECTED(expected_sv);
738 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;
740 0 2 if (out_u) SvUTF8_on(RETVAL);
747 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);
748 1 1 RETVAL = h->path ? newSVpv(h->path, 0) : &PL_sv_undef;
755 0 0 if (SvROK(self_or_class) && SvOBJECT(SvRV(self_or_class))) {
0 0 if (SvROK(self_or_class) && SvOBJECT(SvRV(self_or_class))) {
757 0 0 if (!h) croak("Attempted to use a destroyed Data::HashMap::Shared::SS object");
760 0 0 if (items < 2) croak("Usage: Data::HashMap::Shared::SS->unlink($path)");
772 0 2 if (!SvROK(self_sv)) return;
774 0 2 if (!c) return;
777 1 1 if (h) shm_ss_flush_deferred(h);
783 7 0 EXTRACT_CURSOR("Data::HashMap::Shared::SS::Cursor", self_sv);
0 7 EXTRACT_CURSOR("Data::HashMap::Shared::SS::Cursor", self_sv);
0 7 EXTRACT_CURSOR("Data::HashMap::Shared::SS::Cursor", self_sv);
787 6 1 if (shm_ss_cursor_next(c, &out_key, &out_klen, &out_kutf8, &out_val, &out_vlen, &out_vutf8)) {
788 0 6 EXTEND(SP, 2);
790 0 6 if (out_kutf8) SvUTF8_on(ksv);
791 0 6 mXPUSHs(ksv);
793 0 6 if (out_vutf8) SvUTF8_on(vsv);
794 0 6 mXPUSHs(vsv);
802 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);
808 1 0 EXTRACT_CURSOR("Data::HashMap::Shared::SS::Cursor", self_sv);
0 1 EXTRACT_CURSOR("Data::HashMap::Shared::SS::Cursor", self_sv);
0 1 EXTRACT_CURSOR("Data::HashMap::Shared::SS::Cursor", self_sv);
809 0 1 EXTRACT_STR_KEY(key_sv);
810 1 0 RETVAL = shm_ss_cursor_seek(c, _kstr, (uint32_t)_klen, _kutf8);