OLD | NEW |
---|---|
1 // Copyright 2013 The Chromium Authors. All rights reserved. | 1 // Copyright 2013 The Chromium Authors. All rights reserved. |
2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
4 | 4 |
5 /** | 5 /** |
6 * A global object that gets used by the C++ interface. | 6 * A global object that gets used by the C++ interface. |
7 */ | 7 */ |
8 var media = (function() { | 8 var media = (function() { |
9 'use strict'; | 9 'use strict'; |
10 | 10 |
11 var manager_ = null; | 11 var manager_ = null; |
12 var eventPhases_ = {}; | |
scherkus (not reviewing)
2013/09/04 23:20:53
can we get some short comments describing what eac
Ty Overby
2013/09/05 21:01:02
Done.
| |
13 var eventTypes_ = {}; | |
14 | |
15 var cacheEntries_ = {}; | |
16 var cacheEntriesByKey_ = {}; | |
17 | |
18 var requestURLs_ = {}; | |
19 | |
20 var media = { | |
21 BAR_WIDTH: 200, | |
22 BAR_HEIGHT: 25 | |
23 }; | |
12 | 24 |
13 /** | 25 /** |
14 * Users of |media| must call initialize prior to calling other methods. | 26 * Users of |media| must call initialize prior to calling other methods. |
15 */ | 27 */ |
16 media.initialize = function(manager) { | 28 media.initialize = function(manager) { |
17 manager_ = manager; | 29 manager_ = manager; |
18 }; | 30 }; |
19 | 31 |
20 media.onReceiveEverything = function(everything) { | 32 media.onReceiveEverything = function(everything) { |
21 for (var key in everything.audio_streams) { | 33 for (var key in everything.audio_streams) { |
22 media.updateAudioStream(everything.audio_streams[key]); | 34 media.updateAudioStream(everything.audio_streams[key]); |
23 } | 35 } |
24 }; | 36 }; |
25 | 37 |
26 media.onNetUpdate = function(update) { | 38 media.onReceiveConstants = function(constants) { |
27 // TODO(tyoverby): Implement | 39 for (var key in constants.eventTypes) { |
40 var value = constants.eventTypes[key]; | |
41 eventTypes_[value] = key; | |
42 } | |
43 | |
44 for (var key in constants.eventPhases) { | |
45 var value = constants.eventPhases[key]; | |
46 eventPhases_[value] = key; | |
47 } | |
48 }; | |
49 | |
50 media.cacheForUrl = function(url) { | |
51 return cacheEntriesByKey_[url]; | |
52 }; | |
53 | |
54 media.onNetUpdate = function(updates) { | |
55 updates.forEach(function(update) { | |
56 var id = update.source.id; | |
57 if (!cacheEntries_[id]) | |
58 cacheEntries_[id] = new media.CacheEntry; | |
59 | |
60 switch (eventPhases_[update.phase] + '.' + eventTypes_[update.type]) { | |
61 case 'PHASE_BEGIN.DISK_CACHE_ENTRY_IMPL': | |
scherkus (not reviewing)
2013/09/04 23:20:53
case statements should be indented by 2 more space
Ty Overby
2013/09/05 21:01:02
Done.
| |
62 var key = update.params.key; | |
63 | |
64 // Merge this source with anything we already know about this key. | |
65 if (cacheEntriesByKey_[key]) { | |
66 cacheEntriesByKey_[key].merge(cacheEntries_[id]); | |
67 cacheEntries_[id] = cacheEntriesByKey_[key]; | |
68 } else { | |
69 cacheEntriesByKey_[key] = cacheEntries_[id]; | |
70 } | |
71 cacheEntriesByKey_[key].key = key; | |
72 break; | |
73 | |
74 case 'PHASE_BEGIN.SPARSE_READ': | |
75 cacheEntries_[id].readBytes(update.params.offset, | |
76 update.params.buff_len); | |
77 cacheEntries_[id].sparse = true; | |
78 break; | |
79 | |
80 case 'PHASE_BEGIN.SPARSE_WRITE': | |
81 cacheEntries_[id].writeBytes(update.params.offset, | |
82 update.params.buff_len); | |
83 cacheEntries_[id].sparse = true; | |
84 break; | |
85 | |
86 case 'PHASE_BEGIN.URL_REQUEST_START_JOB': | |
87 requestURLs_[update.source.id] = update.params.url; | |
88 break; | |
89 | |
90 case 'PHASE_NONE.HTTP_TRANSACTION_READ_RESPONSE_HEADERS': | |
91 // Record the total size of the file if this was a range request. | |
92 var range = /content-range:\s*bytes\s*\d+-\d+\/(\d+)/i.exec( | |
93 update.params.headers); | |
94 var key = requestURLs_[update.source.id]; | |
95 delete requestURLs_[update.source.id]; | |
96 if (range && key) { | |
97 if (!cacheEntriesByKey_[key]) { | |
98 cacheEntriesByKey_[key] = new media.CacheEntry; | |
99 cacheEntriesByKey_[key].key = key; | |
100 } | |
101 cacheEntriesByKey_[key].size = range[1]; | |
102 } | |
103 break; | |
104 } | |
105 }); | |
28 }; | 106 }; |
29 | 107 |
30 media.onRendererTerminated = function(renderId) { | 108 media.onRendererTerminated = function(renderId) { |
31 util.object.forEach(manager_.players_, function(playerInfo, id) { | 109 util.object.forEach(manager_.players_, function(playerInfo, id) { |
32 if (playerInfo.properties['render_id'] == renderId) { | 110 if (playerInfo.properties['render_id'] == renderId) { |
33 manager_.removePlayer(id); | 111 manager_.removePlayer(id); |
34 } | 112 } |
35 }); | 113 }); |
36 }; | 114 }; |
37 | 115 |
(...skipping 54 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
92 } | 170 } |
93 propertyCount += 1; | 171 propertyCount += 1; |
94 }); | 172 }); |
95 | 173 |
96 if (propertyCount === 0) { | 174 if (propertyCount === 0) { |
97 manager_.updatePlayerInfo( | 175 manager_.updatePlayerInfo( |
98 source, event.ticksMillis, 'EVENT', event.type); | 176 source, event.ticksMillis, 'EVENT', event.type); |
99 } | 177 } |
100 }; | 178 }; |
101 | 179 |
180 chrome.send('getEverything'); | |
102 return media; | 181 return media; |
103 }()); | 182 }()); |
OLD | NEW |