lib/mongo/cluster/reapers/cursor_reaper.rb in mongo-2.14.1 vs lib/mongo/cluster/reapers/cursor_reaper.rb in mongo-2.15.0.alpha
- old
+ new
@@ -128,19 +128,23 @@
active_cursors_copy = @active_cursors.dup
@to_kill = {}
end
to_kill_copy.each do |server, op_specs|
+ options = {
+ server_api: server.options[:server_api],
+ }
+ context = Operation::Context.new(options: options)
op_specs.each do |op_spec|
if server.features.find_command_enabled?
Cursor::Builder::KillCursorsCommand.update_cursors(op_spec, active_cursors_copy.to_a)
if Cursor::Builder::KillCursorsCommand.get_cursors_list(op_spec).size > 0
- Operation::KillCursors.new(op_spec).execute(server, client: nil)
+ Operation::KillCursors.new(op_spec).execute(server, context: context)
end
else
Cursor::Builder::OpKillCursors.update_cursors(op_spec, active_cursors_copy.to_a)
if Cursor::Builder::OpKillCursors.get_cursors_list(op_spec).size > 0
- Operation::KillCursors.new(op_spec).execute(server, client: nil)
+ Operation::KillCursors.new(op_spec).execute(server, context: context)
end
end
end
end
end