huahaofeng
/
aspnetcore
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

clean up the shutdown timer

This commit is contained in:
Andrew Stanton-Nurse 2018-05-03 09:26:48 -07:00
parent ae329edd2a
commit fdfd5381a5
1 changed files with 9 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
clients/ts/signalr/src/LongPollingTransport.ts
View File

@ -147,6 +147,14 @@ export class LongPollingTransport implements ITransport {
} }
} }
} finally { } finally {
// Trigger the poll aborted token so we don't set the shutdown timer
this.pollAbort.abort();
// Clean up the shutdown timer if it was registered
if (this.shutdownTimer) {
clearTimeout(this.shutdownTimer);
}
// Fire our onclosed event // Fire our onclosed event
if (this.onclose) { if (this.onclose) {
this.logger.log(LogLevel.Trace, `(LongPolling transport) Firing onclose event. Error: ${closeError || "<undefined>"}`); this.logger.log(LogLevel.Trace, `(LongPolling transport) Firing onclose event. Error: ${closeError || "<undefined>"}`);
@ -179,7 +187,7 @@ export class LongPollingTransport implements ITransport {
this.logger.log(LogLevel.Trace, "(LongPolling transport) DELETE request accepted."); this.logger.log(LogLevel.Trace, "(LongPolling transport) DELETE request accepted.");
} finally { } finally {
// Abort the poll after 5 seconds if the server doesn't stop it. // Abort the poll after the shutdown timeout if the server doesn't stop the poll.
if (!this.pollAbort.aborted) { if (!this.pollAbort.aborted) {
this.shutdownTimer = setTimeout(() => { this.shutdownTimer = setTimeout(() => {
this.logger.log(LogLevel.Warning, "(LongPolling transport) server did not terminate after DELETE request, canceling poll."); this.logger.log(LogLevel.Warning, "(LongPolling transport) server did not terminate after DELETE request, canceling poll.");