Searched defs:packetQueue (Results 1 – 7 of 7) sorted by relevance
416 type packetQueue struct { struct417 …y chan packetQueueState // contains configuration parameters when the queue is empty and not closed418 ready chan packetQueueState // contains the packets when non-empty or closed419 full chan packetQueueState // contains the packets when buffer is full and not closed434 func (pq *packetQueue) get() packetQueueState {444 func (pq *packetQueue) put(q packetQueueState) {460 func (pq *packetQueue) closeRead() error {467 func (pq *packetQueue) closeWrite() error {474 func (pq *packetQueue) setLinger(linger bool) error {485 func (pq *packetQueue) write(dt *deadlineTimer, b []byte, from sockaddr) (n int, err error) {[all …]
39 private final LinkedBlockingQueue<byte[]> packetQueue; field in TransferRtpDataChannel
42 private final TreeSet<RtpPacketContainer> packetQueue; field in RtpPacketReorderingQueue
248 private final ConcurrentLinkedQueue<byte[]> packetQueue; field in RtspPlaybackTest.FakeUdpDataSourceRtpDataChannel