lib/mongo/cluster/reapers/cursor_reaper.rb
# Schedule a kill cursors operation to be eventually executed.
#
# @param [ Cursor::KillSpec ] kill_spec The kill specification.
# @param [ Mongo::Server ] server The server to send the kill cursors
#   operation to.
#
# @api private
Schedule a kill cursors operation to be eventually executed.
Schedule a kill cursors operation to be eventually executed .
def schedule_kill_cursor(kill_spec, server)
        @mutex.synchronize do
          if @active_cursor_ids.include?(kill_spec.cursor_id)
            @to_kill[server.address.seed] ||= Set.new
            @to_kill[server.address.seed] << kill_spec
          end
        end
      end
def schedule_kill_cursor ( kill_spec , server ) @mutex . synchronize do if @active_cursor_ids . include? ( kill_spec . cursor_id ) @to_kill [ server . address . seed ] ||= Set . new @to_kill [ server . address . seed ] << kill_spec end end end
Schedule a kill cursors operation to be eventually executed.
Schedule a kill cursors operation to be eventually executed .
kill_spec
<not_specific>
server
<not_specific>
<not_specific>
server The server to send the kill cursors operation to.
server The server to send the kill cursors operation to .
api
None