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
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
|
package steam
import (
"archive/tar"
"errors"
"fmt"
"io"
"path/filepath"
"time"
)
const (
defaultDirectoryMode = 0775
defaultFileMode = 0644
)
func (l *Library) Package(game string, wr io.Writer) error {
if _, ok := l.Games()[game]; !ok {
return E_GameDoesNotExist
}
g := l.Games()[game]
j := newJob("package", g)
defer j.done()
l.status.addJob(j)
j.setSize(g.GetSizeBytes())
// Invert the writer so we can break up the copy and get progress
// information in here
rdr, pwrtr := io.Pipe()
go func() {
err := l.packagePrimitive(j, g, pwrtr)
if err != nil {
j.addError(err)
}
}()
var total int64
for {
n, err := io.CopyN(wr, rdr, updateEveryNBytes)
if err == io.EOF {
break
}
if err != nil {
j.addError(err)
return err
}
total += n
j.setTransferred(total)
elapsedSeconds := float64(time.Since(*j.StartTime()).Seconds())
rate := float64(total) / elapsedSeconds
fmt.Println("rate in bytes/second: ", formatBytes(int64(rate)))
estSize := j.GetSize()
if estSize == nil {
j.addError(errors.New("Expected an estimated size, got nil"))
continue
}
remainingBytes := float64(*estSize - total)
fmt.Println("remaining bytes: ", formatBytes(int64(remainingBytes)))
seconds := (remainingBytes / rate)
duration := time.Duration(seconds * 1000 * 1000 * 1000)
fmt.Println("Raw duration: ", duration)
j.setETA(duration)
}
return nil
}
// Package writes the package to wr, returning errors if any
func (l *Library) packagePrimitive(j *Job, g *Game, wr io.WriteCloser) error {
acf, err := FindACF(l.folder, g.Name)
if err != nil {
j.addError(err)
return err
}
twriter := tar.NewWriter(wr)
paths := []string{
filepath.Join(l.folder, "common", g.Name),
acf,
}
for _, pth := range paths {
err := filepath.Walk(pth, tarWalkfn(twriter, l.folder))
if err != nil {
j.addError(err)
return err
}
}
err = twriter.Flush()
if err != nil {
j.addError(err)
return err
}
err = twriter.Close()
if err != nil {
j.addError(err)
return err
}
err = wr.Close()
if err != nil {
j.addError(err)
return err
}
return err
}
|
