Searched refs:bucket_to (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()930 if !bucket_to.queue_head.get().is_null() { in unpark_requeue()931 (*bucket_to.queue_tail.get()) in unpark_requeue()935 bucket_to.queue_head.set(requeue_threads); in unpark_requeue()937 bucket_to.queue_tail.set(requeue_threads_tail); 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): argument283 url2 = 'gs://%s/%s' % (bucket_to, remote_path_to)