Lines Matching defs:current
139 struct item_info* current;
419 if (p->write.current)
420 item_free(p->write.current);
603 p->write.current = pa_queue_pop(p->send_queue);
605 if (!p->write.current)
618 if (p->write.current->type == PA_PSTREAM_ITEM_PACKET) {
621 pa_assert(p->write.current->packet);
623 p->write.data = (void *) pa_packet_data(p->write.current->packet, &plen);
631 } else if (p->write.current->type == PA_PSTREAM_ITEM_SHMRELEASE) {
634 p->write.descriptor[PA_PSTREAM_DESCRIPTOR_OFFSET_HI] = htonl(p->write.current->block_id);
636 } else if (p->write.current->type == PA_PSTREAM_ITEM_SHMREVOKE) {
639 p->write.descriptor[PA_PSTREAM_DESCRIPTOR_OFFSET_HI] = htonl(p->write.current->block_id);
645 pa_assert(p->write.current->type == PA_PSTREAM_ITEM_MEMBLOCK);
646 pa_assert(p->write.current->chunk.memblock);
648 p->write.descriptor[PA_PSTREAM_DESCRIPTOR_CHANNEL] = htonl(p->write.current->channel);
649 p->write.descriptor[PA_PSTREAM_DESCRIPTOR_OFFSET_HI] = htonl((uint32_t) (((uint64_t) p->write.current->offset) >> 32));
650 p->write.descriptor[PA_PSTREAM_DESCRIPTOR_OFFSET_LO] = htonl((uint32_t) ((uint64_t) p->write.current->offset));
652 flags = (uint32_t) (p->write.current->seek_mode & PA_FLAG_SEEKMASK);
660 pa_mempool *current_pool = pa_memblock_get_pool(p->write.current->chunk.memblock);
669 p->write.current->chunk.memblock,
702 shm_info[PA_PSTREAM_SHM_INDEX] = htonl((uint32_t) (offset + p->write.current->chunk.index));
703 shm_info[PA_PSTREAM_SHM_LENGTH] = htonl((uint32_t) p->write.current->chunk.length);
719 p->write.descriptor[PA_PSTREAM_DESCRIPTOR_LENGTH] = htonl((uint32_t) p->write.current->chunk.length);
720 p->write.memchunk = p->write.current->chunk;
728 if ((p->send_ancil_data_now = p->write.current->with_ancil_data))
729 p->write_ancil_data = &p->write.current->ancil_data;
756 if (!p->write.current)
759 if (!p->write.current) {
813 pa_assert(p->write.current);
814 item_free(p->write.current);
815 p->write.current = NULL;
1174 b = p->write.current || !pa_queue_isempty(p->send_queue);