/*
-** $Id: pz2.js,v 1.70 2008-03-12 11:36:57 jakub Exp $
** pz2.js - pazpar2's javascript client library.
*/
this.showFastCount = 4;
this.bytargetTime = paramArray.bytargettime || 1000;
this.bytargetTimer = null;
+ this.recordTime = paramArray.recordtime || 500;
+ this.recordTimer = null;
// counters for each command and applied delay
this.dumpFactor = 500;
this.termCounter = 0;
this.statCounter = 0;
this.bytargetCounter = 0;
+ this.recordCounter = 0;
// active clients, updated by stat and show
// might be an issue since bytarget will poll accordingly
this.termCounter = 0;
this.bytargetCounter = 0;
this.statCounter = 0;
+ this.activeClients = 1;
// no proxy mode
if( !this.initStatusOK )
Number( data.getElementsByTagName("activeclients")[0]
.childNodes[0].nodeValue );
context.activeClients = activeClients;
- var stat = {
- "activeclients": activeClients,
- "hits":
- Number( data.getElementsByTagName("hits")[0]
- .childNodes[0].nodeValue ),
- "records":
- Number( data.getElementsByTagName("records")[0]
- .childNodes[0].nodeValue ),
- "clients":
- Number( data.getElementsByTagName("clients")[0]
- .childNodes[0].nodeValue ),
- "unconnected":
- Number( data.getElementsByTagName("unconnected")[0]
- .childNodes[0].nodeValue ),
- "connecting":
- Number( data.getElementsByTagName("connecting")[0]
- .childNodes[0].nodeValue ),
- "working":
- Number( data.getElementsByTagName("working")[0]
- .childNodes[0].nodeValue ),
- "idle":
- Number( data.getElementsByTagName("idle")[0]
- .childNodes[0].nodeValue ),
- "failed":
- Number( data.getElementsByTagName("failed")[0]
- .childNodes[0].nodeValue ),
- "error":
- Number( data.getElementsByTagName("error")[0]
- .childNodes[0].nodeValue ),
- "progress":
- Number( data.getElementsByTagName("progress")[0]
- .childNodes[0].nodeValue )
- };
-
+
+ var stat = Element_parseChildNodes(data.documentElement);
+
context.statCounter++;
var delay = context.statTime
+ context.statCounter * context.dumpFactor;
recordParams,
function(data) {
var recordNode;
- var record;
+ var record;
//raw record
if (context.currRecOffset !== null) {
record = new Array();
//parse record
} else {
record = Element_parseChildNodes(recordNode);
- }
+ }
+ var activeClients =
+ Number( data.getElementsByTagName("activeclients")[0]
+ .childNodes[0].nodeValue );
+ context.activeClients = activeClients;
+ context.recordCounter++;
+ var delay = context.recordTime + context.recordCounter * context.dumpFactor;
+ if ( activeClients > 0 )
+ context.recordTimer =
+ setTimeout (
+ function() {
+ context.record(id, offset, syntax, handler);
+ },
+ delay
+ );
callback(record, args);
}
else
for (var key in this.requestHeaders)
this.request.setRequestHeader(key, this.requestHeaders[key]);
this.request.onreadystatechange = function () {
- context._handleResponse();
+ context._handleResponse(url); /// url used ONLY for error reporting
}
this.request.send(data);
},
return this.url;
},
- _handleResponse: function ()
+ _handleResponse: function (savedUrlForErrorReporting)
{
if ( this.request.readyState == 4 ) {
// pick up appplication errors first
else {
throw err;
}
+ } else if (this.request.status == 200 &&
+ this.request.responseXML == null) {
+ var err = new Error("XML response is empty but no error " +
+ "for " + savedUrlForErrorReporting);
+ err.code = -1;
+ if (this.errorHandler) {
+ this.errorHandler(err);
+ } else {
+ throw err;
+ }
} else if (this.request.status == 200) {
this.callback(this.request.responseXML);
} else {
// if no nested elements, get text content
if (node.hasChildNodes() && !hasChildElems) {
if (node.attributes.length)
- parsed['textContent'] = node.firstChild.nodeValue;
+ parsed['#text'] = node.firstChild.nodeValue;
else
parsed = node.firstChild.nodeValue;
}