lib/mongo/operation/drop_index/op_msg.rb in mongo-2.5.3 vs lib/mongo/operation/drop_index/op_msg.rb in mongo-2.6.0

@@ -24,9 +24,18 @@
       class OpMsg
         include Specifiable
         include Executable
         include SessionsSupported
 
+        def execute(server)
+          result = Result.new(dispatch_message(server))
+          process_result(result, server)
+          result.validate!
+        rescue Mongo::Error::SocketError => e
+          e.send(:add_label, Mongo::Error::TRANSIENT_TRANSACTION_ERROR_LABEL) if session.in_transaction?
+          raise e
+        end
+
         private
 
         def selector(server)
           { :dropIndexes => coll_name, :index => index_name }
         end