Searched refs:bucket_from (Results 1 – 2 of 2) sorted by relevance
863 let (bucket_from, bucket_to) = lock_bucket_pair(key_from, key_to); in unpark_requeue()870 unlock_bucket_pair(bucket_from, bucket_to); in unpark_requeue()875 let mut link = &bucket_from.queue_head; in unpark_requeue()876 let mut current = bucket_from.queue_head.get(); in unpark_requeue()886 if bucket_from.queue_tail.get() == current { in unpark_requeue()887 bucket_from.queue_tail.set(previous); in unpark_requeue()942 result.be_fair = (*bucket_from.fair_timeout.get()).should_timeout(); in unpark_requeue()951 unlock_bucket_pair(bucket_from, bucket_to); in unpark_requeue()955 unlock_bucket_pair(bucket_from, bucket_to); in unpark_requeue()
270 def Copy(bucket_from, bucket_to, remote_path_from, remote_path_to): argument282 url1 = 'gs://%s/%s' % (bucket_from, remote_path_from)