Skip to content

Commit

Permalink
Fix throughput on abort (#4203)
Browse files Browse the repository at this point in the history
* Take account aborted request metrics (for throughput history)

* Remove console.log

* Fix aborted request timing info

* Remove request property checkExistenceOnly, not used anymore
  • Loading branch information
bbert committed Jun 6, 2023
1 parent bd0081d commit 59542d3
Show file tree
Hide file tree
Showing 3 changed files with 17 additions and 32 deletions.
23 changes: 10 additions & 13 deletions src/streaming/net/HTTPLoader.js
Expand Up @@ -114,6 +114,11 @@ function HTTPLoader(cfg) {
}

const addHttpRequestMetric = function(success) {
request.requestStartDate = requestStartTime;
request.requestEndDate = new Date();
request.firstByteDate = request.firstByteDate || requestStartTime;
request.fileLoaderType = fileLoaderType;

const responseUrl = httpRequest.response ? httpRequest.response.responseURL : null;
const responseStatus = httpRequest.response ? httpRequest.response.status : null;
const responseHeaders = httpRequest.response && httpRequest.response.getAllResponseHeaders ? httpRequest.response.getAllResponseHeaders() :
Expand All @@ -127,18 +132,11 @@ function HTTPLoader(cfg) {
const handleLoaded = function (success) {
needFailureReport = false;

request.requestStartDate = requestStartTime;
request.requestEndDate = new Date();
request.firstByteDate = request.firstByteDate || requestStartTime;
request.fileLoaderType = fileLoaderType;
addHttpRequestMetric(success);

if (!request.checkExistenceOnly) {
addHttpRequestMetric(success);

if (request.type === HTTPRequest.MPD_TYPE) {
dashMetrics.addManifestUpdate(request);
eventBus.trigger(Events.MANIFEST_LOADING_FINISHED, { request });
}
if (request.type === HTTPRequest.MPD_TYPE) {
dashMetrics.addManifestUpdate(request);
eventBus.trigger(Events.MANIFEST_LOADING_FINISHED, { request });
}
};

Expand Down Expand Up @@ -318,7 +316,6 @@ function HTTPLoader(cfg) {
}
}

const verb = request.checkExistenceOnly ? HTTPRequest.HEAD : HTTPRequest.GET;
const withCredentials = customParametersModel.getXHRWithCredentialsForType(request.type);

// Add queryParams that came from pathway cloning
Expand All @@ -336,7 +333,7 @@ function HTTPLoader(cfg) {

httpRequest = {
url: modifiedUrl,
method: verb,
method: HTTPRequest.GET,
withCredentials: withCredentials,
request: request,
onload: onload,
Expand Down
6 changes: 2 additions & 4 deletions test/unit/streaming.net.HTTPLoader.js
Expand Up @@ -68,7 +68,6 @@ describe('HTTPLoader', function () {

httpLoader.load({
request: {
checkExistenceOnly: true,
responseType: 'json',
type: HTTPRequest.MEDIA_SEGMENT_TYPE,
availabilityTimeComplete: false
Expand All @@ -93,7 +92,7 @@ describe('HTTPLoader', function () {
});

httpLoader.load({
request: {checkExistenceOnly: true},
request: {},
success: callbackSucceeded,
complete: callbackCompleted,
error: callbackError
Expand All @@ -120,7 +119,7 @@ describe('HTTPLoader', function () {
});

httpLoader.load({
request: {checkExistenceOnly: true},
request: {},
success: callbackSucceeded,
complete: callbackCompleted,
error: callbackError
Expand Down Expand Up @@ -149,7 +148,6 @@ describe('HTTPLoader', function () {

httpLoader.load({
request: {
checkExistenceOnly: true,
responseType: 'arraybuffer',
type: HTTPRequest.INIT_SEGMENT_TYPE,
availabilityTimeComplete: false
Expand Down
20 changes: 5 additions & 15 deletions test/unit/streaming.net.XHRLoader.js
Expand Up @@ -42,9 +42,7 @@ describe('XHRLoader', function () {
requestModifier: requestModifier
});
const request = {
request: {
checkExistenceOnly: true
},
request: {},
onload: callbackSucceeded,
onend: callbackCompleted,
onerror: callbackError,
Expand All @@ -70,9 +68,7 @@ describe('XHRLoader', function () {
requestModifier: requestModifier
});
const request = {
request: {
checkExistenceOnly: true
},
request: {},
onload: callbackSucceeded,
onend: callbackCompleted,
onerror: callbackError,
Expand All @@ -99,9 +95,7 @@ describe('XHRLoader', function () {
});

const request = {
request: {
checkExistenceOnly: true
},
request: {},
onload: callbackSucceeded,
onend: callbackCompleted,
onerror: callbackError,
Expand All @@ -127,9 +121,7 @@ describe('XHRLoader', function () {
requestModifier: requestModifier
});
const request = {
request: {
checkExistenceOnly: true
},
request: {},
onload: callbackSucceeded,
onend: callbackCompleted,
onerror: callbackError,
Expand All @@ -150,9 +142,7 @@ describe('XHRLoader', function () {
requestModifier: requestModifier
});
const request = {
request: {
checkExistenceOnly: true
},
request: {},
timeout: 100
};
xhrLoader.load(request);
Expand Down

0 comments on commit 59542d3

Please sign in to comment.