| 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_si16_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::SI16: %s", errbuf[0] ? errbuf : "unknown error"); |
|
|
0 |
0 |
if (!map) croak("Data::HashMap::Shared::SI16: %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::SI16: %s", errbuf[0] ? errbuf : "unknown error"); |
|
|
0 |
0 |
if (!map) croak("Data::HashMap::Shared::SI16: %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::SI16: %s", errbuf[0] ? errbuf : "unknown error"); |
|
|
0 |
0 |
if (!map) croak("Data::HashMap::Shared::SI16: %s", errbuf[0] ? errbuf : "unknown error"); |
|
40
|
0 |
0 |
if (!map) croak("Data::HashMap::Shared::SI16: %s", errbuf[0] ? errbuf : "unknown error"); |
|
|
0 |
0 |
if (!map) croak("Data::HashMap::Shared::SI16: %s", errbuf[0] ? errbuf : "unknown error"); |
|
48
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
49
|
0 |
0 |
RETVAL = h->backing_fd; |
|
57
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
58
|
0 |
0 |
if (shm_msync(h) != 0) croak("Data::HashMap::Shared::SI16 sync: %s", strerror(errno)); |
|
63
|
0 |
6 |
if (!SvROK(self_sv)) return; |
|
65
|
0 |
6 |
if (!h) return; |
|
72
|
7 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
|
0 |
7 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
|
0 |
7 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
73
|
0 |
7 |
EXTRACT_STR_KEY(key_sv); |
|
74
|
7 |
0 |
RETVAL = shm_si16_put(h, _kstr, (uint32_t)_klen, _kutf8, value); |
|
81
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
82
|
0 |
0 |
if ((items - 1) % 2 != 0) croak("set_multi requires even number of arguments (key, value pairs)"); |
|
84
|
0 |
0 |
if (h->shard_handles) { |
|
85
|
0 |
0 |
for (int i = 1; i < items; i += 2) { |
|
88
|
0 |
0 |
if (_klen > SHM_MAX_STR_LEN) croak("key too long (max 1GB)"); |
|
93
|
0 |
0 |
for (int i = 1; i < items; i += 2) { |
|
96
|
0 |
0 |
if (_klen > SHM_MAX_STR_LEN) croak("key too long (max 1GB)"); |
|
100
|
0 |
0 |
RETVAL = count; |
|
107
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
109
|
0 |
0 |
if (h->shard_handles) { |
|
110
|
0 |
0 |
for (int i = 1; i < items; i++) { |
|
113
|
0 |
0 |
if (_kl > SHM_MAX_STR_LEN) croak("key too long (max 1GB)"); |
|
118
|
0 |
0 |
for (int i = 1; i < items; i++) { |
|
121
|
0 |
0 |
if (_kl > SHM_MAX_STR_LEN) croak("key too long (max 1GB)"); |
|
124
|
0 |
0 |
if (count) shm_si16_maybe_shrink(h); |
|
126
|
0 |
0 |
RETVAL = count; |
|
133
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
135
|
0 |
0 |
if (nkeys == 0) XSRETURN_EMPTY; |
|
136
|
0 |
0 |
EXTEND(SP, nkeys); |
|
|
0 |
0 |
EXTEND(SP, nkeys); |
|
137
|
0 |
0 |
if (h->shard_handles) { |
|
138
|
0 |
0 |
for (int i = 0; i < nkeys; i++) { |
|
142
|
0 |
0 |
if (shm_si16_get(h, _ks, (uint32_t)_kl, _ku, &val)) |
|
152
|
0 |
0 |
uint32_t now = h->expires_at ? shm_now() : 0; |
|
155
|
0 |
0 |
for (int i = 0; i < nkeys; i++) { |
|
163
|
0 |
0 |
for (uint32_t j = 0; j <= mask; j++) { |
|
166
|
0 |
0 |
if (st == SHM_EMPTY) break; |
|
167
|
0 |
0 |
if (st != tag) continue; |
|
168
|
0 |
0 |
if (shm_si16__key_eq_str(&nodes[idx], arena, _ks, (uint32_t)_kl, _ku)) { |
|
169
|
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; |
|
174
|
0 |
0 |
if (found) mPUSHi(val); |
|
177
|
0 |
0 |
if (i + 1 < nkeys) { |
|
188
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
189
|
0 |
0 |
EXTRACT_STR_KEY(key_sv); |
|
192
|
0 |
0 |
if (!shm_si16_get_with_ttl(h, _kstr, (uint32_t)_klen, _kutf8, &out_value, &out_ttl)) XSRETURN_EMPTY; |
|
193
|
0 |
0 |
EXTEND(SP, 2); |
|
195
|
0 |
0 |
if (out_ttl < 0) PUSHs(&PL_sv_undef); |
|
201
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
222
|
2 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
|
0 |
2 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
|
0 |
2 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
223
|
0 |
2 |
EXTRACT_STR_KEY(key_sv); |
|
224
|
1 |
1 |
RETVAL = shm_si16_cas(h, _kstr, (uint32_t)_klen, _kutf8, expected, desired); |
|
231
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
232
|
0 |
0 |
EXTRACT_STR_KEY(key_sv); |
|
234
|
0 |
0 |
if (!shm_si16_cas_take(h, _kstr, (uint32_t)_klen, _kutf8, expected, &out_value)) XSRETURN_UNDEF; |
|
242
|
1 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
|
0 |
1 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
|
0 |
1 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
243
|
0 |
1 |
EXTRACT_STR_KEY(key_sv); |
|
244
|
1 |
0 |
RETVAL = shm_si16_persist(h, _kstr, (uint32_t)_klen, _kutf8); |
|
251
|
1 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
|
0 |
1 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
|
0 |
1 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
252
|
0 |
1 |
EXTRACT_STR_KEY(key_sv); |
|
253
|
1 |
0 |
RETVAL = shm_si16_set_ttl(h, _kstr, (uint32_t)_klen, _kutf8, (uint32_t)ttl_sec); |
|
260
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
261
|
0 |
0 |
EXTRACT_STR_KEY(key_sv); |
|
262
|
0 |
0 |
REQUIRE_TTL(h); |
|
|
0 |
0 |
REQUIRE_TTL(h); |
|
263
|
0 |
0 |
RETVAL = shm_si16_put_ttl(h, _kstr, (uint32_t)_klen, _kutf8, value, (uint32_t)ttl_sec); |
|
270
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
271
|
0 |
0 |
RETVAL = (UV)shm_si16_max_size(h); |
|
278
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
279
|
0 |
0 |
RETVAL = (UV)shm_si16_ttl(h); |
|
286
|
9 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
|
0 |
9 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
|
0 |
9 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
287
|
0 |
9 |
EXTRACT_STR_KEY(key_sv); |
|
289
|
0 |
9 |
if (!shm_si16_get(h, _kstr, (uint32_t)_klen, _kutf8, &value)) XSRETURN_UNDEF; |
|
297
|
1 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
|
0 |
1 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
|
0 |
1 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
298
|
0 |
1 |
EXTRACT_STR_KEY(key_sv); |
|
299
|
1 |
0 |
RETVAL = shm_si16_remove(h, _kstr, (uint32_t)_klen, _kutf8); |
|
306
|
1 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
|
0 |
1 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
|
0 |
1 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
307
|
0 |
1 |
EXTRACT_STR_KEY(key_sv); |
|
308
|
1 |
0 |
RETVAL = shm_si16_exists(h, _kstr, (uint32_t)_klen, _kutf8); |
|
315
|
2 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
|
0 |
2 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
|
0 |
2 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
316
|
0 |
2 |
EXTRACT_STR_KEY(key_sv); |
|
319
|
0 |
2 |
if (!ok) croak("Data::HashMap::Shared::SI16: increment failed"); |
|
327
|
1 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
|
0 |
1 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
|
0 |
1 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
328
|
0 |
1 |
EXTRACT_STR_KEY(key_sv); |
|
331
|
0 |
1 |
if (!ok) croak("Data::HashMap::Shared::SI16: decrement failed"); |
|
339
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
340
|
0 |
0 |
EXTRACT_STR_KEY(key_sv); |
|
343
|
0 |
0 |
if (!ok) croak("Data::HashMap::Shared::SI16: incr_by failed"); |
|
351
|
3 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
|
0 |
3 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
|
0 |
3 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
352
|
0 |
3 |
EXTRACT_STR_KEY(key_sv); |
|
355
|
0 |
3 |
if (!ok) croak("Data::HashMap::Shared::SI16: max failed"); |
|
363
|
3 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
|
0 |
3 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
|
0 |
3 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
364
|
0 |
3 |
EXTRACT_STR_KEY(key_sv); |
|
367
|
0 |
3 |
if (!ok) croak("Data::HashMap::Shared::SI16: min failed"); |
|
375
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
376
|
0 |
0 |
RETVAL = (UV)shm_si16_size(h); |
|
383
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
384
|
0 |
0 |
RETVAL = (UV)shm_si16_max_entries(h); |
|
391
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
392
|
0 |
0 |
uint32_t ns = h->shard_handles ? h->num_shards : 1; |
|
393
|
0 |
0 |
for (uint32_t si = 0; si < ns; si++) { |
|
394
|
0 |
0 |
ShmHandle *sh = h->shard_handles ? h->shard_handles[si] : h; |
|
397
|
0 |
0 |
uint32_t now = sh->expires_at ? shm_now() : 0; |
|
399
|
0 |
0 |
EXTEND(SP, hdr->size); |
|
400
|
0 |
0 |
for (uint32_t i = 0; i < hdr->table_cap; i++) { |
|
401
|
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)) { |
|
405
|
0 |
0 |
if (SHM_UNPACK_UTF8(nodes[i].key_len)) SvUTF8_on(sv); |
|
406
|
0 |
0 |
mXPUSHs(sv); |
|
414
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", 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); |
|
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)) |
|
425
|
0 |
0 |
mXPUSHi(nodes[i].value); |
|
432
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
433
|
0 |
0 |
uint32_t ns = h->shard_handles ? h->num_shards : 1; |
|
434
|
0 |
0 |
for (uint32_t si = 0; si < ns; si++) { |
|
435
|
0 |
0 |
ShmHandle *sh = h->shard_handles ? h->shard_handles[si] : h; |
|
438
|
0 |
0 |
uint32_t now = sh->expires_at ? shm_now() : 0; |
|
440
|
0 |
0 |
EXTEND(SP, hdr->size * 2); |
|
441
|
0 |
0 |
for (uint32_t i = 0; i < hdr->table_cap; i++) { |
|
442
|
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)) { |
|
446
|
0 |
0 |
if (SHM_UNPACK_UTF8(nodes[i].key_len)) SvUTF8_on(sv); |
|
447
|
0 |
0 |
mXPUSHs(sv); |
|
448
|
0 |
0 |
mXPUSHi(nodes[i].value); |
|
457
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
460
|
0 |
0 |
if (shm_si16_each(h, &out_key, &out_klen, &out_kutf8, &out_value)) { |
|
461
|
0 |
0 |
EXTEND(SP, 2); |
|
463
|
0 |
0 |
if (out_kutf8) SvUTF8_on(ksv); |
|
464
|
0 |
0 |
mXPUSHs(ksv); |
|
465
|
0 |
0 |
mXPUSHi(out_value); |
|
474
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
481
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
487
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
489
|
0 |
0 |
uint32_t ns = h->shard_handles ? h->num_shards : 1; |
|
490
|
0 |
0 |
for (uint32_t si = 0; si < ns; si++) { |
|
491
|
0 |
0 |
ShmHandle *sh = h->shard_handles ? h->shard_handles[si] : h; |
|
494
|
0 |
0 |
uint32_t now = sh->expires_at ? shm_now() : 0; |
|
496
|
0 |
0 |
for (uint32_t i = 0; i < hdr->table_cap; i++) { |
|
497
|
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)) { |
|
502
|
0 |
0 |
if (!hv_store(hv, kp, |
|
|
0 |
0 |
if (!hv_store(hv, kp, |
|
515
|
2 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
|
0 |
2 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
|
0 |
2 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
516
|
0 |
2 |
EXTRACT_STR_KEY(key_sv); |
|
519
|
0 |
2 |
if (!rc) XSRETURN_UNDEF; |
|
527
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
528
|
0 |
0 |
EXTRACT_STR_KEY(key_sv); |
|
530
|
0 |
0 |
if (!shm_si16_take(h, _kstr, (uint32_t)_klen, _kutf8, &out_value)) XSRETURN_UNDEF; |
|
538
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
541
|
0 |
0 |
if (!shm_si16_pop(h, &out_key, &out_klen, &out_kutf8, &out_val)) XSRETURN_EMPTY; |
|
542
|
0 |
0 |
EXTEND(SP, 2); |
|
544
|
0 |
0 |
if (out_kutf8) SvUTF8_on(ksv); |
|
551
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
554
|
0 |
0 |
if (!shm_si16_shift(h, &out_key, &out_klen, &out_kutf8, &out_val)) XSRETURN_EMPTY; |
|
555
|
0 |
0 |
EXTEND(SP, 2); |
|
557
|
0 |
0 |
if (out_kutf8) SvUTF8_on(ksv); |
|
564
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
565
|
0 |
0 |
if (limit == 0) XSRETURN_EMPTY; |
|
567
|
0 |
0 |
Newxz(entries, limit, shm_si16_drain_entry); |
|
572
|
0 |
0 |
if (buf) SAVEDESTRUCTOR_X(shm_free_cleanup, buf); |
|
574
|
0 |
0 |
EXTEND(SP, n * 2); |
|
575
|
0 |
0 |
for (uint32_t i = 0; i < n; i++) { |
|
577
|
0 |
0 |
if (entries[i].key_utf8) SvUTF8_on(ksv); |
|
586
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
587
|
0 |
0 |
RETVAL = (UV)shm_si16_flush_expired(h); |
|
594
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
597
|
0 |
0 |
EXTEND(SP, 2); |
|
604
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
612
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
613
|
0 |
0 |
EXTRACT_STR_KEY(key_sv); |
|
614
|
0 |
0 |
RETVAL = shm_si16_touch(h, _kstr, (uint32_t)_klen, _kutf8); |
|
621
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
622
|
0 |
0 |
RETVAL = shm_si16_reserve(h, (uint32_t)target); |
|
629
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
637
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
645
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
646
|
0 |
0 |
RETVAL = (UV)shm_si16_stat_recoveries(h); |
|
653
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
661
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
669
|
2 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
|
0 |
2 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
|
0 |
2 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
670
|
0 |
2 |
EXTRACT_STR_KEY(key_sv); |
|
671
|
1 |
1 |
RETVAL = shm_si16_add(h, _kstr, (uint32_t)_klen, _kutf8, value); |
|
678
|
2 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
|
0 |
2 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
|
0 |
2 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
679
|
0 |
2 |
EXTRACT_STR_KEY(key_sv); |
|
680
|
0 |
2 |
REQUIRE_TTL(h); |
|
|
0 |
2 |
REQUIRE_TTL(h); |
|
681
|
1 |
1 |
RETVAL = shm_si16_add_ttl(h, _kstr, (uint32_t)_klen, _kutf8, value, (uint32_t)ttl_sec); |
|
688
|
1 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
|
0 |
1 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
|
0 |
1 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
689
|
0 |
1 |
EXTRACT_STR_KEY(key_sv); |
|
690
|
1 |
0 |
RETVAL = shm_si16_update(h, _kstr, (uint32_t)_klen, _kutf8, value); |
|
697
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
698
|
0 |
0 |
EXTRACT_STR_KEY(key_sv); |
|
699
|
0 |
0 |
REQUIRE_TTL(h); |
|
|
0 |
0 |
REQUIRE_TTL(h); |
|
700
|
0 |
0 |
RETVAL = shm_si16_update_ttl(h, _kstr, (uint32_t)_klen, _kutf8, value, (uint32_t)ttl_sec); |
|
707
|
1 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
|
0 |
1 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
|
0 |
1 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
708
|
0 |
1 |
EXTRACT_STR_KEY(key_sv); |
|
711
|
0 |
1 |
if (rc != 1) XSRETURN_UNDEF; |
|
719
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
720
|
0 |
0 |
RETVAL = h->path ? newSVpv(h->path, 0) : &PL_sv_undef; |
|
727
|
0 |
0 |
if (SvROK(self_or_class) && SvOBJECT(SvRV(self_or_class))) { |
|
|
0 |
0 |
if (SvROK(self_or_class) && SvOBJECT(SvRV(self_or_class))) { |
|
729
|
0 |
0 |
if (!h) croak("Attempted to use a destroyed Data::HashMap::Shared::SI16 object"); |
|
732
|
0 |
0 |
if (items < 2) croak("Usage: Data::HashMap::Shared::SI16->unlink($path)"); |
|
741
|
1 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
|
0 |
1 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
|
0 |
1 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
742
|
0 |
1 |
EXTRACT_STR_KEY(key_sv); |
|
744
|
0 |
1 |
if (remaining < 0) XSRETURN_UNDEF; |
|
752
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
753
|
0 |
0 |
RETVAL = (UV)shm_si16_capacity(h); |
|
760
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
761
|
0 |
0 |
RETVAL = (UV)shm_si16_tombstones(h); |
|
768
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::SI16", self_sv); |
|
770
|
0 |
0 |
if (!c) croak("Failed to allocate cursor"); |
|
781
|
0 |
0 |
if (!SvROK(self_sv)) return; |
|
783
|
0 |
0 |
if (!c) return; |
|
786
|
0 |
0 |
if (h) shm_si16_flush_deferred(h); |
|
792
|
0 |
0 |
EXTRACT_CURSOR("Data::HashMap::Shared::SI16::Cursor", self_sv); |
|
|
0 |
0 |
EXTRACT_CURSOR("Data::HashMap::Shared::SI16::Cursor", self_sv); |
|
|
0 |
0 |
EXTRACT_CURSOR("Data::HashMap::Shared::SI16::Cursor", self_sv); |
|
795
|
0 |
0 |
if (shm_si16_cursor_next(c, &out_key, &out_klen, &out_kutf8, &out_value)) { |
|
796
|
0 |
0 |
EXTEND(SP, 2); |
|
798
|
0 |
0 |
if (out_kutf8) SvUTF8_on(ksv); |
|
799
|
0 |
0 |
mXPUSHs(ksv); |
|
800
|
0 |
0 |
mXPUSHi(out_value); |
|
808
|
0 |
0 |
EXTRACT_CURSOR("Data::HashMap::Shared::SI16::Cursor", self_sv); |
|
|
0 |
0 |
EXTRACT_CURSOR("Data::HashMap::Shared::SI16::Cursor", self_sv); |
|
|
0 |
0 |
EXTRACT_CURSOR("Data::HashMap::Shared::SI16::Cursor", self_sv); |
|
814
|
0 |
0 |
EXTRACT_CURSOR("Data::HashMap::Shared::SI16::Cursor", self_sv); |
|
|
0 |
0 |
EXTRACT_CURSOR("Data::HashMap::Shared::SI16::Cursor", self_sv); |
|
|
0 |
0 |
EXTRACT_CURSOR("Data::HashMap::Shared::SI16::Cursor", self_sv); |
|
815
|
0 |
0 |
EXTRACT_STR_KEY(key_sv); |
|
816
|
0 |
0 |
RETVAL = shm_si16_cursor_seek(c, _kstr, (uint32_t)_klen, _kutf8); |