285     m_context(context),  in AddressSpaceStream()
302         m_ops.unmap(m_context.to_host, sizeof(struct asg_ring_storage));  in ~AddressSpaceStream()
303         m_ops.unmap(m_context.buffer, m_writeBufferSize);  in ~AddressSpaceStream()
465     m_context.ring_config->transfer_size = size;  in writeFully()
466     m_context.ring_config->transfer_mode = 3;  in writeFully()
479                 m_context.to_host_large_xfer.ring,  in writeFully()
480                 &m_context.to_host_large_xfer.view,  in writeFully()
483         if (*(m_context.host_state) != ASG_HOST_STATE_CAN_CONSUME) {  in writeFully()
499     m_context.ring_config->transfer_mode = 1;  in writeFully()
519     return 1 == m_context.ring_config->in_error;  in isInError()
536                 m_context.from_host_large_xfer.ring,  in speculativeRead()
537                 &m_context.from_host_large_xfer.view);  in speculativeRead()
552             m_context.from_host_large_xfer.ring,  in speculativeRead()
553             &m_context.from_host_large_xfer.view,  in speculativeRead()
584     m_writeStart += m_context.ring_config->flush_interval;  in advanceWrite()
586     if (m_writeStart == m_buf + m_context.ring_config->buffer_size) {  in advanceWrite()
592     uint32_t currAvailRead = ring_buffer_available_read(m_context.to_host, 0);  in ensureConsumerFinishing()
596         uint32_t nextAvailRead = ring_buffer_available_read(m_context.to_host, 0);  in ensureConsumerFinishing()
602         if (*(m_context.host_state) != ASG_HOST_STATE_CAN_CONSUME) {  in ensureConsumerFinishing()
613         ring_buffer_available_read(m_context.to_host, 0);  in ensureType1Finished()
617         currAvailRead = ring_buffer_available_read(m_context.to_host, 0);  in ensureType1Finished()
627             m_context.to_host_large_xfer.ring,  in ensureType3Finished()
628             &m_context.to_host_large_xfer.view);  in ensureType3Finished()
633                 m_context.to_host_large_xfer.ring,  in ensureType3Finished()
634                 &m_context.to_host_large_xfer.view);  in ensureType3Finished()
635         if (*(m_context.host_state) != ASG_HOST_STATE_CAN_CONSUME) {  in ensureType3Finished()
656     uint32_t maxSteps = m_context.ring_config->buffer_size /  in type1Write()
657             m_context.ring_config->flush_interval;  in type1Write()
661     uint32_t ringAvailReadNow = ring_buffer_available_read(m_context.to_host, 0);  in type1Write()
666         ringAvailReadNow = ring_buffer_available_read(m_context.to_host, 0);  in type1Write()
672             m_context.to_host,  in type1Write()
676         if (*(m_context.host_state) != ASG_HOST_STATE_CAN_CONSUME) {  in type1Write()