|
@ -78,13 +78,13 @@ var multi_caching = function(caches) { |
|
|
self.queues[key] = [{cb: cb, domain: process.domain}]; |
|
|
self.queues[key] = [{cb: cb, domain: process.domain}]; |
|
|
|
|
|
|
|
|
function fillCallbacks(err, data) { |
|
|
function fillCallbacks(err, data) { |
|
|
self.queues[key].forEach(function(task) { |
|
|
var waiting = self.queues[key]; |
|
|
process.nextTick(function() { |
|
|
delete self.queues[key]; |
|
|
|
|
|
|
|
|
|
|
|
waiting.forEach(function(task) { |
|
|
var taskDomain = task.domain || domain.create(); |
|
|
var taskDomain = task.domain || domain.create(); |
|
|
taskDomain.bind(task.cb)(err, data); |
|
|
taskDomain.bind(task.cb)(err, data); |
|
|
}); |
|
|
}); |
|
|
}); |
|
|
|
|
|
delete self.queues[key]; |
|
|
|
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
get_from_highest_priority_cache(key, function(err, result, index) { |
|
|
get_from_highest_priority_cache(key, function(err, result, index) { |
|
|