Lines Matching refs:m_read
1151 if (RTMP_IsTimedout(r) && r->m_read.status == RTMP_READ_EOF) in RTMP_ToggleStream()
1152 r->m_read.status = 0; in RTMP_ToggleStream()
2032 r->m_read.flags |= RTMP_READ_SEEKING; in RTMP_SendSeek()
2033 r->m_read.nResumeTS = 0; in RTMP_SendSeek()
3166 r->m_read.flags &= ~RTMP_READ_SEEKING; in HandleInvoke()
3335 r->m_read.dataType |= 1; in HandleMetadata()
3337 r->m_read.dataType |= 4; in HandleMetadata()
4163 if (r->m_read.flags & RTMP_READ_HEADER) { in CloseInternal()
4164 free(r->m_read.buf); in CloseInternal()
4165 r->m_read.buf = NULL; in CloseInternal()
4167 r->m_read.dataType = 0; in CloseInternal()
4168 r->m_read.flags = 0; in CloseInternal()
4169 r->m_read.status = 0; in CloseInternal()
4170 r->m_read.nResumeTS = 0; in CloseInternal()
4171 r->m_read.nIgnoredFrameCounter = 0; in CloseInternal()
4172 r->m_read.nIgnoredFlvFrameCounter = 0; in CloseInternal()
4532 r->m_read.dataType |= (((packet.m_packetType == RTMP_PACKET_TYPE_AUDIO) << 2) | in Read_1_Packet()
4550 if (r->m_read.flags & RTMP_READ_SEEKING) in Read_1_Packet()
4563 if (r->m_read.flags & RTMP_READ_RESUME) in Read_1_Packet()
4568 if (r->m_read.nMetaHeaderSize > 0 in Read_1_Packet()
4583 if ((r->m_read.nMetaHeaderSize != nPacketLen) || in Read_1_Packet()
4585 (r->m_read.metaHeader, packetBody, in Read_1_Packet()
4586 r->m_read.nMetaHeaderSize) != 0)) in Read_1_Packet()
4600 if (r->m_read.nInitialFrameSize > 0) in Read_1_Packet()
4603 if (packet.m_packetType == r->m_read.initialFrameType in Read_1_Packet()
4604 && r->m_read.nInitialFrameSize == nPacketLen) in Read_1_Packet()
4612 (r->m_read.initialFrame, packetBody, in Read_1_Packet()
4613 r->m_read.nInitialFrameSize) == 0) in Read_1_Packet()
4616 r->m_read.flags |= RTMP_READ_GOTKF; in Read_1_Packet()
4655 r->m_read.initialFrameType in Read_1_Packet()
4658 if (ts == r->m_read.nResumeTS) in Read_1_Packet()
4662 if (r->m_read.nInitialFrameSize != dataSize in Read_1_Packet()
4663 || memcmp(r->m_read.initialFrame, in Read_1_Packet()
4665 r->m_read. in Read_1_Packet()
4673 r->m_read.flags |= RTMP_READ_GOTFLVK; in Read_1_Packet()
4691 else if (r->m_read.nResumeTS < ts) in Read_1_Packet()
4701 if (ts < r->m_read.nResumeTS) in Read_1_Packet()
4710 if (!(r->m_read.flags & RTMP_READ_GOTFLVK)) in Read_1_Packet()
4722 && (r->m_read.flags & (RTMP_READ_GOTKF|RTMP_READ_GOTFLVK))) in Read_1_Packet()
4735 r->m_read.flags |= (RTMP_READ_GOTKF|RTMP_READ_GOTFLVK); in Read_1_Packet()
4741 if (!(r->m_read.flags & RTMP_READ_GOTKF) && in Read_1_Packet()
4746 r->m_read.nIgnoredFrameCounter++; in Read_1_Packet()
4747 if (r->m_read.nIgnoredFrameCounter > MAX_IGNORED_FRAMES) in Read_1_Packet()
4754 if (!(r->m_read.flags & RTMP_READ_GOTFLVK) && in Read_1_Packet()
4759 r->m_read.nIgnoredFlvFrameCounter++; in Read_1_Packet()
4760 if (r->m_read.nIgnoredFlvFrameCounter > MAX_IGNORED_FRAMES) in Read_1_Packet()
4773 if (!(r->m_read.flags & RTMP_READ_NO_IGNORE) && in Read_1_Packet()
4787 r->m_read.flags |= RTMP_READ_NO_IGNORE; in Read_1_Packet()
4803 r->m_read.buf = malloc(size + 4); in Read_1_Packet()
4804 if (r->m_read.buf == 0) in Read_1_Packet()
4811 ptr = r->m_read.buf; in Read_1_Packet()
4827 nTimeStamp = r->m_read.nResumeTS + packet.m_nTimeStamp; in Read_1_Packet()
4873 delta = packet.m_nTimeStamp - nTimeStamp + r->m_read.nResumeTS; in Read_1_Packet()
4890 r->m_read.dataType |= (((*(packetBody + pos) == 0x08) << 2) | in Read_1_Packet()
4954 r->m_read.timestamp = (r->Link.lFlags & RTMP_LF_LIVE) ? packet.m_nTimeStamp : nTimeStamp; in Read_1_Packet()
4966 memcpy(buf, r->m_read.buf, len); in Read_1_Packet()
4967 r->m_read.bufpos = r->m_read.buf + len; in Read_1_Packet()
4968 r->m_read.buflen = ret - len; in Read_1_Packet()
4987 switch (r->m_read.status) { in RTMP_Read()
4999 if (!(r->m_read.flags & RTMP_READ_HEADER)) in RTMP_Read()
5001 if (!(r->m_read.flags & RTMP_READ_RESUME)) in RTMP_Read()
5005 r->m_read.buf = mybuf; in RTMP_Read()
5006 r->m_read.buflen = HEADERBUF; in RTMP_Read()
5009 r->m_read.buf += sizeof(flvHeader); in RTMP_Read()
5010 r->m_read.buflen -= sizeof(flvHeader); in RTMP_Read()
5013 while (r->m_read.timestamp == 0) in RTMP_Read()
5015 nRead = Read_1_Packet(r, r->m_read.buf, r->m_read.buflen); in RTMP_Read()
5019 r->m_read.buf = NULL; in RTMP_Read()
5020 r->m_read.buflen = 0; in RTMP_Read()
5021 r->m_read.status = nRead; in RTMP_Read()
5025 if (r->m_read.buf < mybuf || r->m_read.buf > end) { in RTMP_Read()
5027 memcpy(mybuf+cnt, r->m_read.buf, nRead); in RTMP_Read()
5028 free(r->m_read.buf); in RTMP_Read()
5029 r->m_read.buf = mybuf+cnt+nRead; in RTMP_Read()
5033 r->m_read.buf += nRead; in RTMP_Read()
5034 r->m_read.buflen -= nRead; in RTMP_Read()
5035 if (r->m_read.dataType == 5) in RTMP_Read()
5038 mybuf[4] = r->m_read.dataType; in RTMP_Read()
5039 r->m_read.buflen = r->m_read.buf - mybuf; in RTMP_Read()
5040 r->m_read.buf = mybuf; in RTMP_Read()
5041 r->m_read.bufpos = mybuf; in RTMP_Read()
5043 r->m_read.flags |= RTMP_READ_HEADER; in RTMP_Read()
5046 if ((r->m_read.flags & RTMP_READ_SEEKING) && r->m_read.buf) in RTMP_Read()
5049 free(r->m_read.buf); in RTMP_Read()
5050 r->m_read.buf = NULL; in RTMP_Read()
5051 r->m_read.bufpos = NULL; in RTMP_Read()
5052 r->m_read.buflen = 0; in RTMP_Read()
5056 if (r->m_read.buf) in RTMP_Read()
5058 nRead = r->m_read.buflen; in RTMP_Read()
5061 memcpy(buf, r->m_read.bufpos, nRead); in RTMP_Read()
5062 r->m_read.buflen -= nRead; in RTMP_Read()
5063 if (!r->m_read.buflen) in RTMP_Read()
5065 free(r->m_read.buf); in RTMP_Read()
5066 r->m_read.buf = NULL; in RTMP_Read()
5067 r->m_read.bufpos = NULL; in RTMP_Read()
5071 r->m_read.bufpos += nRead; in RTMP_Read()
5087 r->m_read.status = nRead; in RTMP_Read()