parameters: (self, iterator, key_infos_map, group_id)
return_statement: return timeouted_keys, corrupted_keys
docstring: Check result of remote sending for every key.
          Returns lists of timeouted keys and corrupted keys.
docstring_summary: Check result of remote sending for every key.
          Returns lists of timeouted keys and corrupted keys.
docstring_tokens: Check result of remote sending for every key . Returns lists of timeouted keys and corrupted keys .
function: def _check_server_send_results(self, iterator, key_infos_map, group_id):
          '''
          Check result of remote sending for every key.
          Returns lists of timeouted keys and corrupted keys.
          '''
          start_time = time.time()
          recovers_in_progress = len(key_infos_map)
  
          timeouted_keys = []
          corrupted_keys = []
          succeeded_keys = Set()
          index = -1
          for index, result in enumerate(iterator, 1):
              status = result.response.status
              self._update_stats(start_time, index, recovers_in_progress, status)
  
              key = result.response.key
              if status < 0:
                  key_infos = key_infos_map[str(key)]
                  self._on_server_send_fail(status, key, key_infos, timeouted_keys, corrupted_keys, group_id)
                  continue
              elif status == 0:
                  succeeded_keys.add(str(key))
                  log.debug("Recovered key: %s, status %d", result.response.key, status)
  
          if index < len(key_infos_map):
              log.error("Server-send operation failed: group_id: %d, received results: %d, expected: %d",
                        group_id, index, len(key_infos_map))
              timeouted_keys = [elliptics.Id(k) for k in key_infos_map.iterkeys() if k not in succeeded_keys]
  
          return timeouted_keys, corrupted_keys
function_tokens: def _check_server_send_results ( self , iterator , key_infos_map , group_id ) : start_time = time . time ( ) recovers_in_progress = len ( key_infos_map ) timeouted_keys = [ ] corrupted_keys = [ ] succeeded_keys = Set ( ) index = - 1 for index , result in enumerate ( iterator , 1 ) : status = result . response . status self . _update_stats ( start_time , index , recovers_in_progress , status ) key = result . response . key if status < 0 : key_infos = key_infos_map [ str ( key ) ] self . _on_server_send_fail ( status , key , key_infos , timeouted_keys , corrupted_keys , group_id ) continue elif status == 0 : succeeded_keys . add ( str ( key ) ) log . debug ( "Recovered key: %s, status %d" , result . response . key , status ) if index < len ( key_infos_map ) : log . error ( "Server-send operation failed: group_id: %d, received results: %d, expected: %d" , group_id , index , len ( key_infos_map ) ) timeouted_keys = [ elliptics . Id ( k ) for k in key_infos_map . iterkeys ( ) if k not in succeeded_keys ] return timeouted_keys , corrupted_keys