OLD | NEW |
1 // Copyright 2012 the V8 project authors. All rights reserved. | 1 // Copyright 2012 the V8 project authors. All rights reserved. |
2 // Redistribution and use in source and binary forms, with or without | 2 // Redistribution and use in source and binary forms, with or without |
3 // modification, are permitted provided that the following conditions are | 3 // modification, are permitted provided that the following conditions are |
4 // met: | 4 // met: |
5 // | 5 // |
6 // * Redistributions of source code must retain the above copyright | 6 // * Redistributions of source code must retain the above copyright |
7 // notice, this list of conditions and the following disclaimer. | 7 // notice, this list of conditions and the following disclaimer. |
8 // * Redistributions in binary form must reproduce the above | 8 // * Redistributions in binary form must reproduce the above |
9 // copyright notice, this list of conditions and the following | 9 // copyright notice, this list of conditions and the following |
10 // disclaimer in the documentation and/or other materials provided | 10 // disclaimer in the documentation and/or other materials provided |
(...skipping 16 matching lines...) Expand all Loading... |
27 | 27 |
28 "use strict"; | 28 "use strict"; |
29 | 29 |
30 var InternalObjectIsFrozen = $Object.isFrozen; | 30 var InternalObjectIsFrozen = $Object.isFrozen; |
31 var InternalObjectFreeze = $Object.freeze; | 31 var InternalObjectFreeze = $Object.freeze; |
32 | 32 |
33 var observationState = %GetObservationState(); | 33 var observationState = %GetObservationState(); |
34 if (IS_UNDEFINED(observationState.observerInfoMap)) { | 34 if (IS_UNDEFINED(observationState.observerInfoMap)) { |
35 observationState.observerInfoMap = %CreateObjectHashTable(); | 35 observationState.observerInfoMap = %CreateObjectHashTable(); |
36 observationState.objectInfoMap = %CreateObjectHashTable(); | 36 observationState.objectInfoMap = %CreateObjectHashTable(); |
| 37 observationState.activeObservers = new InternalArray; |
| 38 observationState.observerPriority = 0; |
37 } | 39 } |
38 | 40 |
39 function InternalObjectHashTable(table) { | 41 function InternalObjectHashTable(table) { |
40 this.table = table; | 42 this.table = table; |
41 } | 43 } |
42 | 44 |
43 InternalObjectHashTable.prototype = { | 45 InternalObjectHashTable.prototype = { |
44 get: function(key) { | 46 get: function(key) { |
45 return %ObjectHashTableGet(this.table, key); | 47 return %ObjectHashTableGet(this.table, key); |
46 }, | 48 }, |
(...skipping 11 matching lines...) Expand all Loading... |
58 | 60 |
59 function ObjectObserve(object, callback) { | 61 function ObjectObserve(object, callback) { |
60 if (!IS_SPEC_OBJECT(object)) | 62 if (!IS_SPEC_OBJECT(object)) |
61 throw MakeTypeError("observe_non_object", ["observe"]); | 63 throw MakeTypeError("observe_non_object", ["observe"]); |
62 if (!IS_SPEC_FUNCTION(callback)) | 64 if (!IS_SPEC_FUNCTION(callback)) |
63 throw MakeTypeError("observe_non_function", ["observe"]); | 65 throw MakeTypeError("observe_non_function", ["observe"]); |
64 if (InternalObjectIsFrozen(callback)) | 66 if (InternalObjectIsFrozen(callback)) |
65 throw MakeTypeError("observe_callback_frozen"); | 67 throw MakeTypeError("observe_callback_frozen"); |
66 | 68 |
67 if (!observerInfoMap.has(callback)) { | 69 if (!observerInfoMap.has(callback)) { |
68 // TODO: setup observerInfo.priority. | |
69 observerInfoMap.set(callback, { | 70 observerInfoMap.set(callback, { |
70 pendingChangeRecords: null | 71 pendingChangeRecords: null, |
| 72 priority: observationState.observerPriority++, |
71 }); | 73 }); |
72 } | 74 } |
73 | 75 |
74 var objectInfo = objectInfoMap.get(object); | 76 var objectInfo = objectInfoMap.get(object); |
75 if (IS_UNDEFINED(objectInfo)) { | 77 if (IS_UNDEFINED(objectInfo)) { |
76 // TODO: setup objectInfo.notifier | 78 // TODO: setup objectInfo.notifier |
77 objectInfo = { | 79 objectInfo = { |
78 changeObservers: new InternalArray(callback) | 80 changeObservers: new InternalArray(callback) |
79 }; | 81 }; |
80 objectInfoMap.set(object, objectInfo); | 82 objectInfoMap.set(object, objectInfo); |
(...skipping 21 matching lines...) Expand all Loading... |
102 if (index < 0) | 104 if (index < 0) |
103 return; | 105 return; |
104 | 106 |
105 changeObservers.splice(index, 1); | 107 changeObservers.splice(index, 1); |
106 } | 108 } |
107 | 109 |
108 function EnqueueChangeRecord(changeRecord, observers) { | 110 function EnqueueChangeRecord(changeRecord, observers) { |
109 for (var i = 0; i < observers.length; i++) { | 111 for (var i = 0; i < observers.length; i++) { |
110 var observer = observers[i]; | 112 var observer = observers[i]; |
111 var observerInfo = observerInfoMap.get(observer); | 113 var observerInfo = observerInfoMap.get(observer); |
112 | 114 observationState.activeObservers[observerInfo.priority] = observer; |
113 // TODO: "activate" the observer | 115 %SetObserverDeliveryPending(); |
114 | |
115 if (IS_NULL(observerInfo.pendingChangeRecords)) { | 116 if (IS_NULL(observerInfo.pendingChangeRecords)) { |
116 observerInfo.pendingChangeRecords = new InternalArray(changeRecord); | 117 observerInfo.pendingChangeRecords = new InternalArray(changeRecord); |
117 } else { | 118 } else { |
118 observerInfo.pendingChangeRecords.push(changeRecord); | 119 observerInfo.pendingChangeRecords.push(changeRecord); |
119 } | 120 } |
120 } | 121 } |
121 } | 122 } |
122 | 123 |
123 function NotifyChange(type, object, name, oldValue) { | 124 function NotifyChange(type, object, name, oldValue) { |
124 var objectInfo = objectInfoMap.get(object); | 125 var objectInfo = objectInfoMap.get(object); |
(...skipping 19 matching lines...) Expand all Loading... |
144 for (var prop in changeRecord) { | 145 for (var prop in changeRecord) { |
145 if (prop === 'object') | 146 if (prop === 'object') |
146 continue; | 147 continue; |
147 newRecord[prop] = changeRecord[prop]; | 148 newRecord[prop] = changeRecord[prop]; |
148 } | 149 } |
149 InternalObjectFreeze(newRecord); | 150 InternalObjectFreeze(newRecord); |
150 | 151 |
151 EnqueueChangeRecord(newRecord, objectInfo.changeObservers); | 152 EnqueueChangeRecord(newRecord, objectInfo.changeObservers); |
152 } | 153 } |
153 | 154 |
154 function ObjectDeliverChangeRecords(callback) { | 155 function DeliverChangeRecordsForObserver(observer) { |
155 if (!IS_SPEC_FUNCTION(callback)) | 156 var observerInfo = observerInfoMap.get(observer); |
156 throw MakeTypeError("observe_non_function", ["deliverChangeRecords"]); | |
157 | |
158 var observerInfo = observerInfoMap.get(callback); | |
159 if (IS_UNDEFINED(observerInfo)) | 157 if (IS_UNDEFINED(observerInfo)) |
160 return; | 158 return; |
161 | 159 |
162 var pendingChangeRecords = observerInfo.pendingChangeRecords; | 160 var pendingChangeRecords = observerInfo.pendingChangeRecords; |
163 if (IS_NULL(pendingChangeRecords)) | 161 if (IS_NULL(pendingChangeRecords)) |
164 return; | 162 return; |
165 | 163 |
166 observerInfo.pendingChangeRecords = null; | 164 observerInfo.pendingChangeRecords = null; |
167 var delivered = []; | 165 var delivered = []; |
168 %MoveArrayContents(pendingChangeRecords, delivered); | 166 %MoveArrayContents(pendingChangeRecords, delivered); |
169 try { | 167 try { |
170 %Call(void 0, delivered, callback); | 168 %Call(void 0, delivered, observer); |
171 } catch (ex) {} | 169 } catch (ex) {} |
172 } | 170 } |
173 | 171 |
| 172 function ObjectDeliverChangeRecords(callback) { |
| 173 if (!IS_SPEC_FUNCTION(callback)) |
| 174 throw MakeTypeError("observe_non_function", ["deliverChangeRecords"]); |
| 175 |
| 176 DeliverChangeRecordsForObserver(callback); |
| 177 } |
| 178 |
| 179 function DeliverChangeRecords() { |
| 180 while (observationState.activeObservers.length) { |
| 181 var activeObservers = observationState.activeObservers; |
| 182 observationState.activeObservers = new InternalArray; |
| 183 for (var i in activeObservers) { |
| 184 DeliverChangeRecordsForObserver(activeObservers[i]); |
| 185 } |
| 186 } |
| 187 } |
| 188 |
174 function SetupObjectObserve() { | 189 function SetupObjectObserve() { |
175 %CheckIsBootstrapping(); | 190 %CheckIsBootstrapping(); |
176 InstallFunctions($Object, DONT_ENUM, $Array( | 191 InstallFunctions($Object, DONT_ENUM, $Array( |
177 "deliverChangeRecords", ObjectDeliverChangeRecords, | 192 "deliverChangeRecords", ObjectDeliverChangeRecords, |
178 "notify", ObjectNotify, // TODO: Remove when getNotifier is implemented. | 193 "notify", ObjectNotify, // TODO: Remove when getNotifier is implemented. |
179 "observe", ObjectObserve, | 194 "observe", ObjectObserve, |
180 "unobserve", ObjectUnobserve | 195 "unobserve", ObjectUnobserve |
181 )); | 196 )); |
182 } | 197 } |
183 | 198 |
184 SetupObjectObserve(); | 199 SetupObjectObserve(); |
OLD | NEW |