206,210c206,213
<       @logger.debug("  MONGODB #{log_message || message}") if @logger
<       packed_message = add_message_headers(operation, message).to_s
<       socket = checkout
<       send_message_on_socket(packed_message, socket)
<       checkin(socket)
---
>       begin
>         @logger.debug("  MONGODB #{log_message || message}") if @logger
>         packed_message = add_message_headers(operation, message).to_s
>         socket = checkout
>         send_message_on_socket(packed_message, socket)
>       ensure
>         checkin(socket)
>       end
220,228c223,235
<       message_with_headers = add_message_headers(operation, message)
<       message_with_check   = last_error_message(db_name)
<       @logger.debug("  MONGODB #{log_message || message}") if @logger
<       sock = checkout
<       packed_message = message_with_headers.append!(message_with_check).to_s
<       docs = num_received = cursor_id = ''
<       @safe_mutex.synchronize do
<         send_message_on_socket(packed_message, sock)
<         docs, num_received, cursor_id = receive(sock)
---
>       begin
>         message_with_headers = add_message_headers(operation, message)
>         message_with_check   = last_error_message(db_name)
>         @logger.debug("  MONGODB #{log_message || message}") if @logger
>         sock = checkout
>         packed_message = message_with_headers.append!(message_with_check).to_s
>         docs = num_received = cursor_id = ''
>         @safe_mutex.synchronize do
>           send_message_on_socket(packed_message, sock)
>           docs, num_received, cursor_id = receive(sock)
>         end
>       ensure
>         checkin(sock)
230d236
<       checkin(sock)
243,250c249,260
<       packed_message = add_message_headers(operation, message).to_s
<       @logger.debug("  MONGODB #{log_message || message}") if @logger
<       sock = socket || checkout
< 
<       result = ''
<       @safe_mutex.synchronize do
<         send_message_on_socket(packed_message, sock)
<         result = receive(sock)
---
>       begin
>         packed_message = add_message_headers(operation, message).to_s
>         @logger.debug("  MONGODB #{log_message || message}") if @logger
>         sock = socket || checkout
> 
>         result = ''
>         @safe_mutex.synchronize do
>           send_message_on_socket(packed_message, sock)
>           result = receive(sock)
>         end
>       ensure
>         checkin(sock)
252d261
<       checkin(sock)
362c371,376
< 
---
>           
>           if @logger 
>             @logger.warn "No socket to MongoDB available. size #{@size}, sockets " + 
>                          "#{@sockets.size}, checked out #{@checked_out.size} " +
>                          "waiting for a socket to get available..."
>           end