Changeset 88 for trunk/sources/applications/applestreamingclient/src/clientcontext.cpp

Timestamp:

08/22/10 20:05:34 (21 months ago)

Author:

shiretu

Message:

-- android related stuff

File:

• trunk/sources/applications/applestreamingclient/src/clientcontext.cpp (modified) (5 diffs)

trunk/sources/applications/applestreamingclient/src/clientcontext.cpp

@@ -44 +44 @@
         _currentItemIndex = 0;
         _optimalBw = 0;
+        _lastUsedBw = 0;
         _pSpeedComputer = NULL;
         _tsId = 0;
@@ -52 +53 @@
         _pStreamsManager = NULL;
         _lastWallClock = 0;
-        _lastStreamClock = 0;
         _avData.EnsureSize(_maxAVBufferSize * 3);
         INFO("Context created: %d (%p)", _id, this);
@@ -103 +103 @@
                 pResult = new ClientContext();
                 pResult->_applicationId = applicationId;
-                pResult->_pEventSink = BaseEventSink::GetInstance(masterProtocolType);
+                pResult->_pEventSink = BaseEventSink::GetInstance(masterProtocolType,
+                                pResult->_id);
                 contextId = pResult->_id;
                 _contexts[pResult->_id] = pResult;
@@ -579 +580 @@
         customParameters["itemUri"] = itemUri;
         customParameters["bw"] = bw;
+        //replace(keyUri, "http://www.mlb.com", "https://qa.mlb.com");
         return FetchURI(keyUri, "key", customParameters);
 }
 
 bool ClientContext::FetchTS(string uri, uint32_t bw, string key, uint64_t iv) {
+        //1. Prepare custom parameters
         Variant customParameters;
         if (key == "") {
@@ -602 +605 @@
         customParameters["iv"] = iv;
         customParameters["bw"] = bw;
+
+        //2. setup last bw used
+        if (_lastUsedBw == 0)
+                _lastUsedBw = bw;
+
+        if (_lastUsedBw != bw) {
+                if (_pEventSink->GetType() == EVENT_SYNC_VARIANT) {
+                        _avData.IgnoreAll();
+                }
+                if (_lastUsedBw < bw) {
+                        _pEventSink->SignalUpgradeBandwidth(_lastUsedBw, bw);
+                } else {
+                        _pEventSink->SignalDowngradeBandwidth(_lastUsedBw, bw);
+                }
+        }
+
+        _lastUsedBw = bw;
+
+
         return FetchURI(uri, "ts", customParameters);
 }