| line |
true |
false |
branch |
|
8
|
0 |
4 |
if (!map) croak("HashMap::Shared::IS: %s", errbuf[0] ? errbuf : "unknown error"); |
|
|
0 |
0 |
if (!map) croak("HashMap::Shared::IS: %s", errbuf[0] ? errbuf : "unknown error"); |
|
17
|
0 |
0 |
if (!map) croak("HashMap::Shared::IS: %s", errbuf[0] ? errbuf : "unknown error"); |
|
|
0 |
0 |
if (!map) croak("HashMap::Shared::IS: %s", errbuf[0] ? errbuf : "unknown error"); |
|
25
|
0 |
4 |
if (!SvROK(self_sv)) return; |
|
27
|
0 |
4 |
if (!h) return; |
|
34
|
7 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
|
0 |
7 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
|
0 |
7 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
35
|
0 |
7 |
EXTRACT_STR_VAL(value); |
|
36
|
7 |
0 |
RETVAL = shm_is_put(h, key, _vstr, (uint32_t)_vlen, _vutf8); |
|
43
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
44
|
0 |
0 |
if ((items - 1) % 2 != 0) croak("set_multi requires even number of arguments (key, value pairs)"); |
|
46
|
0 |
0 |
if (h->shard_handles) { |
|
47
|
0 |
0 |
for (int i = 1; i < items; i += 2) { |
|
56
|
0 |
0 |
for (int i = 1; i < items; i += 2) { |
|
59
|
0 |
0 |
if (_vl > SHM_MAX_STR_LEN) { shm_seqlock_write_end(&hdr->seq); shm_rwlock_wrunlock(hdr); croak("value too long"); } |
|
65
|
0 |
0 |
RETVAL = count; |
|
72
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
74
|
0 |
0 |
if (nkeys == 0) XSRETURN_EMPTY; |
|
75
|
0 |
0 |
EXTEND(SP, nkeys); |
|
|
0 |
0 |
EXTEND(SP, nkeys); |
|
76
|
0 |
0 |
if (h->shard_handles) { |
|
77
|
0 |
0 |
for (int i = 0; i < nkeys; i++) { |
|
80
|
0 |
0 |
if (shm_is_get(h, key, &out_s, &out_l, &out_u)) { |
|
82
|
0 |
0 |
if (out_u) SvUTF8_on(sv); |
|
91
|
0 |
0 |
uint32_t now = h->expires_at ? shm_now() : 0; |
|
98
|
0 |
0 |
for (int i = 0; i < nkeys; i++) { |
|
104
|
0 |
0 |
for (int i = 0; i < nkeys; i++) { |
|
111
|
0 |
0 |
for (uint32_t j = 0; j <= mask; j++) { |
|
114
|
0 |
0 |
if (st == SHM_EMPTY) break; |
|
115
|
0 |
0 |
if (st != tag) continue; |
|
116
|
0 |
0 |
if (nodes[idx].key == key) { |
|
117
|
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; |
|
121
|
0 |
0 |
if (found) { |
|
125
|
0 |
0 |
if (SHM_UNPACK_UTF8(nodes[vidx].val_len)) SvUTF8_on(sv); |
|
129
|
0 |
0 |
if (i + 1 < nkeys) { |
|
140
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
161
|
1 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
|
0 |
1 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
|
0 |
1 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
162
|
1 |
0 |
RETVAL = shm_is_persist(h, key); |
|
169
|
1 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
|
0 |
1 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
|
0 |
1 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
170
|
1 |
0 |
RETVAL = shm_is_set_ttl(h, key, (uint32_t)ttl_sec); |
|
177
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
178
|
0 |
0 |
EXTRACT_STR_VAL(value); |
|
179
|
0 |
0 |
REQUIRE_TTL(h); |
|
|
0 |
0 |
REQUIRE_TTL(h); |
|
180
|
0 |
0 |
RETVAL = shm_is_put_ttl(h, key, _vstr, (uint32_t)_vlen, _vutf8, (uint32_t)ttl_sec); |
|
187
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
188
|
0 |
0 |
RETVAL = (UV)shm_is_max_size(h); |
|
195
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
196
|
0 |
0 |
RETVAL = (UV)shm_is_ttl(h); |
|
203
|
4 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
|
0 |
4 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
|
0 |
4 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
205
|
0 |
4 |
if (!shm_is_get(h, key, &val, &val_len, &val_utf8)) XSRETURN_UNDEF; |
|
207
|
1 |
3 |
if (val_utf8) SvUTF8_on(RETVAL); |
|
214
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
215
|
0 |
0 |
RETVAL = shm_is_remove(h, key); |
|
222
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
223
|
0 |
0 |
RETVAL = shm_is_exists(h, key); |
|
230
|
2 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
|
0 |
2 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
|
0 |
2 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
231
|
0 |
2 |
RETVAL = (UV)shm_is_size(h); |
|
238
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
239
|
0 |
0 |
RETVAL = (UV)shm_is_max_entries(h); |
|
246
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
247
|
0 |
0 |
uint32_t ns = h->shard_handles ? h->num_shards : 1; |
|
248
|
0 |
0 |
for (uint32_t si = 0; si < ns; si++) { |
|
249
|
0 |
0 |
ShmHandle *sh = h->shard_handles ? h->shard_handles[si] : h; |
|
252
|
0 |
0 |
uint32_t now = sh->expires_at ? shm_now() : 0; |
|
254
|
0 |
0 |
EXTEND(SP, hdr->size); |
|
255
|
0 |
0 |
for (uint32_t i = 0; i < hdr->table_cap; i++) { |
|
256
|
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)) |
|
257
|
0 |
0 |
mXPUSHi(nodes[i].key); |
|
264
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
265
|
0 |
0 |
uint32_t ns = h->shard_handles ? h->num_shards : 1; |
|
266
|
0 |
0 |
for (uint32_t si = 0; si < ns; si++) { |
|
267
|
0 |
0 |
ShmHandle *sh = h->shard_handles ? h->shard_handles[si] : h; |
|
270
|
0 |
0 |
uint32_t now = sh->expires_at ? shm_now() : 0; |
|
272
|
0 |
0 |
EXTEND(SP, hdr->size); |
|
273
|
0 |
0 |
for (uint32_t i = 0; i < hdr->table_cap; i++) { |
|
274
|
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)) { |
|
278
|
0 |
0 |
if (SHM_UNPACK_UTF8(nodes[i].val_len)) SvUTF8_on(sv); |
|
279
|
0 |
0 |
mXPUSHs(sv); |
|
287
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
288
|
0 |
0 |
uint32_t ns = h->shard_handles ? h->num_shards : 1; |
|
289
|
0 |
0 |
for (uint32_t si = 0; si < ns; si++) { |
|
290
|
0 |
0 |
ShmHandle *sh = h->shard_handles ? h->shard_handles[si] : h; |
|
293
|
0 |
0 |
uint32_t now = sh->expires_at ? shm_now() : 0; |
|
295
|
0 |
0 |
EXTEND(SP, hdr->size * 2); |
|
296
|
0 |
0 |
for (uint32_t i = 0; i < hdr->table_cap; i++) { |
|
297
|
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)) { |
|
298
|
0 |
0 |
mXPUSHi(nodes[i].key); |
|
302
|
0 |
0 |
if (SHM_UNPACK_UTF8(nodes[i].val_len)) SvUTF8_on(sv); |
|
303
|
0 |
0 |
mXPUSHs(sv); |
|
312
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
315
|
0 |
0 |
if (shm_is_each(h, &out_key, &out_val, &out_vlen, &out_vutf8)) { |
|
316
|
0 |
0 |
EXTEND(SP, 2); |
|
317
|
0 |
0 |
mXPUSHi(out_key); |
|
319
|
0 |
0 |
if (out_vutf8) SvUTF8_on(sv); |
|
320
|
0 |
0 |
mXPUSHs(sv); |
|
329
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
336
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
342
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
344
|
0 |
0 |
uint32_t ns = h->shard_handles ? h->num_shards : 1; |
|
345
|
0 |
0 |
for (uint32_t si = 0; si < ns; si++) { |
|
346
|
0 |
0 |
ShmHandle *sh = h->shard_handles ? h->shard_handles[si] : h; |
|
349
|
0 |
0 |
uint32_t now = sh->expires_at ? shm_now() : 0; |
|
351
|
0 |
0 |
for (uint32_t i = 0; i < hdr->table_cap; i++) { |
|
352
|
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)) { |
|
356
|
0 |
0 |
if (SHM_UNPACK_UTF8(nodes[i].val_len)) SvUTF8_on(val); |
|
359
|
0 |
0 |
if (!hv_store(hv, kbuf, klen, val, 0)) SvREFCNT_dec(val); |
|
371
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
373
|
0 |
0 |
EXTRACT_STR_VAL(default_sv); |
|
375
|
0 |
0 |
if (!rc) XSRETURN_UNDEF; |
|
377
|
0 |
0 |
if (out_utf8) SvUTF8_on(RETVAL); |
|
384
|
1 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
|
0 |
1 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
|
0 |
1 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
386
|
0 |
1 |
if (remaining < 0) XSRETURN_UNDEF; |
|
394
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
395
|
0 |
0 |
RETVAL = (UV)shm_is_capacity(h); |
|
402
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
403
|
0 |
0 |
RETVAL = (UV)shm_is_tombstones(h); |
|
410
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
412
|
0 |
0 |
if (!c) croak("Failed to allocate cursor"); |
|
420
|
1 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
|
0 |
1 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
|
0 |
1 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
422
|
0 |
1 |
if (!shm_is_take(h, key, &out_str, &out_len, &out_utf8)) XSRETURN_UNDEF; |
|
424
|
0 |
1 |
if (out_utf8) SvUTF8_on(RETVAL); |
|
431
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
434
|
0 |
0 |
if (!shm_is_pop(h, &out_key, &out_val, &out_vlen, &out_vutf8)) XSRETURN_EMPTY; |
|
435
|
0 |
0 |
EXTEND(SP, 2); |
|
438
|
0 |
0 |
if (out_vutf8) SvUTF8_on(vsv); |
|
444
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
447
|
0 |
0 |
if (!shm_is_shift(h, &out_key, &out_val, &out_vlen, &out_vutf8)) XSRETURN_EMPTY; |
|
448
|
0 |
0 |
EXTEND(SP, 2); |
|
451
|
0 |
0 |
if (out_vutf8) SvUTF8_on(vsv); |
|
457
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
458
|
0 |
0 |
if (limit == 0) XSRETURN_EMPTY; |
|
460
|
0 |
0 |
Newxz(entries, limit, shm_is_drain_entry); |
|
466
|
0 |
0 |
EXTEND(SP, n * 2); |
|
467
|
0 |
0 |
for (uint32_t i = 0; i < n; i++) { |
|
470
|
0 |
0 |
if (entries[i].val_utf8) SvUTF8_on(vsv); |
|
473
|
0 |
0 |
if (buf) free(buf); |
|
479
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
480
|
0 |
0 |
RETVAL = (UV)shm_is_flush_expired(h); |
|
487
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
490
|
0 |
0 |
EXTEND(SP, 2); |
|
497
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
505
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
506
|
0 |
0 |
RETVAL = shm_is_touch(h, key); |
|
513
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
514
|
0 |
0 |
RETVAL = shm_is_reserve(h, (uint32_t)target); |
|
521
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
529
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
537
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
538
|
0 |
0 |
RETVAL = (UV)shm_is_stat_recoveries(h); |
|
545
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
553
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
561
|
2 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
|
0 |
2 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
|
0 |
2 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
562
|
0 |
2 |
EXTRACT_STR_VAL(val_sv); |
|
563
|
1 |
1 |
RETVAL = shm_is_add(h, key, _vstr, (uint32_t)_vlen, _vutf8); |
|
570
|
1 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
|
0 |
1 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
|
0 |
1 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
571
|
0 |
1 |
EXTRACT_STR_VAL(val_sv); |
|
572
|
1 |
0 |
RETVAL = shm_is_update(h, key, _vstr, (uint32_t)_vlen, _vutf8); |
|
579
|
2 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
|
0 |
2 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
|
0 |
2 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
580
|
0 |
2 |
EXTRACT_STR_VAL(val_sv); |
|
583
|
1 |
1 |
if (rc != 1) XSRETURN_UNDEF; |
|
585
|
0 |
1 |
if (out_u) SvUTF8_on(RETVAL); |
|
592
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::IS", self_sv); |
|
601
|
0 |
0 |
if (SvROK(self_or_class) && SvOBJECT(SvRV(self_or_class))) { |
|
|
0 |
0 |
if (SvROK(self_or_class) && SvOBJECT(SvRV(self_or_class))) { |
|
603
|
0 |
0 |
if (!h) croak("Attempted to use a destroyed Data::HashMap::Shared::IS object"); |
|
606
|
0 |
0 |
if (items < 2) croak("Usage: Data::HashMap::Shared::IS->unlink($path)"); |
|
609
|
0 |
0 |
RETVAL = (SvROK(self_or_class) && SvOBJECT(SvRV(self_or_class))) ? |
|
|
0 |
0 |
RETVAL = (SvROK(self_or_class) && SvOBJECT(SvRV(self_or_class))) ? |
|
610
|
0 |
0 |
shm_unlink_sharded(INT2PTR(ShmHandle*, SvIV(SvRV(self_or_class)))) : |
|
621
|
0 |
0 |
if (!SvROK(self_sv)) return; |
|
623
|
0 |
0 |
if (!c) return; |
|
626
|
0 |
0 |
if (h) shm_is_flush_deferred(h); |
|
632
|
0 |
0 |
EXTRACT_CURSOR("Data::HashMap::Shared::IS::Cursor", self_sv); |
|
|
0 |
0 |
EXTRACT_CURSOR("Data::HashMap::Shared::IS::Cursor", self_sv); |
|
|
0 |
0 |
EXTRACT_CURSOR("Data::HashMap::Shared::IS::Cursor", self_sv); |
|
635
|
0 |
0 |
if (shm_is_cursor_next(c, &out_key, &out_val, &out_vlen, &out_vutf8)) { |
|
636
|
0 |
0 |
EXTEND(SP, 2); |
|
637
|
0 |
0 |
mXPUSHi(out_key); |
|
639
|
0 |
0 |
if (out_vutf8) SvUTF8_on(sv); |
|
640
|
0 |
0 |
mXPUSHs(sv); |
|
648
|
0 |
0 |
EXTRACT_CURSOR("Data::HashMap::Shared::IS::Cursor", self_sv); |
|
|
0 |
0 |
EXTRACT_CURSOR("Data::HashMap::Shared::IS::Cursor", self_sv); |
|
|
0 |
0 |
EXTRACT_CURSOR("Data::HashMap::Shared::IS::Cursor", self_sv); |
|
654
|
0 |
0 |
EXTRACT_CURSOR("Data::HashMap::Shared::IS::Cursor", self_sv); |
|
|
0 |
0 |
EXTRACT_CURSOR("Data::HashMap::Shared::IS::Cursor", self_sv); |
|
|
0 |
0 |
EXTRACT_CURSOR("Data::HashMap::Shared::IS::Cursor", self_sv); |
|
655
|
0 |
0 |
RETVAL = shm_is_cursor_seek(c, key); |