def add_to_reconciler_queue(container_ring, account, container, obj, obj_policy_index, obj_timestamp, op, force=False, conn_timeout=5, response_timeout=15):
 container_name = get_reconciler_container_name(obj_timestamp)
 object_name = get_reconciler_obj_name(obj_policy_index, account, container, obj)
 if force:
  x_timestamp = Timestamp(time.time()).internal
 else:
  x_timestamp = obj_timestamp
 q_op_type = get_reconciler_content_type(op)
 headers = {'X-Size': 0, 'X-Etag': obj_timestamp, 'X-Timestamp': x_timestamp, 'X-Content-Type': q_op_type}
 def _check_success(*args, **kwargs):
  try:
   direct_put_container_object(*args, **kwargs)
   return 1
  except (ClientException, Timeout, socket.error):
   return 0
 pile = GreenPile()
 (part, nodes) = container_ring.get_nodes(MISPLACED_OBJECTS_ACCOUNT, container_name)
 for node in nodes:
  pile.spawn(_check_success, node, part, MISPLACED_OBJECTS_ACCOUNT, container_name, object_name, headers=headers, conn_timeout=conn_timeout, response_timeout=response_timeout)
 successes = sum(pile)
 if (successes >= majority_size(len(nodes))):
  return container_name
 else:
  return False

def add_to_reconciler_queue ( container_ring , account , container , obj , obj_policy_index , obj_timestamp , op , force = False , conn_timeout = 5 , response_timeout = 15 ) : container_name = get_reconciler_container_name ( obj_timestamp ) object_name = get_reconciler_obj_name ( obj_policy_index , account , container , obj ) if force : x_timestamp = Timestamp ( time . time ( ) ) . internal else : x_timestamp = obj_timestamp q_op_type = get_reconciler_content_type ( op ) headers = { 'X-Size' : 0 , 'X-Etag' : obj_timestamp , 'X-Timestamp' : x_timestamp , 'X-Content-Type' : q_op_type } def _check_success ( * args , ** kwargs ) : try : direct_put_container_object ( * args , ** kwargs ) return 1 except ( ClientException , Timeout , socket . error ) : return 0 pile = GreenPile ( ) ( part , nodes ) = container_ring . get_nodes ( MISPLACED_OBJECTS_ACCOUNT , container_name ) for node in nodes : pile . spawn ( _check_success , node , part , MISPLACED_OBJECTS_ACCOUNT , container_name , object_name , headers = headers , conn_timeout = conn_timeout , response_timeout = response_timeout ) successes = sum ( pile ) if ( successes >= majority_size ( len ( nodes ) ) ) : return container_name else : return False
add an object to the container reconcilers queue .