Lines Matching defs:sp
54 struct shared_pool *sp = spp->sp;
55 assert(sp != NULL);
56 spp->c_read_id = spp->sp->read_reg.value;
57 spp->c_write_id = spp->sp->write_reg.value;
58 spp->c_size = spp->sp->size_reg.value;
59 // spp->c_read_id = sp_atomic_read_reg(&spp->sp->read_reg);
60 // spp->c_write_id = sp_atomic_read_reg(&spp->sp->write_reg);
61 // spp->c_size = sp_atomic_read_reg(&spp->sp->size_reg);
238 struct shared_pool *sp = spp->sp;
239 assert(sp != NULL);
247 sp_atomic_set_reg(&sp->read_reg, 0);
248 sp_atomic_set_reg(&sp->write_reg, 0);
249 sp_atomic_set_reg(&sp->size_reg, slot_count);
251 memset(&sp->slot_list[i], 0, sizeof(union slot));
293 spp->sp = (struct shared_pool *)spp->va;
314 /* printf("##### procon sizeof spp[%lu], sizeof sp[%lu]\n",
331 assert(spp->sp == NULL);
359 spp->sp = (struct shared_pool *)spp->va;
401 spp->sp->slot_list[id].d.buffer_id = buf_id;
402 spp->sp->slot_list[id].d.no_pbufs = no_pbufs;
403 spp->sp->slot_list[id].d.pbuf_id = id;
404 spp->sp->slot_list[id].d.offset = offset;
405 spp->sp->slot_list[id].d.len = len;
406 spp->sp->slot_list[id].d.client_data = client_data;
407 spp->sp->slot_list[id].d.ts = ts;
415 cache_flush_range(&spp->sp->slot_list[id], SLOT_SIZE);
442 sp_copy_slot_data(d, &spp->sp->slot_list[idx].d);
470 sp_atomic_set_reg(&spp->sp->read_reg, idx);
512 sp_atomic_set_reg(&spp->sp->write_reg, idx);
544 sp_atomic_set_reg(&spp->sp->write_reg, idx);
597 return spp->sp->slot_list[id].d.client_data;
612 sp_copy_slot_data(d, &spp->sp->slot_list[id].d);
616 // disp_name(), &spp->sp->slot_list[id].d,
617 // id, spp->sp->slot_list[id].d.client_data, d->client_data);
619 spp->sp->slot_list[id].d.client_data = 0;
659 sp_copy_slot_data(&spp->sp->slot_list[wi].d, d);
663 cache_flush_range(&spp->sp->slot_list[wi], SLOT_SIZE);
699 sp_copy_slot_data(&spp->sp->slot_list[idx].d, d);
702 cache_flush_range(&spp->sp->slot_list[idx], SLOT_SIZE);
710 sp_print_slot(&spp->sp->slot_list[idx].d);
741 cache_flush_range(&spp->sp->slot_list[spp->ghost_read_id], SLOT_SIZE);
744 sp_copy_slot_data(dst, &spp->sp->slot_list[spp->ghost_read_id].d);
746 sp_print_slot(&spp->sp->slot_list[spp->ghost_read_id].d);
783 cache_flush_range(&spp->sp->slot_list[ri], SLOT_SIZE);
786 sp_copy_slot_data(&tmp, &spp->sp->slot_list[ri].d);
787 sp_copy_slot_data(&spp->sp->slot_list[ri].d, new_slot);
791 cache_flush_range(&spp->sp->slot_list[ri], SLOT_SIZE);
819 struct shared_pool *sp = spp->sp;
820 assert(sp != NULL);
824 sp->size_reg.value, sp->read_reg.value, sp->write_reg.value,
844 struct shared_pool *sp = spp->sp;
845 assert(sp != NULL);
847 uint64_t queue_size = sp->size_reg.value;
851 sp_print_slot(&sp->slot_list[i].d);