wine/gecko
0
0
Fork 0
mirror of https://gitlab.winehq.org/wine/wine-gecko.git synced 2024-09-13 09:24:08 -07:00
Code Issues Packages Projects Releases Wiki Activity

Bug 784717 - Asynchronous directory walk worker code. r=froydnj

Browse Source
This commit is contained in:
David Rajchenbach-Teller 2012-09-26 21:37:23 -04:00
parent d204c36ff3
commit 600e5f8970
1 changed files with 53 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

58
toolkit/components/osfile/osfile_async_worker.js
View File

@ -151,6 +151,18 @@ if (this.Components) {
return f.call(file);
};
let OpenedDirectoryIterators = new ResourceTracker();
let withDir = function withDir(fd, f) {
let file = OpenedDirectoryIterators.get(fd);
if (file == null) {
throw new Error("Could not find Directory");
}
if (!(file instanceof File.DirectoryIterator)) {
throw new Error("file is not a directory iterator " + file.__proto__.toSource());
}
return f.call(file);
};
let Type = exports.OS.Shared.Type;
let File = exports.OS.File;
@ -192,6 +204,10 @@ if (this.Components) {
let file = File.open(Type.path.fromMsg(path), mode, options);
return OpenedFiles.add(file);
},
new_DirectoryIterator: function new_DirectoryIterator(path, options) {
let iterator = new File.DirectoryIterator(Type.path.fromMsg(path), options);
return OpenedDirectoryIterators.add(iterator);
},
// Methods of OS.File
File_prototype_close: function close(fd) {
return withFile(fd,
@ -227,19 +243,51 @@ if (this.Components) {
return withFile(fd,
function do_setPosition() {
return this.setPosition(pos, whence);
}
);
});
},
File_prototype_getPosition: function getPosition(fd) {
return withFile(fd,
function do_getPosition() {
return this.getPosition();
}
);
});
},
// Methods of OS.File.DirectoryIterator
DirectoryIterator_prototype_next: function next(dir) {
return withDir(dir,
function do_next() {
try {
return File.DirectoryIterator.Entry.toMsg(this.next());
} catch (x) {
if (x == StopIteration) {
OpenedDirectoryIterators.remove(dir);
}
throw x;
}
});
},
DirectoryIterator_prototype_nextBatch: function nextBatch(dir, size) {
return withDir(dir,
function do_nextBatch() {
let result;
try {
result = this.nextBatch(size);
} catch (x) {
OpenedDirectoryIterators.remove(dir);
throw x;
}
return result.map(File.DirectoryIterator.Entry.toMsg);
});
},
DirectoryIterator_prototype_close: function close(dir) {
return withDir(dir,
function do_close() {
this.close();
OpenedDirectoryIterators.remove(dir);
});
}
};
} catch(ex) {
dump("WORKER ERROR DURING SETUP " + ex + "\n");
dump("WORKER ERROR DETAIL " + ex.stack);
dump("WORKER ERROR DETAIL " + ex.stack + "\n");
}
})(this);