* Watchdog client requests for timeouts * @this {!Client} * @param {!number} utc UTC timestamp in milliseconds
(utc)
| 7352 | * @param {!number} utc UTC timestamp in milliseconds |
| 7353 | */ |
| 7354 | watchdogRequests (utc) { |
| 7355 | this._protoClient.watchdogRequests(utc) |
| 7356 | |
| 7357 | for (let [, value] of this._requests_by_timestamp) { |
| 7358 | let item = this._requests_by_id.get(value) |
| 7359 | let id = value |
| 7360 | let timestamp = item[0] |
| 7361 | let timespan = item[1] |
| 7362 | if ((timestamp + timespan) <= utc) { |
| 7363 | let promise = item[2] |
| 7364 | promise.reject(new Error('Timeout!')) |
| 7365 | this._requests_by_id.delete(id) |
| 7366 | this._requests_by_timestamp.delete(timestamp) |
| 7367 | } |
| 7368 | } |
| 7369 | } |
| 7370 | } |
| 7371 | |
| 7372 | exports.Client = Client |
no test coverage detected