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 48 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
59 var observerInfoMap = | 59 var observerInfoMap = |
60 new ObservationWeakMap(observationState.observerInfoMap); | 60 new ObservationWeakMap(observationState.observerInfoMap); |
61 var objectInfoMap = new ObservationWeakMap(observationState.objectInfoMap); | 61 var objectInfoMap = new ObservationWeakMap(observationState.objectInfoMap); |
62 var notifierTargetMap = | 62 var notifierTargetMap = |
63 new ObservationWeakMap(observationState.notifierTargetMap); | 63 new ObservationWeakMap(observationState.notifierTargetMap); |
64 | 64 |
65 function CreateObjectInfo(object) { | 65 function CreateObjectInfo(object) { |
66 var info = { | 66 var info = { |
67 changeObservers: new InternalArray, | 67 changeObservers: new InternalArray, |
68 notifier: null, | 68 notifier: null, |
| 69 inactiveObservers: new InternalArray, |
| 70 performing: { __proto__: null }, |
| 71 performingCount: 0, |
69 }; | 72 }; |
70 objectInfoMap.set(object, info); | 73 objectInfoMap.set(object, info); |
71 return info; | 74 return info; |
72 } | 75 } |
73 | 76 |
74 function ObjectObserve(object, callback) { | 77 var defaultAcceptTypes = { |
| 78 __proto__: null, |
| 79 'new': true, |
| 80 'updated': true, |
| 81 'deleted': true, |
| 82 'prototype': true, |
| 83 'reconfigured': true |
| 84 }; |
| 85 |
| 86 function CreateObserver(callback, accept) { |
| 87 var observer = { |
| 88 __proto__: null, |
| 89 callback: callback, |
| 90 accept: defaultAcceptTypes |
| 91 }; |
| 92 |
| 93 if (IS_UNDEFINED(accept)) |
| 94 return observer; |
| 95 |
| 96 var acceptMap = { __proto__: null }; |
| 97 for (var i = 0; i < accept.length; i++) |
| 98 acceptMap[accept[i]] = true; |
| 99 |
| 100 observer.accept = acceptMap; |
| 101 return observer; |
| 102 } |
| 103 |
| 104 function ObserverIsActive(observer, objectInfo) { |
| 105 if (objectInfo.performingCount === 0) |
| 106 return true; |
| 107 |
| 108 var performing = objectInfo.performing; |
| 109 for (var type in performing) { |
| 110 if (performing[type] > 0 && observer.accept[type]) |
| 111 return false; |
| 112 } |
| 113 |
| 114 return true; |
| 115 } |
| 116 |
| 117 function ObserverIsInactive(observer, objectInfo) { |
| 118 return !ObserverIsActive(observer, objectInfo); |
| 119 } |
| 120 |
| 121 function RemoveNullElements(from) { |
| 122 var i = 0; |
| 123 var j = 0; |
| 124 for (; i < from.length; i++) { |
| 125 if (from[i] === null) |
| 126 continue; |
| 127 if (j < i) |
| 128 from[j] = from[i]; |
| 129 j++; |
| 130 } |
| 131 |
| 132 if (i !== j) |
| 133 from.length = from.length - (i - j); |
| 134 } |
| 135 |
| 136 function RepartitionObservers(conditionFn, from, to, objectInfo) { |
| 137 var anyRemoved = false; |
| 138 for (var i = 0; i < from.length; i++) { |
| 139 var observer = from[i]; |
| 140 if (conditionFn(observer, objectInfo)) { |
| 141 anyRemoved = true; |
| 142 from[i] = null; |
| 143 to.push(observer); |
| 144 } |
| 145 } |
| 146 |
| 147 if (anyRemoved) |
| 148 RemoveNullElements(from); |
| 149 } |
| 150 |
| 151 function BeginPerformChange(objectInfo, type) { |
| 152 objectInfo.performing[type] = (objectInfo.performing[type] || 0) + 1; |
| 153 objectInfo.performingCount++; |
| 154 RepartitionObservers(ObserverIsInactive, |
| 155 objectInfo.changeObservers, |
| 156 objectInfo.inactiveObservers, |
| 157 objectInfo); |
| 158 } |
| 159 |
| 160 function EndPerformChange(objectInfo, type) { |
| 161 objectInfo.performing[type]--; |
| 162 objectInfo.performingCount--; |
| 163 RepartitionObservers(ObserverIsActive, |
| 164 objectInfo.inactiveObservers, |
| 165 objectInfo.changeObservers, |
| 166 objectInfo); |
| 167 } |
| 168 |
| 169 function ensureObserverRemoved(objectInfo, callback) { |
| 170 function remove(observerList) { |
| 171 for (var i = 0; i < observerList.length; i++) { |
| 172 if (observerList[i].callback === callback) { |
| 173 observerList.splice(i, 1); |
| 174 return true; |
| 175 } |
| 176 } |
| 177 return false; |
| 178 } |
| 179 |
| 180 if (!remove(objectInfo.changeObservers)) |
| 181 remove(objectInfo.inactiveObservers); |
| 182 } |
| 183 |
| 184 function AcceptArgIsValid(arg) { |
| 185 if (IS_UNDEFINED(arg)) |
| 186 return true; |
| 187 |
| 188 if (!IS_SPEC_OBJECT(arg) || |
| 189 !IS_NUMBER(arg.length) || |
| 190 arg.length < 0) |
| 191 return false; |
| 192 |
| 193 var length = arg.length; |
| 194 for (var i = 0; i < length; i++) { |
| 195 if (!IS_STRING(arg[i])) |
| 196 return false; |
| 197 } |
| 198 return true; |
| 199 } |
| 200 |
| 201 function ObjectObserve(object, callback, accept) { |
75 if (!IS_SPEC_OBJECT(object)) | 202 if (!IS_SPEC_OBJECT(object)) |
76 throw MakeTypeError("observe_non_object", ["observe"]); | 203 throw MakeTypeError("observe_non_object", ["observe"]); |
77 if (!IS_SPEC_FUNCTION(callback)) | 204 if (!IS_SPEC_FUNCTION(callback)) |
78 throw MakeTypeError("observe_non_function", ["observe"]); | 205 throw MakeTypeError("observe_non_function", ["observe"]); |
79 if (ObjectIsFrozen(callback)) | 206 if (ObjectIsFrozen(callback)) |
80 throw MakeTypeError("observe_callback_frozen"); | 207 throw MakeTypeError("observe_callback_frozen"); |
| 208 if (!AcceptArgIsValid(accept)) |
| 209 throw MakeTypeError("observe_accept_invalid"); |
81 | 210 |
82 if (!observerInfoMap.has(callback)) { | 211 if (!observerInfoMap.has(callback)) { |
83 observerInfoMap.set(callback, { | 212 observerInfoMap.set(callback, { |
84 pendingChangeRecords: null, | 213 pendingChangeRecords: null, |
85 priority: observationState.observerPriority++, | 214 priority: observationState.observerPriority++, |
86 }); | 215 }); |
87 } | 216 } |
88 | 217 |
89 var objectInfo = objectInfoMap.get(object); | 218 var objectInfo = objectInfoMap.get(object); |
90 if (IS_UNDEFINED(objectInfo)) objectInfo = CreateObjectInfo(object); | 219 if (IS_UNDEFINED(objectInfo)) objectInfo = CreateObjectInfo(object); |
91 %SetIsObserved(object, true); | 220 %SetIsObserved(object, true); |
92 | 221 |
93 var changeObservers = objectInfo.changeObservers; | 222 ensureObserverRemoved(objectInfo, callback); |
94 if (changeObservers.indexOf(callback) < 0) changeObservers.push(callback); | 223 |
| 224 var observer = CreateObserver(callback, accept); |
| 225 if (ObserverIsActive(observer, objectInfo)) |
| 226 objectInfo.changeObservers.push(observer); |
| 227 else |
| 228 objectInfo.inactiveObservers.push(observer); |
95 | 229 |
96 return object; | 230 return object; |
97 } | 231 } |
98 | 232 |
99 function ObjectUnobserve(object, callback) { | 233 function ObjectUnobserve(object, callback) { |
100 if (!IS_SPEC_OBJECT(object)) | 234 if (!IS_SPEC_OBJECT(object)) |
101 throw MakeTypeError("observe_non_object", ["unobserve"]); | 235 throw MakeTypeError("observe_non_object", ["unobserve"]); |
102 if (!IS_SPEC_FUNCTION(callback)) | 236 if (!IS_SPEC_FUNCTION(callback)) |
103 throw MakeTypeError("observe_non_function", ["unobserve"]); | 237 throw MakeTypeError("observe_non_function", ["unobserve"]); |
104 | 238 |
105 var objectInfo = objectInfoMap.get(object); | 239 var objectInfo = objectInfoMap.get(object); |
106 if (IS_UNDEFINED(objectInfo)) | 240 if (IS_UNDEFINED(objectInfo)) |
107 return object; | 241 return object; |
108 | 242 |
109 var changeObservers = objectInfo.changeObservers; | 243 ensureObserverRemoved(objectInfo, callback); |
110 var index = changeObservers.indexOf(callback); | 244 |
111 if (index >= 0) { | 245 if (objectInfo.changeObservers.length === 0 && |
112 changeObservers.splice(index, 1); | 246 objectInfo.inactiveObservers.length === 0) { |
113 if (changeObservers.length === 0) %SetIsObserved(object, false); | 247 %SetIsObserved(object, false); |
114 } | 248 } |
115 | 249 |
116 return object; | 250 return object; |
117 } | 251 } |
118 | 252 |
119 function EnqueueChangeRecord(changeRecord, observers) { | 253 function EnqueueChangeRecord(changeRecord, observers) { |
120 // TODO(rossberg): adjust once there is a story for symbols vs proxies. | 254 // TODO(rossberg): adjust once there is a story for symbols vs proxies. |
121 if (IS_SYMBOL(changeRecord.name)) return; | 255 if (IS_SYMBOL(changeRecord.name)) return; |
122 | 256 |
123 for (var i = 0; i < observers.length; i++) { | 257 for (var i = 0; i < observers.length; i++) { |
124 var observer = observers[i]; | 258 var observer = observers[i]; |
125 var observerInfo = observerInfoMap.get(observer); | 259 if (IS_UNDEFINED(observer.accept[changeRecord.type])) |
126 observationState.pendingObservers[observerInfo.priority] = observer; | 260 continue; |
| 261 |
| 262 var callback = observer.callback; |
| 263 var observerInfo = observerInfoMap.get(callback); |
| 264 observationState.pendingObservers[observerInfo.priority] = callback; |
127 %SetObserverDeliveryPending(); | 265 %SetObserverDeliveryPending(); |
128 if (IS_NULL(observerInfo.pendingChangeRecords)) { | 266 if (IS_NULL(observerInfo.pendingChangeRecords)) { |
129 observerInfo.pendingChangeRecords = new InternalArray(changeRecord); | 267 observerInfo.pendingChangeRecords = new InternalArray(changeRecord); |
130 } else { | 268 } else { |
131 observerInfo.pendingChangeRecords.push(changeRecord); | 269 observerInfo.pendingChangeRecords.push(changeRecord); |
132 } | 270 } |
133 } | 271 } |
134 } | 272 } |
135 | 273 |
136 function NotifyChange(type, object, name, oldValue) { | 274 function NotifyChange(type, object, name, oldValue) { |
137 var objectInfo = objectInfoMap.get(object); | 275 var objectInfo = objectInfoMap.get(object); |
| 276 if (objectInfo.changeObservers.length === 0) |
| 277 return; |
| 278 |
138 var changeRecord = (arguments.length < 4) ? | 279 var changeRecord = (arguments.length < 4) ? |
139 { type: type, object: object, name: name } : | 280 { type: type, object: object, name: name } : |
140 { type: type, object: object, name: name, oldValue: oldValue }; | 281 { type: type, object: object, name: name, oldValue: oldValue }; |
141 // TODO(rafaelw): This breaks spec-compliance. Re-enable when freezing isn't | 282 // TODO(rafaelw): This breaks spec-compliance. Re-enable when freezing isn't |
142 // slow. | 283 // slow. |
143 // ObjectFreeze(changeRecord); | 284 // ObjectFreeze(changeRecord); |
144 EnqueueChangeRecord(changeRecord, objectInfo.changeObservers); | 285 EnqueueChangeRecord(changeRecord, objectInfo.changeObservers); |
145 } | 286 } |
146 | 287 |
147 var notifierPrototype = {}; | 288 var notifierPrototype = {}; |
(...skipping 18 matching lines...) Expand all Loading... |
166 %DefineOrRedefineDataProperty(newRecord, prop, changeRecord[prop], | 307 %DefineOrRedefineDataProperty(newRecord, prop, changeRecord[prop], |
167 READ_ONLY + DONT_DELETE); | 308 READ_ONLY + DONT_DELETE); |
168 } | 309 } |
169 // TODO(rafaelw): This breaks spec-compliance. Re-enable when freezing isn't | 310 // TODO(rafaelw): This breaks spec-compliance. Re-enable when freezing isn't |
170 // slow. | 311 // slow. |
171 // ObjectFreeze(newRecord); | 312 // ObjectFreeze(newRecord); |
172 | 313 |
173 EnqueueChangeRecord(newRecord, objectInfo.changeObservers); | 314 EnqueueChangeRecord(newRecord, objectInfo.changeObservers); |
174 } | 315 } |
175 | 316 |
| 317 function ObjectNotifierPerformChange(changeType, changeFn, receiver) { |
| 318 if (!IS_SPEC_OBJECT(this)) |
| 319 throw MakeTypeError("called_on_non_object", ["performChange"]); |
| 320 |
| 321 var target = notifierTargetMap.get(this); |
| 322 if (IS_UNDEFINED(target)) |
| 323 throw MakeTypeError("observe_notify_non_notifier"); |
| 324 if (!IS_STRING(changeType)) |
| 325 throw MakeTypeError("observe_perform_non_string"); |
| 326 if (!IS_SPEC_FUNCTION(changeFn)) |
| 327 throw MakeTypeError("observe_perform_non_function"); |
| 328 |
| 329 if (IS_NULL_OR_UNDEFINED(receiver)) { |
| 330 receiver = %GetDefaultReceiver(changeFn) || receiver; |
| 331 } else if (!IS_SPEC_OBJECT(receiver) && %IsClassicModeFunction(changeFn)) { |
| 332 receiver = ToObject(receiver); |
| 333 } |
| 334 |
| 335 var objectInfo = objectInfoMap.get(target); |
| 336 if (IS_UNDEFINED(objectInfo)) |
| 337 return; |
| 338 |
| 339 BeginPerformChange(objectInfo, changeType); |
| 340 try { |
| 341 %_CallFunction(receiver, changeFn); |
| 342 } finally { |
| 343 EndPerformChange(objectInfo, changeType); |
| 344 } |
| 345 } |
| 346 |
176 function ObjectGetNotifier(object) { | 347 function ObjectGetNotifier(object) { |
177 if (!IS_SPEC_OBJECT(object)) | 348 if (!IS_SPEC_OBJECT(object)) |
178 throw MakeTypeError("observe_non_object", ["getNotifier"]); | 349 throw MakeTypeError("observe_non_object", ["getNotifier"]); |
179 | 350 |
180 if (ObjectIsFrozen(object)) return null; | 351 if (ObjectIsFrozen(object)) return null; |
181 | 352 |
182 var objectInfo = objectInfoMap.get(object); | 353 var objectInfo = objectInfoMap.get(object); |
183 if (IS_UNDEFINED(objectInfo)) objectInfo = CreateObjectInfo(object); | 354 if (IS_UNDEFINED(objectInfo)) objectInfo = CreateObjectInfo(object); |
184 | 355 |
185 if (IS_NULL(objectInfo.notifier)) { | 356 if (IS_NULL(objectInfo.notifier)) { |
(...skipping 42 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
228 | 399 |
229 function SetupObjectObserve() { | 400 function SetupObjectObserve() { |
230 %CheckIsBootstrapping(); | 401 %CheckIsBootstrapping(); |
231 InstallFunctions($Object, DONT_ENUM, $Array( | 402 InstallFunctions($Object, DONT_ENUM, $Array( |
232 "deliverChangeRecords", ObjectDeliverChangeRecords, | 403 "deliverChangeRecords", ObjectDeliverChangeRecords, |
233 "getNotifier", ObjectGetNotifier, | 404 "getNotifier", ObjectGetNotifier, |
234 "observe", ObjectObserve, | 405 "observe", ObjectObserve, |
235 "unobserve", ObjectUnobserve | 406 "unobserve", ObjectUnobserve |
236 )); | 407 )); |
237 InstallFunctions(notifierPrototype, DONT_ENUM, $Array( | 408 InstallFunctions(notifierPrototype, DONT_ENUM, $Array( |
238 "notify", ObjectNotifierNotify | 409 "notify", ObjectNotifierNotify, |
| 410 "performChange", ObjectNotifierPerformChange |
239 )); | 411 )); |
240 } | 412 } |
241 | 413 |
242 SetupObjectObserve(); | 414 SetupObjectObserve(); |
OLD | NEW |