@@ -931,21 +931,18 @@ func (d *Driver) copyFileShare(ctx context.Context, req *csi.CreateVolumeRequest
931
931
dstPath := fmt .Sprintf ("https://%s.file.%s/%s%s" , accountName , storageEndpointSuffix , dstFileShareName , accountSasToken )
932
932
933
933
jobState , percent , err := getAzcopyJob (dstFileShareName )
934
- switch jobState {
935
- case AzcopyJobError , AzcopyJobCompleted :
934
+ klog . V ( 2 ). Infof ( "azcopy job status: %s, copy percent: %s%, error: %v" , jobState , percent , err )
935
+ if jobState == AzcopyJobError || jobState == AzcopyJobCompleted {
936
936
return err
937
- case AzcopyJobRunning :
938
- klog .V (2 ).Infof ("azcopy job is in progress, copy percent: %s%" , percent )
939
937
}
940
938
for {
941
939
select {
942
940
case <- timeTick :
943
941
jobState , percent , err := getAzcopyJob (dstFileShareName )
942
+ klog .V (2 ).Infof ("azcopy job status: %s, copy percent: %s%, error: %v" , jobState , percent , err )
944
943
switch jobState {
945
944
case AzcopyJobError , AzcopyJobCompleted :
946
945
return err
947
- case AzcopyJobRunning :
948
- klog .V (2 ).Infof ("azcopy job is in progress, copy percent: %s%" , percent )
949
946
case AzcopyJobNotFound :
950
947
klog .V (2 ).Infof ("copy fileshare %s to %s" , srcFileShareName , dstFileShareName )
951
948
out , copyErr := exec .Command ("azcopy" , "copy" , srcPath , dstPath , "--recursive" , "--check-length=false" ).CombinedOutput ()
0 commit comments