| line |
true |
false |
branch |
|
7
|
6 |
0 |
char errbuf[SHM_ERR_BUFLEN]; const char* path = SvOK(path_sv) ? SvPV_nolen(path_sv) : NULL; ShmHandle* map = shm_i32_create(path, (uint32_t)max_entries, (uint32_t)lru_max, (uint32_t)ttl_default, (uint32_t)lru_skip, errbuf); |
|
8
|
0 |
6 |
if (!map) croak("Data::HashMap::Shared::I32: %s", errbuf[0] ? errbuf : "unknown error"); |
|
|
0 |
0 |
if (!map) croak("Data::HashMap::Shared::I32: %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::I32: %s", errbuf[0] ? errbuf : "unknown error"); |
|
|
0 |
0 |
if (!map) croak("Data::HashMap::Shared::I32: %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::I32: %s", errbuf[0] ? errbuf : "unknown error"); |
|
|
0 |
0 |
if (!map) croak("Data::HashMap::Shared::I32: %s", errbuf[0] ? errbuf : "unknown error"); |
|
40
|
0 |
0 |
if (!map) croak("Data::HashMap::Shared::I32: %s", errbuf[0] ? errbuf : "unknown error"); |
|
|
0 |
0 |
if (!map) croak("Data::HashMap::Shared::I32: %s", errbuf[0] ? errbuf : "unknown error"); |
|
48
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
49
|
0 |
0 |
RETVAL = h->backing_fd; |
|
57
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
58
|
0 |
0 |
if (shm_msync(h) != 0) croak("Data::HashMap::Shared::I32 sync: %s", strerror(errno)); |
|
63
|
0 |
6 |
if (!SvROK(self_sv)) return; |
|
65
|
0 |
6 |
if (!h) return; |
|
72
|
1014 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
|
0 |
1014 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
|
0 |
1014 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
73
|
1014 |
0 |
RETVAL = shm_i32_put(h, key, value); |
|
80
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", 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) |
|
88
|
0 |
0 |
for (int i = 1; i < items; i += 2) |
|
91
|
0 |
0 |
RETVAL = count; |
|
98
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
100
|
0 |
0 |
if (h->shard_handles) { |
|
101
|
0 |
0 |
for (int i = 1; i < items; i++) |
|
105
|
0 |
0 |
for (int i = 1; i < items; i++) |
|
107
|
0 |
0 |
if (count) shm_i32_maybe_shrink(h); |
|
109
|
0 |
0 |
RETVAL = count; |
|
116
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
118
|
0 |
0 |
if (nkeys == 0) XSRETURN_EMPTY; |
|
119
|
0 |
0 |
EXTEND(SP, nkeys); |
|
|
0 |
0 |
EXTEND(SP, nkeys); |
|
120
|
0 |
0 |
if (h->shard_handles) { |
|
121
|
0 |
0 |
for (int i = 0; i < nkeys; i++) { |
|
124
|
0 |
0 |
if (shm_i32_get(h, key, &val)) |
|
133
|
0 |
0 |
uint32_t now = h->expires_at ? shm_now() : 0; |
|
140
|
0 |
0 |
for (int i = 0; i < nkeys; i++) { |
|
146
|
0 |
0 |
for (int i = 0; i < nkeys; i++) { |
|
153
|
0 |
0 |
for (uint32_t j = 0; j <= mask; j++) { |
|
156
|
0 |
0 |
if (st == SHM_EMPTY) break; |
|
157
|
0 |
0 |
if (st != tag) continue; |
|
158
|
0 |
0 |
if (nodes[idx].key == key) { |
|
159
|
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; |
|
165
|
0 |
0 |
if (found) mPUSHi(val); |
|
168
|
0 |
0 |
if (i + 1 < nkeys) { |
|
179
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
182
|
0 |
0 |
if (!shm_i32_get_with_ttl(h, key, &out_value, &out_ttl)) XSRETURN_EMPTY; |
|
183
|
0 |
0 |
EXTEND(SP, 2); |
|
185
|
0 |
0 |
if (out_ttl < 0) PUSHs(&PL_sv_undef); |
|
191
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
212
|
2 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
|
0 |
2 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
|
0 |
2 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
213
|
1 |
1 |
RETVAL = shm_i32_cas(h, key, expected, desired); |
|
220
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
222
|
0 |
0 |
if (!shm_i32_cas_take(h, key, expected, &out_value)) XSRETURN_UNDEF; |
|
230
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
231
|
0 |
0 |
RETVAL = shm_i32_persist(h, key); |
|
238
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
239
|
0 |
0 |
RETVAL = shm_i32_set_ttl(h, key, (uint32_t)ttl_sec); |
|
246
|
9 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
|
0 |
9 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
|
0 |
9 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
248
|
0 |
9 |
if (!shm_i32_get(h, key, &value)) XSRETURN_UNDEF; |
|
256
|
500 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
|
0 |
500 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
|
0 |
500 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
257
|
500 |
0 |
RETVAL = shm_i32_remove(h, key); |
|
264
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
265
|
0 |
0 |
RETVAL = shm_i32_exists(h, key); |
|
272
|
1 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
|
0 |
1 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
|
0 |
1 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
275
|
0 |
1 |
if (!ok) croak("Data::HashMap::Shared::I32: increment failed"); |
|
283
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
286
|
0 |
0 |
if (!ok) croak("Data::HashMap::Shared::I32: decrement failed"); |
|
294
|
1 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
|
0 |
1 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
|
0 |
1 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
297
|
0 |
1 |
if (!ok) croak("Data::HashMap::Shared::I32: incr_by failed"); |
|
305
|
3 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
|
0 |
3 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
|
0 |
3 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
308
|
0 |
3 |
if (!ok) croak("Data::HashMap::Shared::I32: max failed"); |
|
316
|
3 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
|
0 |
3 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
|
0 |
3 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
319
|
0 |
3 |
if (!ok) croak("Data::HashMap::Shared::I32: min failed"); |
|
327
|
2 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
|
0 |
2 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
|
0 |
2 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
328
|
0 |
2 |
RETVAL = (UV)shm_i32_size(h); |
|
335
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
336
|
0 |
0 |
RETVAL = (UV)shm_i32_max_entries(h); |
|
343
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", 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 |
EXTEND(SP, hdr->size); |
|
352
|
0 |
0 |
for (uint32_t i = 0; i < hdr->table_cap; i++) { |
|
353
|
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)) |
|
354
|
0 |
0 |
mXPUSHi(nodes[i].key); |
|
361
|
1 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
|
0 |
1 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
|
0 |
1 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
362
|
0 |
1 |
uint32_t ns = h->shard_handles ? h->num_shards : 1; |
|
363
|
1 |
1 |
for (uint32_t si = 0; si < ns; si++) { |
|
364
|
0 |
1 |
ShmHandle *sh = h->shard_handles ? h->shard_handles[si] : h; |
|
367
|
0 |
1 |
uint32_t now = sh->expires_at ? shm_now() : 0; |
|
369
|
0 |
1 |
EXTEND(SP, hdr->size); |
|
370
|
16 |
1 |
for (uint32_t i = 0; i < hdr->table_cap; i++) { |
|
371
|
10 |
6 |
if (SHM_IS_LIVE(sh->states[i]) && !SHM_IS_EXPIRED(sh, i, now)) |
|
|
0 |
10 |
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)) |
|
372
|
0 |
10 |
mXPUSHi(nodes[i].value); |
|
379
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
380
|
0 |
0 |
uint32_t ns = h->shard_handles ? h->num_shards : 1; |
|
381
|
0 |
0 |
for (uint32_t si = 0; si < ns; si++) { |
|
382
|
0 |
0 |
ShmHandle *sh = h->shard_handles ? h->shard_handles[si] : h; |
|
385
|
0 |
0 |
uint32_t now = sh->expires_at ? shm_now() : 0; |
|
387
|
0 |
0 |
EXTEND(SP, hdr->size * 2); |
|
388
|
0 |
0 |
for (uint32_t i = 0; i < hdr->table_cap; i++) { |
|
389
|
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)) { |
|
390
|
0 |
0 |
mXPUSHi(nodes[i].key); |
|
391
|
0 |
0 |
mXPUSHi(nodes[i].value); |
|
400
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
402
|
0 |
0 |
if (shm_i32_each(h, &out_key, &out_value)) { |
|
403
|
0 |
0 |
EXTEND(SP, 2); |
|
404
|
0 |
0 |
mXPUSHi(out_key); |
|
405
|
0 |
0 |
mXPUSHi(out_value); |
|
414
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
421
|
1 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
|
0 |
1 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
|
0 |
1 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
427
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
429
|
0 |
0 |
uint32_t ns = h->shard_handles ? h->num_shards : 1; |
|
430
|
0 |
0 |
for (uint32_t si = 0; si < ns; si++) { |
|
431
|
0 |
0 |
ShmHandle *sh = h->shard_handles ? h->shard_handles[si] : h; |
|
434
|
0 |
0 |
uint32_t now = sh->expires_at ? shm_now() : 0; |
|
436
|
0 |
0 |
for (uint32_t i = 0; i < hdr->table_cap; i++) { |
|
437
|
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)) { |
|
441
|
0 |
0 |
if (!hv_store(hv, kbuf, klen, val, 0)) SvREFCNT_dec(val); |
|
453
|
2 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
|
0 |
2 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
|
0 |
2 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
456
|
0 |
2 |
if (!rc) XSRETURN_UNDEF; |
|
464
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
465
|
0 |
0 |
REQUIRE_TTL(h); |
|
|
0 |
0 |
REQUIRE_TTL(h); |
|
466
|
0 |
0 |
RETVAL = shm_i32_put_ttl(h, key, value, (uint32_t)ttl_sec); |
|
473
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
474
|
0 |
0 |
RETVAL = (UV)shm_i32_max_size(h); |
|
481
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
482
|
0 |
0 |
RETVAL = (UV)shm_i32_ttl(h); |
|
489
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
491
|
0 |
0 |
if (!shm_i32_take(h, key, &out_value)) XSRETURN_UNDEF; |
|
499
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
502
|
0 |
0 |
if (!shm_i32_pop(h, &out_key, &out_val)) XSRETURN_EMPTY; |
|
503
|
0 |
0 |
EXTEND(SP, 2); |
|
510
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
513
|
0 |
0 |
if (!shm_i32_shift(h, &out_key, &out_val)) XSRETURN_EMPTY; |
|
514
|
0 |
0 |
EXTEND(SP, 2); |
|
521
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
522
|
0 |
0 |
if (limit == 0) XSRETURN_EMPTY; |
|
524
|
0 |
0 |
Newxz(entries, limit, shm_i32_drain_entry); |
|
529
|
0 |
0 |
if (buf) SAVEDESTRUCTOR_X(shm_free_cleanup, buf); |
|
531
|
0 |
0 |
EXTEND(SP, n * 2); |
|
532
|
0 |
0 |
for (uint32_t i = 0; i < n; i++) { |
|
541
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
542
|
0 |
0 |
RETVAL = (UV)shm_i32_flush_expired(h); |
|
549
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
552
|
0 |
0 |
EXTEND(SP, 2); |
|
559
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
567
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
568
|
0 |
0 |
RETVAL = shm_i32_touch(h, key); |
|
575
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
576
|
0 |
0 |
RETVAL = shm_i32_reserve(h, (uint32_t)target); |
|
583
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
591
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
599
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
600
|
0 |
0 |
RETVAL = (UV)shm_i32_stat_recoveries(h); |
|
607
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
615
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
623
|
2 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
|
0 |
2 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
|
0 |
2 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
624
|
1 |
1 |
RETVAL = shm_i32_add(h, key, value); |
|
631
|
2 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
|
0 |
2 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
|
0 |
2 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
632
|
0 |
2 |
REQUIRE_TTL(h); |
|
|
0 |
2 |
REQUIRE_TTL(h); |
|
633
|
1 |
1 |
RETVAL = shm_i32_add_ttl(h, key, value, (uint32_t)ttl_sec); |
|
640
|
1 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
|
0 |
1 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
|
0 |
1 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
641
|
1 |
0 |
RETVAL = shm_i32_update(h, key, value); |
|
648
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
649
|
0 |
0 |
REQUIRE_TTL(h); |
|
|
0 |
0 |
REQUIRE_TTL(h); |
|
650
|
0 |
0 |
RETVAL = shm_i32_update_ttl(h, key, value, (uint32_t)ttl_sec); |
|
657
|
1 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
|
0 |
1 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
|
0 |
1 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
660
|
0 |
1 |
if (rc != 1) XSRETURN_UNDEF; |
|
668
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
669
|
0 |
0 |
RETVAL = h->path ? newSVpv(h->path, 0) : &PL_sv_undef; |
|
676
|
0 |
0 |
if (SvROK(self_or_class) && SvOBJECT(SvRV(self_or_class))) { |
|
|
0 |
0 |
if (SvROK(self_or_class) && SvOBJECT(SvRV(self_or_class))) { |
|
678
|
0 |
0 |
if (!h) croak("Attempted to use a destroyed Data::HashMap::Shared::I32 object"); |
|
681
|
0 |
0 |
if (items < 2) croak("Usage: Data::HashMap::Shared::I32->unlink($path)"); |
|
690
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
692
|
0 |
0 |
if (remaining < 0) XSRETURN_UNDEF; |
|
700
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
701
|
0 |
0 |
RETVAL = (UV)shm_i32_capacity(h); |
|
708
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
709
|
0 |
0 |
RETVAL = (UV)shm_i32_tombstones(h); |
|
716
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I32", self_sv); |
|
718
|
0 |
0 |
if (!c) croak("Failed to allocate cursor"); |
|
729
|
0 |
0 |
if (!SvROK(self_sv)) return; |
|
731
|
0 |
0 |
if (!c) return; |
|
734
|
0 |
0 |
if (h) shm_i32_flush_deferred(h); |
|
740
|
0 |
0 |
EXTRACT_CURSOR("Data::HashMap::Shared::I32::Cursor", self_sv); |
|
|
0 |
0 |
EXTRACT_CURSOR("Data::HashMap::Shared::I32::Cursor", self_sv); |
|
|
0 |
0 |
EXTRACT_CURSOR("Data::HashMap::Shared::I32::Cursor", self_sv); |
|
742
|
0 |
0 |
if (shm_i32_cursor_next(c, &out_key, &out_value)) { |
|
743
|
0 |
0 |
EXTEND(SP, 2); |
|
744
|
0 |
0 |
mXPUSHi(out_key); |
|
745
|
0 |
0 |
mXPUSHi(out_value); |
|
753
|
0 |
0 |
EXTRACT_CURSOR("Data::HashMap::Shared::I32::Cursor", self_sv); |
|
|
0 |
0 |
EXTRACT_CURSOR("Data::HashMap::Shared::I32::Cursor", self_sv); |
|
|
0 |
0 |
EXTRACT_CURSOR("Data::HashMap::Shared::I32::Cursor", self_sv); |
|
759
|
0 |
0 |
EXTRACT_CURSOR("Data::HashMap::Shared::I32::Cursor", self_sv); |
|
|
0 |
0 |
EXTRACT_CURSOR("Data::HashMap::Shared::I32::Cursor", self_sv); |
|
|
0 |
0 |
EXTRACT_CURSOR("Data::HashMap::Shared::I32::Cursor", self_sv); |
|
760
|
0 |
0 |
RETVAL = shm_i32_cursor_seek(c, key); |