Lines Matching defs:msg

85     sp<AMessage> msg = new AMessage(kWhatAddStream, id());
86 msg->setInt32("rtp-socket", rtpSocket);
87 msg->setInt32("rtcp-socket", rtcpSocket);
88 msg->setObject("session-desc", sessionDesc);
89 msg->setSize("index", index);
90 msg->setMessage("notify", notify);
91 msg->setInt32("injected", injected);
92 msg->post();
96 sp<AMessage> msg = new AMessage(kWhatRemoveStream, id());
97 msg->setInt32("rtp-socket", rtpSocket);
98 msg->setInt32("rtcp-socket", rtcpSocket);
99 msg->post();
147 void ARTPConnection::onMessageReceived(const sp<AMessage> &msg) {
148 switch (msg->what()) {
151 onAddStream(msg);
157 onRemoveStream(msg);
169 onInjectPacket(msg);
181 void ARTPConnection::onAddStream(const sp<AMessage> &msg) {
186 CHECK(msg->findInt32("rtp-socket", &s));
188 CHECK(msg->findInt32("rtcp-socket", &s));
192 CHECK(msg->findInt32("injected", &injected));
197 CHECK(msg->findObject("session-desc", &obj));
200 CHECK(msg->findSize("index", &info->mIndex));
201 CHECK(msg->findMessage("notify", &info->mNotifyMsg));
212 void ARTPConnection::onRemoveStream(const sp<AMessage> &msg) {
214 CHECK(msg->findInt32("rtp-socket", &rtpSocket));
215 CHECK(msg->findInt32("rtcp-socket", &rtcpSocket));
235 sp<AMessage> msg = new AMessage(kWhatPollStreams, id());
236 msg->post();
641 sp<AMessage> msg = new AMessage(kWhatInjectPacket, id());
642 msg->setInt32("index", index);
643 msg->setBuffer("buffer", buffer);
644 msg->post();
647 void ARTPConnection::onInjectPacket(const sp<AMessage> &msg) {
649 CHECK(msg->findInt32("index", &index));
652 CHECK(msg->findBuffer("buffer", &buffer));