Skip to content
This repository has been archived by the owner on Apr 12, 2024. It is now read-only.

Commit

Permalink
fix($timeout): clean deferreds immediately after callback exec/cancel
Browse files Browse the repository at this point in the history
Make sure $timeout callbacks are forgotten about immediately after
execution or cancellation.

Previously when passing invokeApply=false, the cleanup used $q and so
would be pending until the next $digest was triggered. This does not
make a large functional difference, but can be very visible when
looking at memory consumption of an app or debugging around the
$$asyncQueue - these callbacks can have a big retaining tree.
  • Loading branch information
andyrooger authored and vojtajina committed Aug 14, 2013
1 parent a5fb372 commit ac69392
Show file tree
Hide file tree
Showing 2 changed files with 55 additions and 5 deletions.
9 changes: 4 additions & 5 deletions src/ng/timeout.js
Original file line number Diff line number Diff line change
Expand Up @@ -45,17 +45,15 @@ function $TimeoutProvider() {
deferred.reject(e);
$exceptionHandler(e);
}
finally {
delete deferreds[promise.$$timeoutId];
}

if (!skipApply) $rootScope.$apply();
}, delay);

cleanup = function() {
delete deferreds[promise.$$timeoutId];
};

promise.$$timeoutId = timeoutId;
deferreds[timeoutId] = deferred;
promise.then(cleanup, cleanup);

return promise;
}
Expand All @@ -77,6 +75,7 @@ function $TimeoutProvider() {
timeout.cancel = function(promise) {
if (promise && promise.$$timeoutId in deferreds) {
deferreds[promise.$$timeoutId].reject('canceled');
delete deferreds[promise.$$timeoutId];
return $browser.defer.cancel(promise.$$timeoutId);
}
return false;
Expand Down
51 changes: 51 additions & 0 deletions test/ng/timeoutSpec.js
Original file line number Diff line number Diff line change
Expand Up @@ -68,6 +68,27 @@ describe('$timeout', function() {
}));


it('should forget references to deferreds when callback called even if skipApply is true',
inject(function($timeout, $browser) {
// $browser.defer.cancel is only called on cancel if the deferred object is still referenced
var cancelSpy = spyOn($browser.defer, 'cancel').andCallThrough();

var promise1 = $timeout(function() {}, 0, false);
var promise2 = $timeout(function() {}, 100, false);
expect(cancelSpy).not.toHaveBeenCalled();

$timeout.flush(0);

// Promise1 deferred object should already be removed from the list and not cancellable
$timeout.cancel(promise1);
expect(cancelSpy).not.toHaveBeenCalled();

// Promise2 deferred object should not have been called and should be cancellable
$timeout.cancel(promise2);
expect(cancelSpy).toHaveBeenCalled();
}));


describe('exception handling', function() {

beforeEach(module(function($exceptionHandlerProvider) {
Expand Down Expand Up @@ -106,6 +127,20 @@ describe('$timeout', function() {

expect(log).toEqual('error: Some Error');
}));


it('should forget references to relevant deferred even when exception is thrown',
inject(function($timeout, $browser) {
// $browser.defer.cancel is only called on cancel if the deferred object is still referenced
var cancelSpy = spyOn($browser.defer, 'cancel').andCallThrough();

var promise = $timeout(function() { throw "Test Error"; }, 0, false);
$timeout.flush();

expect(cancelSpy).not.toHaveBeenCalled();
$timeout.cancel(promise);
expect(cancelSpy).not.toHaveBeenCalled();
}));
});


Expand Down Expand Up @@ -147,5 +182,21 @@ describe('$timeout', function() {
it('should not throw a runtime exception when given an undefined promise', inject(function($timeout) {
expect($timeout.cancel()).toBe(false);
}));


it('should forget references to relevant deferred', inject(function($timeout, $browser) {
// $browser.defer.cancel is only called on cancel if the deferred object is still referenced
var cancelSpy = spyOn($browser.defer, 'cancel').andCallThrough();

var promise = $timeout(function() {}, 0, false);

expect(cancelSpy).not.toHaveBeenCalled();
$timeout.cancel(promise);
expect(cancelSpy).toHaveBeenCalledOnce();

// Promise deferred object should already be removed from the list and not cancellable again
$timeout.cancel(promise);
expect(cancelSpy).toHaveBeenCalledOnce();
}));
});
});

0 comments on commit ac69392

Please sign in to comment.