summaryrefslogtreecommitdiff
path: root/src/mongo/db/initialize_operation_session_info.cpp
diff options
context:
space:
mode:
authorLucas de Castro Borges <lucas@gnuabordo.com.br>2025-02-11 15:07:35 -0300
committerLucas de Castro Borges <lucas@gnuabordo.com.br>2025-02-11 15:07:35 -0300
commit4cb8841196d0625dfa3825aa326f071cd27c7b8b (patch)
tree1682a647d4463397c119183369ae6f750d5fdcff /src/mongo/db/initialize_operation_session_info.cpp
parentaa03c6362cbaa767638e6eed9b031d86dd2643d1 (diff)
parent8f0827553e09872941945a093b647a4211a9db7f (diff)
Update upstream source from tag 'upstream/6.0.0'master
Update to upstream version '6.0.0' with Debian dir 5604a80ec1c96ca76f25f40d78e6ef855abec322
Diffstat (limited to 'src/mongo/db/initialize_operation_session_info.cpp')
-rw-r--r--src/mongo/db/initialize_operation_session_info.cpp25
1 files changed, 0 insertions, 25 deletions
diff --git a/src/mongo/db/initialize_operation_session_info.cpp b/src/mongo/db/initialize_operation_session_info.cpp
index 5eccaf3faa7..a3b75ec443d 100644
--- a/src/mongo/db/initialize_operation_session_info.cpp
+++ b/src/mongo/db/initialize_operation_session_info.cpp
@@ -36,20 +36,9 @@
#include "mongo/db/logical_session_cache.h"
#include "mongo/db/logical_session_id_helpers.h"
#include "mongo/db/operation_context.h"
-#include "mongo/db/stats/counters.h"
namespace mongo {
-/**
- * A client is internal if the connection is a self connection, a connection from a mongos or
- * different mongod or a direct client connection.
- */
-bool isInternalClient(OperationContext* opCtx) {
- return !opCtx->getClient()->session() ||
- (opCtx->getClient()->session()->getTags() & transport::Session::kInternalClient) ||
- opCtx->getClient()->isInDirectClient();
-}
-
OperationSessionInfoFromClient initializeOperationSessionInfo(OperationContext* opCtx,
const BSONObj& requestBody,
bool requiresAuth,
@@ -177,20 +166,6 @@ OperationSessionInfoFromClient initializeOperationSessionInfo(OperationContext*
osi.getStartTransaction().value());
}
- if (osi.getTxnNumber()) {
- if (!osi.getAutocommit()) {
- if (isInternalClient(opCtx)) {
- internalRetryableWriteCount.increment(1);
- } else {
- externalRetryableWriteCount.increment(1);
- }
- } else {
- if (osi.getSessionId()->getTxnNumber() && osi.getSessionId()->getTxnUUID()) {
- retryableInternalTransactionCount.increment(1);
- }
- }
- }
-
return osi;
}