/frameworks/av/media/libstagefright/rtsp/ |
H A D | AAVCAssembler.cpp | 69 sp<ABuffer> buffer = *queue->begin(); local 73 mNextExpectedSeqNo = (uint32_t)buffer->int32Data(); 74 } else if ((uint32_t)buffer->int32Data() != mNextExpectedSeqNo) { 80 const uint8_t *data = buffer->data(); 81 size_t size = buffer->size(); 86 ALOGV("Ignoring corrupt buffer."); 95 addSingleNALUnit(buffer); 104 bool success = addSingleTimeAggregationPacket(buffer); 117 ALOGV("Ignoring unsupported buffer (nalType=%d)", nalType); 126 void AAVCAssembler::addSingleNALUnit(const sp<ABuffer> &buffer) { argument 143 addSingleTimeAggregationPacket(const sp<ABuffer> &buffer) argument 184 sp<ABuffer> buffer = *queue->begin(); local 230 const sp<ABuffer> &buffer = *it; local 295 const sp<ABuffer> &buffer = *it; local [all...] |
H A D | AH263Assembler.cpp | 75 sp<ABuffer> buffer = *queue->begin(); local 79 mNextExpectedSeqNo = (uint32_t)buffer->int32Data(); 80 } else if ((uint32_t)buffer->int32Data() != mNextExpectedSeqNo) { 89 CHECK(buffer->meta()->findInt32("rtp-time", (int32_t *)&rtpTime)); 96 // hexdump(buffer->data(), buffer->size()); 98 if (buffer->size() < 2) { 105 unsigned payloadHeader = U16_AT(buffer->data()); 137 buffer->setRange(buffer [all...] |
H A D | AMPEG2TSAssembler.cpp | 76 sp<ABuffer> buffer = *queue->begin(); local 80 mNextExpectedSeqNo = (uint32_t)buffer->int32Data(); 81 } else if ((uint32_t)buffer->int32Data() != mNextExpectedSeqNo) { 87 // hexdump(buffer->data(), buffer->size()); 89 if ((buffer->size() % 188) > 0) { 99 msg->setBuffer("access-unit", buffer);
|
H A D | AMPEG4AudioAssembler.cpp | 69 sp<ABuffer> buffer = new ABuffer(outLen); local 70 uint8_t *out = buffer->data(); 95 return buffer; 362 sp<ABuffer> AMPEG4AudioAssembler::removeLATMFraming(const sp<ABuffer> &buffer) { argument 365 sp<ABuffer> out = new ABuffer(buffer->size()); 369 uint8_t *ptr = buffer->data(); 382 CHECK_LT(offset, buffer->size()); 408 CHECK_LT(offset, buffer->size()); 409 CHECK_LE(payloadLength, buffer->size() - offset); 420 CHECK_LE(offset + (mOtherDataLenBits / 8), buffer 509 sp<ABuffer> buffer = *queue->begin(); local [all...] |
H A D | AMPEG4ElementaryAssembler.cpp | 229 sp<ABuffer> buffer = *queue->begin(); local 233 mNextExpectedSeqNo = (uint32_t)buffer->int32Data(); 234 } else if ((uint32_t)buffer->int32Data() != mNextExpectedSeqNo) { 241 CHECK(buffer->meta()->findInt32("rtp-time", (int32_t *)&rtpTime)); 249 mPackets.push_back(buffer); 251 // hexdump(buffer->data(), buffer->size()); 252 if (buffer->size() < 2) { 256 unsigned AU_headers_length = U16_AT(buffer->data()); // in bits 258 if (buffer [all...] |
H A D | APacketSource.cpp | 78 sp<ABuffer> buffer = new ABuffer(outLen); local 79 uint8_t *out = buffer->data(); 104 return buffer;
|
H A D | ARTPConnection.cpp | 311 sp<ABuffer> buffer = new ABuffer(kMaxUDPSize); local 328 buffer->setRange(0, 0); 333 source->addReceiverReport(buffer); 336 source->addFIR(buffer); 340 if (buffer->size() > 0) { 346 s->mRTCPSocket, buffer->data(), buffer->size(), 0, 359 CHECK_EQ(n, (ssize_t)buffer->size()); 378 sp<ABuffer> buffer = new ABuffer(65536); local 388 buffer 413 parseRTP(StreamInfo *s, const sp<ABuffer> &buffer) argument 499 parseRTCP(StreamInfo *s, const sp<ABuffer> &buffer) argument 641 injectPacket(int index, const sp<ABuffer> &buffer) argument 652 sp<ABuffer> buffer; local [all...] |
H A D | ARTPSource.cpp | 88 void ARTPSource::processRTPPacket(const sp<ABuffer> &buffer) { argument 89 if (queuePacket(buffer) && mAssembler != NULL) { 105 bool ARTPSource::queuePacket(const sp<ABuffer> &buffer) { argument 106 uint32_t seqNum = (uint32_t)buffer->int32Data(); 110 mQueue.push_back(buffer); 145 buffer->setInt32Data(seqNum); 153 ALOGW("Discarding duplicate buffer"); 157 mQueue.insert(it, buffer); 166 void ARTPSource::addFIR(const sp<ABuffer> &buffer) { argument 179 if (buffer 216 addReceiverReport(const sp<ABuffer> &buffer) argument [all...] |
H A D | ARTPWriter.cpp | 176 static void StripStartcode(MediaBuffer *buffer) { argument 177 if (buffer->range_length() < 4) { 182 (const uint8_t *)buffer->data() + buffer->range_offset(); 185 buffer->set_range( 186 buffer->range_offset() + 4, buffer->range_length() - 4); 198 MediaBuffer *buffer; 199 CHECK_EQ(mSource->read(&buffer), (status_t)OK); 201 StripStartcode(buffer); 299 sp<ABuffer> buffer = new ABuffer(65536); local 311 send(const sp<ABuffer> &buffer, bool isRTCP) argument 330 addSR(const sp<ABuffer> &buffer) argument 369 addSDES(const sp<ABuffer> &buffer) argument 526 makeH264SPropParamSets(MediaBuffer *buffer) argument 555 sp<ABuffer> buffer = new ABuffer(8); local 582 sp<ABuffer> buffer = new ABuffer(kMaxPacketSize); local 686 sp<ABuffer> buffer = new ABuffer(kMaxPacketSize); local 773 sp<ABuffer> buffer = new ABuffer(kMaxPacketSize); local [all...] |
H A D | ARTSPConnection.cpp | 595 sp<ABuffer> buffer = new ABuffer((x[1] << 8) | x[2]); local 596 if (receive(buffer->data(), buffer->size()) != OK) { 600 buffer->meta()->setInt32("index", (int32_t)x[0]); 602 return buffer; 617 sp<ABuffer> buffer = receiveBinaryData(); local 619 if (buffer == NULL) { 625 notify->setBuffer("buffer", buffer);
|
H A D | ARawAudioAssembler.cpp | 76 sp<ABuffer> buffer = *queue->begin(); local 80 mNextExpectedSeqNo = (uint32_t)buffer->int32Data(); 81 } else if ((uint32_t)buffer->int32Data() != mNextExpectedSeqNo) { 87 // hexdump(buffer->data(), buffer->size()); 89 if (buffer->size() < 1) { 99 msg->setBuffer("access-unit", buffer);
|
H A D | MyHandler.h | 261 static void addSDES(int s, const sp<ABuffer> &buffer) { argument 268 uint8_t *data = buffer->data() + buffer->size(); 314 buffer->setRange(buffer->offset(), buffer->size() + offset); 1334 sp<ABuffer> buffer; local 1335 CHECK(msg->findBuffer("buffer", &buffer)); 1338 CHECK(buffer [all...] |
H A D | MyTransmitter.h | 126 MediaBuffer *buffer; local 127 CHECK_EQ(mEncoder->read(&buffer), (status_t)OK); 128 CHECK(buffer != NULL); 130 makeH264SPropParamSets(buffer); 132 buffer->release(); 133 buffer = NULL; 436 sp<ABuffer> buffer = new ABuffer(65536); 437 ssize_t n = recv(mRTCPSocket, buffer->data(), buffer->size(), 0); 444 hexdump(buffer 616 sp<ABuffer> buffer = new ABuffer(65536); local 717 sp<ABuffer> buffer = new ABuffer(65536); local 861 makeH264SPropParamSets(MediaBuffer *buffer) argument 889 addSR(const sp<ABuffer> &buffer) argument 928 addSDES(const sp<ABuffer> &buffer) argument [all...] |
H A D | SDPLoader.cpp | 119 sp<ABuffer> buffer = new ABuffer(sdpSize); local 122 ssize_t readSize = mHTTPDataSource->readAt(0, buffer->data(), sdpSize); 130 if (desc == NULL || !desc->setTo(buffer->data(), (size_t)readSize)) {
|
H A D | UDPPusher.cpp | 82 sp<ABuffer> buffer = new ABuffer(length); local 83 if (fread(buffer->data(), 1, length, mFile) < length) { 89 mSocket, buffer->data(), buffer->size(), 0, 92 CHECK_EQ(n, (ssize_t)buffer->size()); 118 sp<ABuffer> buffer = new ABuffer(8); local 119 uint8_t *data = buffer->data(); 128 buffer->setRange(0, 8); 134 mSocket, buffer->data(), buffer [all...] |
H A D | VideoSource.h | 58 MediaBuffer **buffer, const MediaSource::ReadOptions *options) { 65 status_t err = mGroup.acquire_buffer(buffer); 71 memset((*buffer)->data(), x, mSize); 72 (*buffer)->set_range(0, mSize); 73 (*buffer)->meta_data()->clear(); 74 (*buffer)->meta_data()->setInt64( 78 // printf("VideoSource::read - returning buffer\n"); 79 // LOG(INFO)("VideoSource::read - returning buffer"); 57 read( MediaBuffer **buffer, const MediaSource::ReadOptions *options) argument
|
H A D | rtp_test.cpp | 195 MediaBuffer *buffer; local 196 status_t err = decoder->read(&buffer); 212 if (buffer->range_length() != 0) { 214 CHECK(buffer->meta_data()->findInt64(kKeyTime, &timeUs)); 217 buffer->range_length(), timeUs / 1E6); 221 buffer->release(); 222 buffer = NULL;
|
/frameworks/av/media/libstagefright/tests/ |
H A D | DummyRecorder.cpp | 78 MediaBuffer *buffer; local 80 while (mStarted && (err = mSource->read(&buffer)) == OK){ 81 // if not getting a valid buffer from source, then exit 82 if (buffer == NULL) { 85 buffer->release(); 86 buffer = NULL;
|
/frameworks/av/media/libstagefright/webm/ |
H A D | WebmFrameThread.cpp | 334 MediaBuffer *buffer; local 335 while (!mDone && (err = mSource->read(&buffer, NULL)) == OK) { 336 if (buffer->range_length() == 0) { 337 buffer->release(); 338 buffer = NULL; 342 sp<MetaData> md = buffer->meta_data(); 352 buffer->release(); 353 buffer = NULL; 376 buffer); 384 buffer [all...] |
/frameworks/av/media/libstagefright/wifi-display/rtp/ |
H A D | RTPSender.cpp | 185 const sp<ABuffer> &buffer, uint8_t packetType, PacketizationMode mode) { 190 err = queueRawPacket(buffer, packetType); 194 err = queueTSPackets(buffer, packetType); 198 err = queueAVCBuffer(buffer, packetType); 460 const sp<ABuffer> &buffer, bool storeInHistory, 465 mRTPSessionID, buffer->data(), buffer->size(), 473 mLastRTPTime = U32_AT(buffer->data() + 4); 476 mNumRTPOctetsSent += buffer->size() - 12; 484 mHistory.push_back(buffer); 184 queueBuffer( const sp<ABuffer> &buffer, uint8_t packetType, PacketizationMode mode) argument 459 sendRTPPacket( const sp<ABuffer> &buffer, bool storeInHistory, bool timeValid, int64_t timeUs) argument 613 onRTCPData(const sp<ABuffer> &buffer) argument 713 const sp<ABuffer> &buffer = *it; local [all...] |
/frameworks/av/media/libstagefright/wifi-display/source/ |
H A D | Converter.cpp | 500 sp<ABuffer> buffer = *mInputBufferQueue.begin(); local 503 int16_t *ptr = (int16_t *)buffer->data(); 504 int16_t *stop = (int16_t *)(buffer->data() + buffer->size()); 519 size_t copy = buffer->size(); 525 buffer->data(), 530 buffer->setRange(buffer->offset() + copy, buffer->size() - copy); 533 CHECK(buffer 611 sp<ABuffer> buffer = *mInputBufferQueue.begin(); local 722 sp<ABuffer> buffer; local [all...] |
H A D | RepeaterSource.cpp | 110 MediaBuffer **buffer, const ReadOptions *options) { 157 *buffer = mBuffer; 158 (*buffer)->meta_data()->setInt64(kKeyTime, bufferTimeUs); 183 MediaBuffer *buffer; local 184 status_t err = mSource->read(&buffer); 186 ALOGV("read mbuf %p", buffer); 193 mBuffer = buffer; 109 read( MediaBuffer **buffer, const ReadOptions *options) argument
|
H A D | TSPacketizer.cpp | 515 // the first fragment of "buffer" follows 642 sp<ABuffer> buffer = new ABuffer(numTSPackets * 188); local 643 uint8_t *packetDataStart = buffer->data(); 957 // for subsequent fragments of "buffer": 966 // the fragment of "buffer" follows. 1007 CHECK(packetDataStart == buffer->data() + buffer->capacity()); 1009 *packets = buffer;
|
/frameworks/av/media/libstagefright/yuv/ |
H A D | YUVImage.cpp | 32 uint8_t *buffer = new uint8_t[numberOfBytes]; local 33 mBuffer = buffer; 39 YUVImage::YUVImage(YUVFormat yuvFormat, int32_t width, int32_t height, uint8_t *buffer) { argument 43 mBuffer = buffer;
|
/frameworks/av/media/mediaserver/ |
H A D | main_mediaserver.cpp | 72 char buffer[32]; local 94 snprintf(buffer, sizeof(buffer), "unknown (%d)", info.si_code); 95 code = buffer;
|