Changeset 80 for trunk/sources/applications/applestreamingclient/src/protocols/rtmp/rtmpappprotocolhandler.cpp

Timestamp:

08/17/10 13:54:17 (21 months ago)

Author:

shiretu

Message:

-- work on applestreamingclient

File:

• trunk/sources/applications/applestreamingclient/src/protocols/rtmp/rtmpappprotocolhandler.cpp (modified) (3 diffs)

trunk/sources/applications/applestreamingclient/src/protocols/rtmp/rtmpappprotocolhandler.cpp

@@ -26 +26 @@
 #include "application/baseclientapplication.h"
 #include "eventsink/rtmpeventsink.h"
+#include "protocols/variant/messagestructure.h"
+#include "protocols/rtmp/messagefactories/genericmessagefactory.h"
 
 RTMPAppProtocolHandler::RTMPAppProtocolHandler(Variant &configuration)
@@ -45 +47 @@
         if (functionName == "setupStream") {
                 return ProcessSetupStream(pFrom, request);
+        } else if (functionName == "getBWInfo") {
+                return ProcessGetBWInfo(pFrom, request);
         } else {
                 WARN("Invalid function name");
@@ -88 +92 @@
         return pContext->StartProcessing();
 }
+
+bool RTMPAppProtocolHandler::ProcessGetBWInfo(BaseRTMPProtocol *pFrom,
+                Variant &request) {
+        uint32_t contextId = pFrom->GetCustomParameters()["contextId"];
+        Variant response;
+        Variant parameters;
+        parameters.PushToArray(Variant());
+        parameters.PushToArray(Variant());
+        if (contextId == 0) {
+                WARN("No context available yet");
+                response = GenericMessageFactory::GetInvokeResult(request, parameters);
+                return SendRTMPMessage(pFrom, response);
+        }
+        ClientContext *pContext = ClientContext::GetContext(contextId,
+                        GetApplication()->GetId(), pFrom->GetType());
+        if (pContext == NULL) {
+                FATAL("Unable to get context");
+                return false;
+        }
+
+
+        ASC_RES_BUILD_OK_INFO_BANDWIDTH(parameters[(uint32_t) 1],
+                        pContext->GetAvailableBandwidths(),
+                        pContext->GetDetectedBandwidth(),
+                        pContext->GetSelectedBandwidth(),
+                        pContext->GetBufferLevel(),
+                        pContext->GetMaxBufferLevel(),
+                        pContext->GetBufferLevelPercent());
+        response = GenericMessageFactory::GetInvokeResult(request, parameters);
+        return SendRTMPMessage(pFrom, response);
+}
+
 #endif /* HAS_PROTOCOL_RTMP */