Copy c.src to (c.f, c.remoteForCopy) using multiThreadCopy
(ctx context.Context, uploadOptions []fs.OpenOption)
| 173 | |
| 174 | // Copy c.src to (c.f, c.remoteForCopy) using multiThreadCopy |
| 175 | func (c *copy) multiThreadCopy(ctx context.Context, uploadOptions []fs.OpenOption) (actionTaken string, newDst fs.Object, err error) { |
| 176 | newDst, err = multiThreadCopy(ctx, c.f, c.remoteForCopy, c.src, c.ci.MultiThreadStreams, c.tr, uploadOptions...) |
| 177 | if c.doUpdate { |
| 178 | actionTaken = "Multi-thread Copied (replaced existing)" |
| 179 | } else { |
| 180 | actionTaken = "Multi-thread Copied (new)" |
| 181 | } |
| 182 | return actionTaken, newDst, err |
| 183 | } |
| 184 | |
| 185 | // Copy the stream from in to (c.f, c.remoteForCopy) and close it |
| 186 | // |
no test coverage detected