Searched defs:buffer (Results 126 - 150 of 524) sorted by path

1234567891011>>

/frameworks/av/media/libstagefright/rtsp/
H A DAAVCAssembler.cpp69 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 DAH263Assembler.cpp75 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 DAMPEG2TSAssembler.cpp76 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 DAMPEG4AudioAssembler.cpp69 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 DAMPEG4ElementaryAssembler.cpp229 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 DAPacketSource.cpp78 sp<ABuffer> buffer = new ABuffer(outLen); local
79 uint8_t *out = buffer->data();
104 return buffer;
H A DARTPConnection.cpp311 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 DARTPSource.cpp88 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 DARTPWriter.cpp176 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 DARTSPConnection.cpp595 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 DARawAudioAssembler.cpp76 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 DMyHandler.h261 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 DMyTransmitter.h126 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 DSDPLoader.cpp119 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 DUDPPusher.cpp82 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 DVideoSource.h58 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 Drtp_test.cpp195 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 DDummyRecorder.cpp78 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 DWebmFrameThread.cpp334 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 DRTPSender.cpp185 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 DConverter.cpp500 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 DRepeaterSource.cpp110 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 DTSPacketizer.cpp515 // 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 DYUVImage.cpp32 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 Dmain_mediaserver.cpp72 char buffer[32]; local
94 snprintf(buffer, sizeof(buffer), "unknown (%d)", info.si_code);
95 code = buffer;

Completed in 196 milliseconds

1234567891011>>