Lines Matching refs:amf
208 amf::write(buf, "connect"); in sendConnectPacket()
212 amf::write(buf, static_cast<double>(cn)); in sendConnectPacket()
214 buf.appendByte(amf::OBJECT_AMF0); in sendConnectPacket()
215 if (!app.empty()) amf::writeProperty(buf, "app", app); in sendConnectPacket()
216 if (!ver.empty()) amf::writeProperty(buf, "flashVer", ver); in sendConnectPacket()
217 if (!swfurl.empty()) amf::writeProperty(buf, "swfUrl", swfurl); in sendConnectPacket()
218 if (!tcurl.empty()) amf::writeProperty(buf, "tcUrl", tcurl); in sendConnectPacket()
219 amf::writeProperty(buf, "fpad", false); in sendConnectPacket()
220 amf::writeProperty(buf, "capabilities", 15.0); in sendConnectPacket()
221 amf::writeProperty(buf, "audioCodecs", 3191.0); in sendConnectPacket()
222 amf::writeProperty(buf, "videoCodecs", 252.0); in sendConnectPacket()
223 amf::writeProperty(buf, "videoFunction", 1.0); in sendConnectPacket()
224 if (!pageurl.empty()) amf::writeProperty(buf, "pageUrl", pageurl); in sendConnectPacket()
227 buf.appendByte(amf::OBJECT_END_AMF0); in sendConnectPacket()
241 amf::write(buf, "_checkbw"); in sendCheckBW()
242 amf::write(buf, static_cast<double>(cn)); in sendCheckBW()
243 buf.appendByte(amf::NULL_AMF0); in sendCheckBW()
254 amf::write(buf, "_result"); in replyBWCheck()
255 amf::write(buf, txn); in replyBWCheck()
256 buf.appendByte(amf::NULL_AMF0); in replyBWCheck()
257 amf::write(buf, 0.0); in replyBWCheck()
270 amf::write(buf, "pause"); in sendPausePacket()
273 amf::write(buf, 0.0); in sendPausePacket()
274 buf.appendByte(amf::NULL_AMF0); in sendPausePacket()
277 amf::write(buf, flag); in sendPausePacket()
280 amf::write(buf, time * 1000.0); in sendPausePacket()
301 amf::write(buf, "play"); in sendPlayPacket()
304 amf::write(buf, 0.0); in sendPlayPacket()
305 buf.appendByte(amf::NULL_AMF0); in sendPlayPacket()
309 amf::write(buf, nc.playpath()); in sendPlayPacket()
318 amf::write(buf, seektime); in sendPlayPacket()
325 amf::write(buf, length); in sendPlayPacket()
336 amf::write(buf, "createStream"); in sendCreateStream()
337 amf::write(buf, static_cast<double>(cn)); in sendCreateStream()
338 buf.appendByte(amf::NULL_AMF0); in sendCreateStream()
348 amf::write(buf, "deleteStream"); in sendDeleteStream()
351 amf::write(buf, static_cast<double>(cn)); in sendDeleteStream()
352 buf.appendByte(amf::NULL_AMF0); in sendDeleteStream()
353 amf::write(buf, id); in sendDeleteStream()
364 amf::write(buf, "FCSubscribe"); in sendFCSubscribe()
367 amf::write(buf, static_cast<double>(cn)); in sendFCSubscribe()
368 buf.appendByte(amf::NULL_AMF0); in sendFCSubscribe()
369 amf::write(buf, subscribepath); in sendFCSubscribe()
554 std::string method = amf::readString(payload, end); in handleInvoke()
557 if (*payload != amf::NUMBER_AMF0) return false; in handleInvoke()
569 const double txn = amf::readNumber(payload, end); in handleInvoke()
584 if (*payload != amf::NULL_AMF0) return false; in handleInvoke()
590 if (*payload != amf::NUMBER_AMF0) return false; in handleInvoke()
592 double sid = amf::readNumber(payload, end); in handleInvoke()
612 const double txn = amf::readNumber(payload, end); in handleInvoke()
645 if (*payload != amf::NULL_AMF0) return false; in handleInvoke()
651 double latency = amf::readNumber(payload, end); in handleInvoke()
652 double bandwidth = amf::readNumber(payload, end); in handleInvoke()
681 if (*payload != amf::NULL_AMF0) return false; in handleInvoke()
687 if (*payload != amf::OBJECT_AMF0) { in handleInvoke()
699 while (payload < end && *payload != amf::OBJECT_END_AMF0) { in handleInvoke()
701 const std::string& n = amf::readString(payload, end); in handleInvoke()
709 if (*payload != amf::STRING_AMF0) { in handleInvoke()
716 const std::string& v = amf::readString(payload, end); in handleInvoke()
722 catch (const amf::AMFException& e) { in handleInvoke()