// old targetpage == page and moved into start method
-function xynt_streaming(win, console, gst, from, cookiename, sess, sandbox, page, cmdproc)
+//
+// CLASS transport_xhr
+//
+function transport_xhr(doc, xynt_streaming, page)
+{
+ this.doc = doc;
+ this.xynt_streaming = xynt_streaming;
+ this.xhr = createXMLHttpRequest();
+ this.xhr.open('GET', page);
+
+ var self = this;
+ this.xhr.onreadystatechange = function () { self.xhr_cb(); };
+ this.xhr.send(null);
+
+ this.stopped = false;
+}
+
+transport_xhr.prototype = {
+ doc: null,
+ xynt_streaming: "ready",
+ xhr: null,
+ stopped: true,
+
+ ctx_old: "",
+ ctx_old_len: 0,
+ ctx_new: null,
+
+ // script_clean: 0,
+
+ destroy: function () { /* public */
+ if (this.xhr != null) {
+ this.xhr_abort();
+ }
+ delete this.xhr;
+ },
+
+ xhr_cb: function () {
+ var ret;
+
+ if (this.xhr.readyState == 4) {
+ // console.log("SS: "+safestatus(xhr));
+
+ // NOTE: delay management later
+ // try {
+ // if ((ret = safestatus(this.xhr)) == 200) {
+ // this.delay = 0;
+ // // console.log("del a null "+this.delayed);
+ // } else if (ret != -1) {
+ // this.delay = 5000;
+ // this.hbit('X');
+ // // alert('There was a problem with the request.' + ret);
+ // }
+ // } catch(b) {};
+
+ // this.delayed = null;
+ this.stopped = true;
+ }
+ },
+
+ xhr_abort: function() {
+ if (this.xhr != null) {
+ this.xhr.abort();
+ }
+ },
+
+ xstr_is_init: function () { /* public */
+ try {
+ if (this.xhr.responseText != null) {
+ this.ctx_new = this.xhr.responseText;
+ }
+ }
+ catch (e) {
+ }
+
+ return (this.ctx_new != null);
+ },
+
+ /* only after a successfull is_initialized call */
+ xstr_is_ready: function () { /* public */
+ return (this.xynt_streaming == "ready");
+ },
+
+ xstr_set: function () { /* public */
+ // already set
+ },
+
+ ctx_new_is_set: function () { /* public */
+ return (this.ctx_new != null);
+ },
+
+ ctx_new_curlen_get: function () { /* public */
+ return (this.ctx_new.length);
+ },
+
+ ctx_new_getchar: function(idx) { /* public */
+ return (this.ctx_new[idx]);
+ },
+
+ ctx_old_len_is_set: function () { /* public */
+ return (true);
+ },
+
+ ctx_old_len_get: function () { /* public */
+ return (this.ctx_old_len);
+ },
+
+ ctx_old_len_set: function (len) { /* public */
+ this.ctx_old_len = len;
+ },
+
+ ctx_old_len_add: function (len) { /* public */
+ this.ctx_old_len += len;
+ },
+
+ new_part: function () { /* public */
+ return (this.ctx_new.substr(this.ctx_old_len));
+ },
+
+ scrcls_set: function (step) { /* public */
+ // this.script_clean = step;
+ },
+
+ postproc: function () {
+ if (this.stopped && !this.xstr_is_ready()) {
+ this.xynt_streaming.reload();
+ }
+ }
+}
+
+//
+// CLASS transport_htmlfile
+//
+function transport_htmlfile(doc, xynt_streaming, page)
+{
+ this.doc = doc;
+ this.xynt_streaming = xynt_streaming;
+ this.transfdoc = new ActiveXObject("htmlfile");
+ this.transfdoc.open();
+ this.transfdoc.write("<html><body><iframe id='iframe'></iframe></body></html>");
+ this.transfdoc.close();
+
+ this.ifra = this.transfdoc.getElementById("iframe");
+ this.ifra.contentWindow.location.href = page;
+ this.stopped = false;
+}
+
+transport_htmlfile.prototype = {
+ doc: null,
+ xynt_streaming: null,
+ stopped: true,
+ ifra: null,
+ tradoc: null,
+
+ destroy: function () { /* public */
+ if (this.ifra != null) {
+ // this.doc.body.removeChild(this.ifra);
+ // delete this.ifra;
+ this.ifra = null;
+ }
+
+ if (this.transfdoc) {
+ delete this.transfdoc;
+ this.transfdoc = null;
+ }
+ },
+
+ xstr_is_init: function () { /* public */
+ return (typeof(this.ifra.contentWindow.xynt_streaming) != 'undefined');
+ },
+
+ /* only after a successfull is_initialized call */
+ xstr_is_ready: function () { /* public */
+ return (this.ifra.contentWindow.xynt_streaming == "ready");
+ },
+
+ /* only after a successfull is_initialized call */
+ xstr_set: function () { /* public */
+ if (this.ifra.contentWindow.xynt_streaming == "ready") {
+ this.ifra.contentWindow.xynt_streaming = this.xynt_streaming;
+ return (true);
+ }
+ else if (this.ifra.contentWindow.xynt_streaming == this.xynt_streaming) {
+ return (true);
+ }
+ else {
+ return (false);
+ }
+ },
+
+ ctx_new_is_set: function () { /* public */
+ return (typeof(this.ifra.contentWindow.ctx_new) != 'undefined');
+ },
+
+ ctx_new_curlen_get: function () { /* public */
+ return (this.ifra.contentWindow.ctx_new.length);
+ },
+
+ ctx_new_getchar: function(idx) { /* public */
+ return (this.ifra.contentWindow.ctx_new.charAt(idx));
+
+ },
+
+ ctx_old_len_is_set: function () { /* public */
+ return (typeof(this.ifra.contentWindow.ctx_old_len) != 'undefined');
+ },
+
+ ctx_old_len_get: function () { /* public */
+ return (this.ifra.contentWindow.ctx_old_len);
+ },
+
+ ctx_old_len_set: function (len) { /* public */
+ this.ifra.contentWindow.ctx_old_len = len;
+ },
+
+ ctx_old_len_add: function (len) { /* public */
+ this.ifra.contentWindow.ctx_old_len += len;
+ },
+
+ new_part: function () { /* public */
+ return (this.ifra.contentWindow.ctx_new.substr(this.ifra.contentWindow.ctx_old_len));
+ },
+
+ scrcls_set: function (step) { /* public */
+ this.ifra.contentWindow.script_clean = step;
+ },
+
+ postproc: function () { /* public */
+ if (this.stopped && !this.xstr_is_ready()) {
+ this.xynt_streaming.reload();
+ }
+ }
+}
+
+
+
+//
+// CLASS transport_iframe
+//
+function transport_iframe(doc, xynt_streaming, page)
+{
+ this.doc = doc;
+ this.xynt_streaming = xynt_streaming;
+ this.ifra = doc.createElement("iframe");
+ this.ifra.style.visibility = "hidden";
+ doc.body.appendChild(this.ifra);
+ this.ifra.contentWindow.location.href = page;
+ this.stopped = false;
+}
+
+transport_iframe.prototype = {
+ doc: null,
+ xynt_streaming: null,
+ stopped: true,
+ ifra: null,
+
+ destroy: function () { /* public */
+ try {
+ if (this.ifra != null) {
+ // NOTE: on Opera this remove child crash js if called from
+ // inside of the iframe, on IE on Windows without
+ // it stream abort fails.
+ // the problem is fixed setting into the iframe's onload
+ // function the stopped attribute to true and delegate
+ // postproc() fired by xynt_streaming watchdog()
+ this.doc.body.removeChild(this.ifra);
+ delete this.ifra;
+ this.ifra = null;
+ }
+ } catch (b) {
+ alert("destroy exception catched");
+ }
+ },
+
+ xstr_is_init: function () { /* public */
+ return (typeof(this.ifra.contentWindow.xynt_streaming) != 'undefined');
+ },
+
+ /* only after a successfull is_initialized call */
+ xstr_is_ready: function () { /* public */
+ return (this.ifra.contentWindow.xynt_streaming == "ready");
+ },
+
+ /* only after a successfull is_initialized call */
+ xstr_set: function () { /* public */
+ if (this.ifra.contentWindow.xynt_streaming == "ready") {
+ this.ifra.contentWindow.xynt_streaming = this.xynt_streaming;
+ return (true);
+ }
+ else if (this.ifra.contentWindow.xynt_streaming == this.xynt_streaming) {
+ return (true);
+ }
+ else {
+ return (false);
+ }
+ },
+
+
+ /* only after a successfull is_ready call to be sure the accessibility of the var */
+ xstr_set_old: function (xynt_streaming) { /* public */
+ this.ifra.contentWindow.xynt_streaming = xynt_streaming;
+ },
+
+ ctx_new_is_set: function () { /* public */
+ return (typeof(this.ifra.contentWindow.ctx_new) != 'undefined');
+ },
+
+ ctx_new_curlen_get: function () { /* public */
+ return (this.ifra.contentWindow.ctx_new.length);
+ },
+
+ ctx_new_getchar: function(idx) { /* public */
+ return (this.ifra.contentWindow.ctx_new.charAt(idx));
+ },
+
+ ctx_old_len_is_set: function () { /* public */
+ return (typeof(this.ifra.contentWindow.ctx_old_len) != 'undefined');
+ },
+
+ ctx_old_len_get: function () { /* public */
+ return (this.ifra.contentWindow.ctx_old_len);
+ },
+
+ ctx_old_len_set: function (len) { /* public */
+ this.ifra.contentWindow.ctx_old_len = len;
+ },
+
+ ctx_old_len_add: function (len) { /* public */
+ this.ifra.contentWindow.ctx_old_len += len;
+ },
+
+ new_part: function () { /* public */
+ return (this.ifra.contentWindow.ctx_new.substr(this.ifra.contentWindow.ctx_old_len));
+ },
+
+ scrcls_set: function (step) { /* public */
+ this.ifra.contentWindow.script_clean = step;
+ },
+
+ postproc: function () { /* public */
+ if (this.stopped && !this.xstr_is_ready()) {
+ this.xynt_streaming.reload();
+ }
+ }
+}
+
+function xynt_streaming(win, transp_type, console, gst, from, cookiename, sess, sandbox, page, cmdproc)
{
this.win = win;
+ this.transp_type = transp_type;
this.console = console;
this.gst = gst;
this.from = from;
this.page = page;
this.cmdproc = cmdproc;
// this.cmdproc = function(com){/* console.log("COM: "+com); */ eval(com);}
-
this.doc = win.document;
this.keepalive_old = -1;
this.keepalive_new = -1;
xynt_streaming.prototype = {
win: null,
+ transp_type: null,
+ transp: null,
console: null,
gst: null,
from: null,
page: null,
cmdproc: null,
+ start_time: 0,
+ restart_wait: 5000, // wait restart_wait millisec before begin to check if restart is needed
+
doc: null,
- ifra: null,
cookiepath: "/brisk/",
watchdog_hdl: null,
- hbit: null,
+ hbit: function () {},
keepalive_old: -1,
keepalive_new: -1,
keepalives_equal: 0,
/* NOTE: right watch_timeout value to 100, for devel reasons use 1000 or more */
- // FIXME watchdog_timeout: 200,
- /* restart after 3 * 40 * 100 millisec if server ping is missing => 12secs */
- keepalives_eq_max: 3,
+ /* restart after 4 * 40 * 100 millisec if server ping is missing => 16secs */
+ keepalives_eq_max: 4,
watchdog_checktm: 40,
watchdog_timeout: 100,
watchdog_ct: 0,
stream: "",
the_end: false,
+ w_stat_old: "",
+ s_stat_old: "",
+
start: function() { /* public */
if (this.the_end)
return;
// alert("start");
this.log("xynt_streaming:start restart: "+this.restart_n);
this.keepalives_equal = 0;
- this.ifra = this.doc.createElement("iframe");
- this.ifra.style.visibility = "hidden";
- this.doc.body.appendChild(this.ifra);
+
+ // page arrangement
this.page = url_complete(this.win.location.href, this.page);
// stat, subst, this.gst.st
this.page = url_append_args(this.page, "sess", this.sess, "stat", stat, "subst", subst, "step", this.gst.st, "from", this.from);
- // alert(this.page);
this.log(this.page);
- // this.log(this.ifra);
- this.ifra.contentWindow.location.href = this.page;
- // this.ifra.src = this.page;
+ // transport instantiation
+ if (this.transp_type == "xhr") {
+ this.page = url_append_args(this.page, "transp", "xhr");
+ this.transp = new transport_xhr(this.doc, this, this.page);
+ }
+ else if (this.transp_type == "iframe") {
+ this.page = url_append_args(this.page, "transp", "iframe");
+ this.transp = new transport_iframe(this.doc, this, this.page);
+ }
+ else if (this.transp_type == "htmlfile") {
+ this.page = url_append_args(this.page, "transp", "htmlfile");
+ this.transp = new transport_htmlfile(this.doc, this, this.page);
+ }
+ else
+ return;
+
+ // watchdog setting
this.watchdog_ct = 0;
if (!this.the_end) {
this.watchdog_hdl = setTimeout(function(obj) { obj.log("tout1"); obj.watchdog(); }, this.watchdog_timeout, this);
}
+
+ var date = new Date();
+ this.start_time = date.getTime();
},
stop: function() {
this.hbit = hbit;
},
+ hbit_status: function () {
+ if (this.watchdog_hdl)
+ w_stat = "g";
+ else
+ w_stat = "r";
+
+ if (this.transp.ctx_new_is_set() &&
+ this.transp.ctx_new_curlen_get() > 0) {
+ if (this.keepalives_equal == 0) {
+ s_stat = "g";
+ }
+ else if (this.keepalives_equal < this.keepalives_eq_max) {
+ s_stat = "y";
+ }
+ else {
+ s_stat = "r";
+ }
+ }
+ else {
+ s_stat = "r";
+ }
+
+ if (this.s_stat_old != s_stat ||
+ this.w_stat_old != w_stat)
+ this.hbit(s_stat, w_stat);
+ this.s_stat_old = s_stat;
+ this.w_stat_old = w_stat;
+ },
+
watchdog: function () {
// alert("watchdog");
var i, again;
var comm_newpart, comm_len, comm_arr;
var ctx_new_len;
+ this.watchdog_hdl = null;
+
+ this.hbit_status();
if (this.sandbox != null) {
// from old: var zug = "POLL sess = "+sess+" stat = "+stat+" subst = "+subst+" step = "+this.gst.st+" step_loc = "+this.gst.st_loc+" step_loc_new = "+this.gst.st_loc_new+" STOP: "+this.stopped;
var zug = "WATCHDOG sess = ["+this.sess+"] step = "+this.gst.st+" step_loc = "+this.gst.st_loc+" step_loc_new = "+this.gst.st_loc_new;
if (!this.watchable) {
do {
try{
- if (typeof(this.ifra.contentWindow.xynt_streaming) == 'undefined')
+ // if (typeof(this.ifra.contentWindow.xynt_streaming) == 'undefined')
+ if (!this.transp.xstr_is_init()) {
+ this.log("hs::watchdog: xstr_is_init = false");
break;
+ }
}
catch(b) {
+ this.log("hs::watchdog: exception");
break;
}
on IE7 the the window frame scope is cleaned after the href is set, so we wait
for a well know variable value before assign this object value to it (OO is a passion)
*/
- if (this.ifra.contentWindow.xynt_streaming == "ready") {
- this.ifra.contentWindow.xynt_streaming = this;
+ // if (this.ifra.contentWindow.xynt_streaming == "ready") {
+ if (this.transp.xstr_set()) {
+ // this.ifra.contentWindow.xynt_streaming = this;
this.watchable = true;
this.watchdog_ct = 0;
this.log("hs::watchdog: watchable = yes");
}
if ( (this.watchdog_ct % this.watchdog_checktm) == 0) {
this.log("hs::watchdog: this.keepalive_old: "+this.keepalive_old+" this.keepalive_new: "+this.keepalive_new);
+
+ // alert("qui "+this.transp.ctx_new_curlen_get()+" "+this.transp.ctx_old_len_get();
if (this.keepalive_old == this.keepalive_new) {
this.keepalives_equal++;
}
this.keepalives_equal = 0;
}
- if (this.keepalives_equal > this.keepalives_eq_max) {
+ if (this.keepalives_equal >= this.keepalives_eq_max) {
this.log("hs::watchdog: MAX ACHIEVED "+this.keepalives_equal);
this.reload();
// alert("watchdog return reload");
// CHECK: maybe again here isn't needed
again = 0;
try {
- if (typeof(this.ifra.contentWindow.ctx_new) == 'undefined' ||
- typeof(this.ifra.contentWindow.ctx_old_len) == 'undefined')
+ /* if (typeof(this.ifra.contentWindow.ctx_new) == 'undefined' ||
+ typeof(this.ifra.contentWindow.ctx_old_len) == 'undefined') */
+ if (!this.transp.ctx_new_is_set() || !this.transp.ctx_old_len_is_set())
break;
}
catch(b) {
break;
}
-
- ctx_new_len = this.ifra.contentWindow.ctx_new.length;
- if (ctx_new_len <= this.ifra.contentWindow.ctx_old_len) {
+ // ctx_new_len = this.ifra.contentWindow.ctx_new.length;
+ ctx_new_len = this.transp.ctx_new_curlen_get();
+ this.log("new_len: "+ ctx_new_len);
+ // if (ctx_new_len <= this.ifra.contentWindow.ctx_old_len) {
+ if (ctx_new_len <= this.transp.ctx_old_len_get()) {
break;
}
- this.log("new: "+ ctx_new_len + " old: "+this.ifra.contentWindow.ctx_old_len);
+ this.log("new: "+ ctx_new_len + " old: "+this.transp.ctx_old_len_get());
this.keepalive_new++;
// alert("pre-loop 1");
- for (i = this.ifra.contentWindow.ctx_old_len ; i < ctx_new_len ; i++) {
- if (this.ifra.contentWindow.ctx_new.charAt(i) != '_') {
+ for (i = this.transp.ctx_old_len_get() ; i < ctx_new_len ; i++) {
+ // alert("ctx_new_getchar: "+this.transp.ctx_new_getchar(i));
+
+ if (this.transp.ctx_new_getchar(i) != '_') {
// this.log("ctx_new.char(i) != '_' ["+this.ifra.contentWindow.ctx_new.charAt(i)+"]");
break;
}
// this.log("ctx_new.charAt(i) == '_'");
// }
}
- this.ifra.contentWindow.ctx_old_len = i;
+ // this.ifra.contentWindow.ctx_old_len = i;
+ this.transp.ctx_old_len_set(i);
if (i == ctx_new_len) {
this.log("old_len == i");
break;
}
// alert("do--while middle ["+this.ifra.contentWindow.ctx_old_len+"]");
- comm_newpart = this.ifra.contentWindow.ctx_new.substr(this.ifra.contentWindow.ctx_old_len);
+ comm_newpart = this.transp.new_part();
this.log("COM_NEWPART: ["+comm_newpart+"]");
comm_len = 0;
comm_arr = comm_newpart.match(this.comm_match);
}
again = 1;
}
- this.ifra.contentWindow.ctx_old_len += comm_len;
- this.ifra.contentWindow.script_clean = this.gst.st;
+ // this.ifra.contentWindow.ctx_old_len += comm_len;
+ this.transp.ctx_old_len_add(comm_len);
+ // this.ifra.contentWindow.script_clean = this.gst.st;
+ this.transp.scrcls_set(this.gst.st);
// alert("do--while end ["+again+"]");
} while (again);
} while (again);
this.watchdog_ct++;
if (!this.the_end) {
+ var date = new Date();
+ if (date.getTime() > (this.start_time + this.restart_wait)) {
+ this.transp.postproc();
+ }
this.watchdog_hdl = setTimeout(function(obj) { /* obj.log("tout2"); */ obj.watchdog(); }, this.watchdog_timeout, this);
+ this.hbit_status();
}
// alert("watchdog return normal");
this.restart_n++;
this.log("hs::reload");
this.watchable = false;
- if (this.ifra != null) {
- this.doc.body.removeChild(this.ifra);
- delete this.ifra;
- this.ifra = null;
+ if (this.transp != null) {
+ this.transp.destroy();
+ delete this.transp;
+ this.transp = null;
}
},
projects / brisk.git / blobdiff