|
@@ -45,7 +45,9 @@ namespace B2Uploader
|
45
|
45
|
|
46
|
46
|
var bucket = buckets.buckets.First();
|
47
|
47
|
|
48
|
|
- foreach(string s in Directory.GetFiles(options.Directory))
|
|
48
|
+ string[] FilesToProcess = Directory.GetFiles(options.Directory);
|
|
49
|
+
|
|
50
|
+ Parallel.ForEach(FilesToProcess, s =>
|
49
|
51
|
{
|
50
|
52
|
//check if file already exists
|
51
|
53
|
|
|
@@ -73,14 +75,14 @@ namespace B2Uploader
|
73
|
75
|
}
|
74
|
76
|
if (found)
|
75
|
77
|
{
|
76
|
|
- Console.WriteLine("File exists already, skipping");
|
77
|
|
- continue;
|
|
78
|
+ Console.WriteLine("File {0} exists already, skipping", fileName);
|
78
|
79
|
}
|
79
|
|
-
|
80
|
|
-
|
81
|
|
- var uploadURL = GetUploadURL(new GetUploadURLRequest { bucketId = bucket.bucketId }, auth.apiUrl, auth.authorizationToken);
|
82
|
|
- var response = UploadFile(uploadURL.authorizationToken, "b2/x-auto", s, uploadURL.uploadUrl);
|
83
|
|
- }
|
|
80
|
+ else
|
|
81
|
+ {
|
|
82
|
+ var uploadURL = GetUploadURL(new GetUploadURLRequest { bucketId = bucket.bucketId }, auth.apiUrl, auth.authorizationToken);
|
|
83
|
+ var response = UploadFile(uploadURL.authorizationToken, "b2/x-auto", s, uploadURL.uploadUrl);
|
|
84
|
+ }
|
|
85
|
+ });
|
84
|
86
|
return 1;
|
85
|
87
|
},
|
86
|
88
|
errors =>{
|