* Executed after an scheduled new connection attempt finished * @private
(err)
| 401 | * @private |
| 402 | */ |
| 403 | async _onNewConnectionOpen(err) { |
| 404 | if (err) { |
| 405 | this._checkPoolState(); |
| 406 | return; |
| 407 | } |
| 408 | if (!this.isUp() && this.options.rePrepareOnUp) { |
| 409 | this.log('info', `Re-preparing all queries on host ${this.address} before setting it as UP`); |
| 410 | const allPrepared = this._metadata.getAllPrepared(); |
| 411 | try { |
| 412 | await PrepareHandler.prepareAllQueries(this, allPrepared); |
| 413 | } |
| 414 | catch (err) { |
| 415 | this.log('warning', `Failed re-preparing on host ${this.address}: ${err}`, err); |
| 416 | } |
| 417 | } |
| 418 | this.setUp(); |
| 419 | this.pool.increaseSize(); |
| 420 | } |
| 421 | |
| 422 | /** |
| 423 | * Returns an array containing the Cassandra Version as an Array of Numbers having the major version in the first |
no test coverage detected