-
Notifications
You must be signed in to change notification settings - Fork 0
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
Showing
5 changed files
with
3,843 additions
and
1 deletion.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,126 @@ | ||
/// This code is licensed under the MIT License. See LICENSE for more details. | ||
|
||
/// Does the environment support web workers? If not, let's fake it. | ||
if (!Worker) { | ||
///NOTE: IE8 needs onmessage to be created first, IE9 cannot, IE7- do not care. | ||
/*@cc_on | ||
/// Is this IE8-? | ||
@if (@_jscript_version < 9) | ||
var onmessage = function () {}; | ||
@end | ||
@*/ | ||
|
||
/// If this were a regular function statement, IE9 would run it first and therefore make the Worker variable truthy because of hoisting. | ||
var Worker = function(script) { | ||
var global_var, | ||
return_object = {}; | ||
|
||
/// Determine the global variable (it's called "window" in browsers, "global" in Node.js). | ||
if (typeof window !== "undefined") { | ||
global_var = window; | ||
} else if (global) { | ||
global_var = global; | ||
} | ||
|
||
/// Is the environment is browser? | ||
/// If not, create a require() function, if it doesn't have one. | ||
if (global_var.document && !global_var.require) { | ||
global_var.require = function (path) { | ||
var script_tag = document.createElement("script"); | ||
script_tag.type ="text/javascript"; | ||
script_tag.src = path; | ||
document.getElementsByTagName('head')[0].appendChild(script_tag); | ||
}; | ||
} | ||
|
||
/// Dummy onmessage() function. | ||
return_object.onmessage = function () {}; | ||
|
||
/// This is the function that the main script calls to post a message to the "worker." | ||
return_object.postMessage = function (message) { | ||
/// Delay the call just in case the "worker" script has not had time to load. | ||
setTimeout(function () { | ||
/// Call the global onmessage() created by the "worker." | ||
///NOTE: Wrap the message in an object. | ||
global_var.onmessage({data: message}); | ||
}, 10); | ||
}; | ||
|
||
/// Create a global postMessage() function for the "worker" to call. | ||
global_var.postMessage = function (e) { | ||
///NOTE: Wrap the message in an object. | ||
///TODO: Add more properties. | ||
return_object.onmessage({data: e, type: "message"}); | ||
}; | ||
|
||
require(script); | ||
|
||
return return_object; | ||
}; | ||
} | ||
|
||
|
||
///NOTE: The "this" keyword is the global context ("window" variable) if loaded via a <script> tag | ||
/// or the function context if loaded as a module (e.g., in Node.js). | ||
this.LZMA = function (lzma_path) { | ||
var action_compress = 1, | ||
action_decompress = 2, | ||
action_progress = 3, | ||
|
||
callback_obj = {}, | ||
|
||
///NOTE: Node.js needs something like "./" or "../" at the beginning. | ||
lzma_worker = new Worker((typeof lzma_path === "undefined" ? "./lzma_worker.js" : lzma_path)); | ||
|
||
lzma_worker.onmessage = function (e) { | ||
if (e.data.action === action_progress) { | ||
if (callback_obj[e.data.callback_num] && typeof callback_obj[e.data.callback_num].on_progress === "function") { | ||
callback_obj[e.data.callback_num].on_progress(e.data.result); | ||
} | ||
} else { | ||
if (callback_obj[e.data.callback_num] && typeof callback_obj[e.data.callback_num].on_finish === "function") { | ||
callback_obj[e.data.callback_num].on_finish(e.data.result); | ||
|
||
/// Since the (de)compression is complete, the callbacks are no longer needed. | ||
delete callback_obj[e.data.callback_num]; | ||
} | ||
} | ||
}; | ||
|
||
/// Very simple error handling. | ||
lzma_worker.onerror = function(event) { | ||
throw new Error(event.message + " (" + event.filename + ":" + event.lineno + ")"); | ||
}; | ||
|
||
return (function () { | ||
|
||
function send_to_worker(action, data, mode, on_finish, on_progress) { | ||
var callback_num; | ||
|
||
do { | ||
callback_num = Math.floor(Math.random() * (10000000)); | ||
} while(typeof callback_obj[callback_num] !== "undefined"); | ||
|
||
callback_obj[callback_num] = { | ||
on_finish: on_finish, | ||
on_progress: on_progress | ||
}; | ||
|
||
lzma_worker.postMessage({ | ||
action: action, | ||
callback_num: callback_num, | ||
data: data, | ||
mode: mode | ||
}); | ||
} | ||
|
||
return { | ||
compress: function (string, mode, on_finish, on_progress) { | ||
send_to_worker(action_compress, String(string), mode, on_finish, on_progress); | ||
}, | ||
decompress: function (byte_arr, on_finish, on_progress) { | ||
send_to_worker(action_decompress, byte_arr, false, on_finish, on_progress); | ||
} | ||
}; | ||
}()); | ||
}; |
Oops, something went wrong.