Module = {
|
onRuntimeInitialized: function() {
|
onWasmLoaded();
|
},
|
};
|
importScripts("libffmpeg.js");
|
|
var MediaName = null;
|
var IsStream = true;
|
var FileLen = -1;
|
|
var SocketObj; //WebSocket
|
var CPointer_Buffer = null;
|
var CPointer_Cap = 0;
|
|
function onWasmLoaded() {
|
DeliverVideo = Module.addFunction(function(Buf, BufLen, TimeStamp) {
|
var CPointer_Array = Module.HEAPU8.subarray(Buf, Buf + BufLen);
|
var message = {
|
command: "deliver_video",
|
sample: { time_stamp: TimeStamp, buf: new Uint8Array(CPointer_Array) },
|
};
|
self.postMessage(message, [message.sample.buf.buffer]);
|
}, "viii");
|
|
DeliverAudio = Module.addFunction(function(Buf, BufLen, TimeStamp) {
|
var CPointer_Array = Module.HEAPU8.subarray(Buf, Buf + BufLen);
|
var message = {
|
command: "deliver_audio",
|
sample: { time_stamp: TimeStamp, buf: new Uint8Array(CPointer_Array) },
|
};
|
self.postMessage(message, [message.sample.buf.buffer]);
|
}, "viii");
|
|
GetFileLength = Module.addFunction(function() {
|
if (FileLen == -1) {
|
var xhr = new XMLHttpRequest();
|
xhr.open("get", MediaName, false); //false: syn mode
|
xhr.send();
|
FileLen = xhr.getResponseHeader("Content-Length");
|
xhr.abort();
|
}
|
return FileLen;
|
}, "i");
|
|
ReadFile = Module.addFunction(function(Buf, Pos, Size) {
|
var xhr = new XMLHttpRequest();
|
xhr.open("get", MediaName, false);
|
xhr.responseType = "arraybuffer";
|
xhr.setRequestHeader("Range", "bytes=" + Pos + "-" + (Pos + Size - 1));
|
xhr.send();
|
Module.HEAPU8.set(new Uint8Array(xhr.response), Buf); //Uint8Array(xhr.response).length
|
xhr.abort();
|
}, "viii");
|
|
CreateVideo = Module.addFunction(function(Duration, Width, Height) {
|
self.postMessage({
|
command: "create_video",
|
param: { duration: Duration, width: Width, height: Height },
|
});
|
}, "viii");
|
|
CreateAudio = Module.addFunction(function(Channel, SampleRate) {
|
self.postMessage({
|
command: "create_audio",
|
param: { channel: Channel, sample_rate: SampleRate },
|
});
|
}, "vii");
|
|
Notify = Module.addFunction(function(Type, Value) {
|
//type 1:播放失败 2:文件播放到末尾
|
//console.log(Type+" "+Value);
|
if (Type == 1) self.postMessage({ command: "play_failed" });
|
else if (Type == 2) self.postMessage({ command: "play_end" });
|
}, "vii");
|
|
Module._Initialize(
|
DeliverVideo,
|
DeliverAudio,
|
GetFileLength,
|
ReadFile,
|
CreateVideo,
|
CreateAudio,
|
Notify
|
);
|
|
self.postMessage({ command: "initialized" });
|
}
|
|
function OnTimer() {
|
Module._Turbo0(null, 0);
|
}
|
|
function requestWebsocket(url, msg, cb_message) {
|
SocketObj = new WebSocket(url);
|
SocketObj.binaryType = "arraybuffer";
|
SocketObj.onopen = function(evt) {
|
SocketObj.send(msg);
|
};
|
SocketObj.onerror = function(evt) {
|
console.log("Ws connect error " + evt.data);
|
};
|
SocketObj.onmessage = cb_message;
|
SocketObj.onclose = function() {
|
console.log("Ws closed.");
|
};
|
}
|
|
function downloadFileByWebsocket(ws, payload) {
|
this.requestWebsocket(ws, payload, function(evt) {
|
if (evt.data.byteLength > CPointer_Cap) {
|
if (CPointer_Buffer != null) Module._free(CPointer_Buffer);
|
CPointer_Cap = evt.data.byteLength;
|
CPointer_Buffer = Module._malloc(CPointer_Cap);
|
}
|
|
var typedArray = new Uint8Array(evt.data);
|
Module.HEAPU8.set(typedArray, CPointer_Buffer);
|
//console.log("websocket data: "+typedArray.length);
|
Module._Turbo0(CPointer_Buffer, typedArray.length);
|
});
|
}
|
|
self.onmessage = function(evt) {
|
switch (evt.data.command) {
|
case "play": {
|
MediaName = evt.data.media_name;
|
IsStream = evt.data.other;
|
if (IsStream) {
|
downloadFileByWebsocket(MediaName, evt.data.payload);
|
}
|
|
Module._Play(null, !IsStream);
|
TimerID = setInterval(OnTimer, 5); //此值越小,渲染精度越高,且可增强'双线程缓冲平滑机制'可靠性
|
break;
|
}
|
case "pause": {
|
Module._Pause();
|
clearInterval(TimerID);
|
break;
|
}
|
case "resume": {
|
Module._Resume();
|
TimerID = setInterval(OnTimer, 5);
|
break;
|
}
|
case "stop": {
|
Module._Stop();
|
clearInterval(TimerID);
|
if (IsStream) {
|
SocketObj.close();
|
if (CPointer_Buffer != null) {
|
Module._free(CPointer_Buffer);
|
CPointer_Buffer = null;
|
CPointer_Cap = 0;
|
}
|
}
|
close(); //exit worker
|
break;
|
}
|
case "seek": {
|
Module._Seek(evt.data.pos);
|
break;
|
}
|
default:
|
return;
|
}
|
};
|
