| line |
true |
false |
branch |
|
7
|
4 |
0 |
char errbuf[SHM_ERR_BUFLEN]; const char* path = SvOK(path_sv) ? SvPV_nolen(path_sv) : NULL; ShmHandle* map = shm_i16_create(path, (uint32_t)max_entries, (uint32_t)lru_max, (uint32_t)ttl_default, (uint32_t)lru_skip, errbuf); |
|
8
|
0 |
4 |
if (!map) croak("HashMap::Shared::I16: %s", errbuf[0] ? errbuf : "unknown error"); |
|
|
0 |
0 |
if (!map) croak("HashMap::Shared::I16: %s", errbuf[0] ? errbuf : "unknown error"); |
|
17
|
0 |
0 |
if (!map) croak("HashMap::Shared::I16: %s", errbuf[0] ? errbuf : "unknown error"); |
|
|
0 |
0 |
if (!map) croak("HashMap::Shared::I16: %s", errbuf[0] ? errbuf : "unknown error"); |
|
27
|
0 |
0 |
const char* name = SvOK(name_sv) ? SvPV_nolen(name_sv) : NULL; |
|
29
|
0 |
0 |
if (!map) croak("Data::HashMap::Shared::I16: %s", errbuf[0] ? errbuf : "unknown error"); |
|
|
0 |
0 |
if (!map) croak("Data::HashMap::Shared::I16: %s", errbuf[0] ? errbuf : "unknown error"); |
|
39
|
0 |
0 |
if (!map) croak("Data::HashMap::Shared::I16: %s", errbuf[0] ? errbuf : "unknown error"); |
|
|
0 |
0 |
if (!map) croak("Data::HashMap::Shared::I16: %s", errbuf[0] ? errbuf : "unknown error"); |
|
47
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
48
|
0 |
0 |
RETVAL = h->backing_fd; |
|
56
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
57
|
0 |
0 |
if (shm_msync(h) != 0) croak("Data::HashMap::Shared::I16 sync: %s", strerror(errno)); |
|
62
|
0 |
4 |
if (!SvROK(self_sv)) return; |
|
64
|
0 |
4 |
if (!h) return; |
|
71
|
12 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
|
0 |
12 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
|
0 |
12 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
72
|
12 |
0 |
RETVAL = shm_i16_put(h, key, value); |
|
79
|
9 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
|
0 |
9 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
|
0 |
9 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
81
|
1 |
8 |
if (!shm_i16_get(h, key, &value)) XSRETURN_UNDEF; |
|
89
|
1 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
|
0 |
1 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
|
0 |
1 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
90
|
1 |
0 |
RETVAL = shm_i16_remove(h, key); |
|
97
|
2 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
|
0 |
2 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
|
0 |
2 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
98
|
1 |
1 |
RETVAL = shm_i16_exists(h, key); |
|
105
|
2 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
|
0 |
2 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
|
0 |
2 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
108
|
0 |
2 |
if (!ok) croak("HashMap::Shared::I16: increment failed"); |
|
116
|
1 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
|
0 |
1 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
|
0 |
1 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
119
|
0 |
1 |
if (!ok) croak("HashMap::Shared::I16: decrement failed"); |
|
127
|
1 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
|
0 |
1 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
|
0 |
1 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
130
|
0 |
1 |
if (!ok) croak("HashMap::Shared::I16: incr_by failed"); |
|
138
|
1 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
|
0 |
1 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
|
0 |
1 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
139
|
0 |
1 |
RETVAL = (UV)shm_i16_size(h); |
|
146
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
147
|
0 |
0 |
RETVAL = (UV)shm_i16_max_entries(h); |
|
154
|
1 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
|
0 |
1 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
|
0 |
1 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
155
|
0 |
1 |
uint32_t ns = h->shard_handles ? h->num_shards : 1; |
|
156
|
1 |
1 |
for (uint32_t si = 0; si < ns; si++) { |
|
157
|
0 |
1 |
ShmHandle *sh = h->shard_handles ? h->shard_handles[si] : h; |
|
160
|
0 |
1 |
uint32_t now = sh->expires_at ? shm_now() : 0; |
|
162
|
0 |
1 |
EXTEND(SP, hdr->size); |
|
163
|
16 |
1 |
for (uint32_t i = 0; i < hdr->table_cap; i++) { |
|
164
|
5 |
11 |
if (SHM_IS_LIVE(sh->states[i]) && !SHM_IS_EXPIRED(sh, i, now)) |
|
|
0 |
5 |
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)) |
|
165
|
0 |
5 |
mXPUSHi(nodes[i].key); |
|
172
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
173
|
0 |
0 |
uint32_t ns = h->shard_handles ? h->num_shards : 1; |
|
174
|
0 |
0 |
for (uint32_t si = 0; si < ns; si++) { |
|
175
|
0 |
0 |
ShmHandle *sh = h->shard_handles ? h->shard_handles[si] : h; |
|
178
|
0 |
0 |
uint32_t now = sh->expires_at ? shm_now() : 0; |
|
180
|
0 |
0 |
EXTEND(SP, hdr->size); |
|
181
|
0 |
0 |
for (uint32_t i = 0; i < hdr->table_cap; i++) { |
|
182
|
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)) |
|
183
|
0 |
0 |
mXPUSHi(nodes[i].value); |
|
191
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
192
|
0 |
0 |
uint32_t ns = h->shard_handles ? h->num_shards : 1; |
|
193
|
0 |
0 |
for (uint32_t si = 0; si < ns; si++) { |
|
194
|
0 |
0 |
ShmHandle *sh = h->shard_handles ? h->shard_handles[si] : h; |
|
197
|
0 |
0 |
uint32_t now = sh->expires_at ? shm_now() : 0; |
|
199
|
0 |
0 |
EXTEND(SP, hdr->size * 2); |
|
200
|
0 |
0 |
for (uint32_t i = 0; i < hdr->table_cap; i++) { |
|
201
|
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)) { |
|
202
|
0 |
0 |
mXPUSHi(nodes[i].key); |
|
203
|
0 |
0 |
mXPUSHi(nodes[i].value); |
|
212
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
214
|
0 |
0 |
if (shm_i16_each(h, &out_key, &out_value)) { |
|
215
|
0 |
0 |
EXTEND(SP, 2); |
|
216
|
0 |
0 |
mXPUSHi(out_key); |
|
217
|
0 |
0 |
mXPUSHi(out_value); |
|
226
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
233
|
1 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
|
0 |
1 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
|
0 |
1 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
239
|
1 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
|
0 |
1 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
|
0 |
1 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
241
|
0 |
1 |
uint32_t ns = h->shard_handles ? h->num_shards : 1; |
|
242
|
1 |
1 |
for (uint32_t si = 0; si < ns; si++) { |
|
243
|
0 |
1 |
ShmHandle *sh = h->shard_handles ? h->shard_handles[si] : h; |
|
246
|
0 |
1 |
uint32_t now = sh->expires_at ? shm_now() : 0; |
|
248
|
16 |
1 |
for (uint32_t i = 0; i < hdr->table_cap; i++) { |
|
249
|
5 |
11 |
if (SHM_IS_LIVE(sh->states[i]) && !SHM_IS_EXPIRED(sh, i, now)) { |
|
|
0 |
5 |
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)) { |
|
253
|
0 |
5 |
if (!hv_store(hv, kbuf, klen, val, 0)) SvREFCNT_dec(val); |
|
265
|
2 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
|
0 |
2 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
|
0 |
2 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
268
|
0 |
2 |
if (!rc) XSRETURN_UNDEF; |
|
276
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
277
|
0 |
0 |
REQUIRE_TTL(h); |
|
|
0 |
0 |
REQUIRE_TTL(h); |
|
278
|
0 |
0 |
RETVAL = shm_i16_put_ttl(h, key, value, (uint32_t)ttl_sec); |
|
285
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
286
|
0 |
0 |
RETVAL = (UV)shm_i16_max_size(h); |
|
293
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
294
|
0 |
0 |
RETVAL = (UV)shm_i16_ttl(h); |
|
301
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
303
|
0 |
0 |
if (!shm_i16_take(h, key, &out_value)) XSRETURN_UNDEF; |
|
311
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
314
|
0 |
0 |
if (!shm_i16_pop(h, &out_key, &out_val)) XSRETURN_EMPTY; |
|
315
|
0 |
0 |
EXTEND(SP, 2); |
|
322
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
325
|
0 |
0 |
if (!shm_i16_shift(h, &out_key, &out_val)) XSRETURN_EMPTY; |
|
326
|
0 |
0 |
EXTEND(SP, 2); |
|
333
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
334
|
0 |
0 |
if (limit == 0) XSRETURN_EMPTY; |
|
336
|
0 |
0 |
Newxz(entries, limit, shm_i16_drain_entry); |
|
342
|
0 |
0 |
EXTEND(SP, n * 2); |
|
343
|
0 |
0 |
for (uint32_t i = 0; i < n; i++) { |
|
347
|
0 |
0 |
if (buf) free(buf); |
|
353
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
354
|
0 |
0 |
RETVAL = (UV)shm_i16_flush_expired(h); |
|
361
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
364
|
0 |
0 |
EXTEND(SP, 2); |
|
371
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
379
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
380
|
0 |
0 |
RETVAL = shm_i16_touch(h, key); |
|
387
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
388
|
0 |
0 |
RETVAL = shm_i16_reserve(h, (uint32_t)target); |
|
395
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
403
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
411
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
412
|
0 |
0 |
RETVAL = (UV)shm_i16_stat_recoveries(h); |
|
419
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
427
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
435
|
2 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
|
0 |
2 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
|
0 |
2 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
436
|
1 |
1 |
RETVAL = shm_i16_add(h, key, value); |
|
443
|
2 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
|
0 |
2 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
|
0 |
2 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
444
|
1 |
1 |
RETVAL = shm_i16_update(h, key, value); |
|
451
|
2 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
|
0 |
2 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
|
0 |
2 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
454
|
1 |
1 |
if (rc != 1) XSRETURN_UNDEF; |
|
462
|
2 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
|
0 |
2 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
|
0 |
2 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
463
|
1 |
1 |
RETVAL = shm_i16_cas(h, key, expected, desired); |
|
470
|
1 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
|
0 |
1 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
|
0 |
1 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
471
|
1 |
0 |
RETVAL = shm_i16_persist(h, key); |
|
478
|
1 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
|
0 |
1 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
|
0 |
1 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
479
|
1 |
0 |
RETVAL = shm_i16_set_ttl(h, key, (uint32_t)ttl_sec); |
|
486
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
488
|
0 |
0 |
if (nkeys == 0) XSRETURN_EMPTY; |
|
489
|
0 |
0 |
EXTEND(SP, nkeys); |
|
|
0 |
0 |
EXTEND(SP, nkeys); |
|
490
|
0 |
0 |
if (h->shard_handles) { |
|
491
|
0 |
0 |
for (int i = 0; i < nkeys; i++) { |
|
494
|
0 |
0 |
if (shm_i16_get(h, key, &val)) |
|
503
|
0 |
0 |
uint32_t now = h->expires_at ? shm_now() : 0; |
|
510
|
0 |
0 |
for (int i = 0; i < nkeys; i++) { |
|
516
|
0 |
0 |
for (int i = 0; i < nkeys; i++) { |
|
523
|
0 |
0 |
for (uint32_t j = 0; j <= mask; j++) { |
|
526
|
0 |
0 |
if (st == SHM_EMPTY) break; |
|
527
|
0 |
0 |
if (st != tag) continue; |
|
528
|
0 |
0 |
if (nodes[idx].key == key) { |
|
529
|
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; |
|
535
|
0 |
0 |
if (found) mPUSHi(val); |
|
538
|
0 |
0 |
if (i + 1 < nkeys) { |
|
549
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
570
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
571
|
0 |
0 |
if ((items - 1) % 2 != 0) croak("set_multi requires even number of arguments (key, value pairs)"); |
|
573
|
0 |
0 |
if (h->shard_handles) { |
|
574
|
0 |
0 |
for (int i = 1; i < items; i += 2) |
|
580
|
0 |
0 |
for (int i = 1; i < items; i += 2) |
|
585
|
0 |
0 |
RETVAL = count; |
|
592
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
593
|
0 |
0 |
RETVAL = h->path ? newSVpv(h->path, 0) : &PL_sv_undef; |
|
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::I16 object"); |
|
606
|
0 |
0 |
if (items < 2) croak("Usage: Data::HashMap::Shared::I16->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)))) : |
|
618
|
3 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
|
0 |
3 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
|
0 |
3 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
620
|
0 |
3 |
if (remaining < 0) XSRETURN_UNDEF; |
|
628
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
629
|
0 |
0 |
RETVAL = (UV)shm_i16_capacity(h); |
|
636
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
637
|
0 |
0 |
RETVAL = (UV)shm_i16_tombstones(h); |
|
644
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
|
0 |
0 |
EXTRACT_MAP("Data::HashMap::Shared::I16", self_sv); |
|
646
|
0 |
0 |
if (!c) croak("Failed to allocate cursor"); |
|
657
|
0 |
0 |
if (!SvROK(self_sv)) return; |
|
659
|
0 |
0 |
if (!c) return; |
|
662
|
0 |
0 |
if (h) shm_i16_flush_deferred(h); |
|
668
|
0 |
0 |
EXTRACT_CURSOR("Data::HashMap::Shared::I16::Cursor", self_sv); |
|
|
0 |
0 |
EXTRACT_CURSOR("Data::HashMap::Shared::I16::Cursor", self_sv); |
|
|
0 |
0 |
EXTRACT_CURSOR("Data::HashMap::Shared::I16::Cursor", self_sv); |
|
670
|
0 |
0 |
if (shm_i16_cursor_next(c, &out_key, &out_value)) { |
|
671
|
0 |
0 |
EXTEND(SP, 2); |
|
672
|
0 |
0 |
mXPUSHi(out_key); |
|
673
|
0 |
0 |
mXPUSHi(out_value); |
|
681
|
0 |
0 |
EXTRACT_CURSOR("Data::HashMap::Shared::I16::Cursor", self_sv); |
|
|
0 |
0 |
EXTRACT_CURSOR("Data::HashMap::Shared::I16::Cursor", self_sv); |
|
|
0 |
0 |
EXTRACT_CURSOR("Data::HashMap::Shared::I16::Cursor", self_sv); |
|
687
|
0 |
0 |
EXTRACT_CURSOR("Data::HashMap::Shared::I16::Cursor", self_sv); |
|
|
0 |
0 |
EXTRACT_CURSOR("Data::HashMap::Shared::I16::Cursor", self_sv); |
|
|
0 |
0 |
EXTRACT_CURSOR("Data::HashMap::Shared::I16::Cursor", self_sv); |
|
688
|
0 |
0 |
RETVAL = shm_i16_cursor_seek(c, key); |