/
upload_v3.go
49 lines (47 loc) · 1.28 KB
/
upload_v3.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
package client
import (
"context"
"github.com/lazyxu/kfs/core"
"github.com/lazyxu/kfs/pb"
"github.com/lazyxu/kfs/rpc/rpcutil"
"net"
"os"
"path/filepath"
)
func (fs *RpcFs) UploadDir(ctx context.Context, deviceId string, driverId uint64, dstPath string, srcPath string, config core.UploadDirConfig) (err error) {
srcPath, err = filepath.Abs(srcPath)
if err != nil {
return
}
var d net.Dialer
conn, err := d.DialContext(ctx, "tcp", fs.SocketServerAddr)
if err != nil {
return err
}
defer conn.Close()
handlers := &uploadHandlersV3{
uploadProcess: config.UploadDirProcess,
encoder: config.Encoder,
verbose: config.Verbose,
concurrent: config.Concurrent,
socketServerAddr: fs.SocketServerAddr,
conns: make([]net.Conn, config.Concurrent),
files: make([]*os.File, config.Concurrent),
driverId: driverId,
srcPath: srcPath,
dstPath: dstPath,
conn: conn,
uploadDeviceId: deviceId,
}
var startResp pb.UploadStartResp
_, err = ReqRespWithConn(handlers.conn, rpcutil.CommandUploadStart, &pb.UploadStartReq{}, &startResp)
if err != nil {
return err
}
handlers.uploadTime = startResp.UploadTime
err = core.WalkDir(ctx, srcPath, handlers)
if err != nil {
return
}
return nil
}