diff options
Diffstat (limited to 'jstests/libs/kill_sessions.js')
| -rw-r--r-- | jstests/libs/kill_sessions.js | 21 |
1 files changed, 16 insertions, 5 deletions
diff --git a/jstests/libs/kill_sessions.js b/jstests/libs/kill_sessions.js index b56554d02c4..bf4a2c541b8 100644 --- a/jstests/libs/kill_sessions.js +++ b/jstests/libs/kill_sessions.js @@ -1,4 +1,5 @@ load("jstests/libs/parallelTester.js"); +load("jstests/libs/logv2_helpers.js"); /** * Implements a kill session test helper @@ -248,11 +249,21 @@ var _kill_sessions_api_module = (function() { CursorHandle.prototype.assertCursorKillLogMessages = function(hostsToCheck) { for (let hostToCheck of hostsToCheck) { if (hostToCheck.host in this._cursors) { - assert(checkLog.checkContainsOnce( - hostToCheck, - 'killing cursor: ' + this._cursors[hostToCheck.host].exactValueString + - ' as part of killing session(s)'), - "cursor kill was not logged by " + hostToCheck.host); + if (isJsonLog(hostToCheck)) { + assert(checkLog.checkContainsOnceJson( + hostToCheck, + 20528, + 'id', + this._cursors[hostToCheck.host].exactValueString), + "cursor kill was not logged by " + hostToCheck.host); + } else { + assert( + checkLog.checkContainsOnce( + hostToCheck, + 'killing cursor: ' + this._cursors[hostToCheck.host].exactValueString + + ' as part of killing session(s)'), + "cursor kill was not logged by " + hostToCheck.host); + } } } }; |