Skip to content

Commit bf0dd5d

Browse files
Disable cursor nesting
1 parent 10f5f6c commit bf0dd5d

File tree

3 files changed

+4
-6
lines changed

3 files changed

+4
-6
lines changed

lib/mongo/operation/insert/op_msg.rb

Lines changed: 1 addition & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -35,11 +35,7 @@ class OpMsg < OpMsgBase
3535

3636
def get_result(connection, context, options = {})
3737
message = build_message(connection, context)
38-
if (tracer = context.tracer)
39-
tracer.trace_command(message, context, connection) do
40-
Result.new(*dispatch_message(message, connection, context), @ids, context: context)
41-
end
42-
else
38+
connection.tracer.trace_command(message, context, connection) do
4339
Result.new(*dispatch_message(message, connection, context), @ids, context: context)
4440
end
4541
end

lib/mongo/session.rb

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -130,6 +130,8 @@ def snapshot?
130130
# @since 2.5.0
131131
attr_reader :operation_time
132132

133+
def_delegators :client, :tracer
134+
133135
# Sets the dirty state to the given value for the underlying server
134136
# session. If there is no server session, this does nothing.
135137
#

lib/mongo/tracing/open_telemetry/command_tracer.rb

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -76,7 +76,7 @@ def span_attributes(message, connection)
7676
end
7777

7878
def process_cursor_context(result, cursor_id, context, span)
79-
if result.respond_to?(:cursor_id) && result.cursor_id.positive?
79+
if result.has_cursor_id? && result.cursor_id.positive?
8080
span.set_attribute('db.mongodb.cursor_id', result.cursor_id)
8181
end
8282
end

0 commit comments

Comments
 (0)