fix variables that werent being called
Signed-off-by: Jessica Frazelle <acidburn@docker.com>
This commit is contained in:
parent
9527d789e7
commit
b9fcb41e6d
9 changed files with 19 additions and 22 deletions
|
@ -241,7 +241,7 @@ func (t *authZPluginTestServer) start() {
|
||||||
r.HandleFunc("/Plugin.Activate", t.activate)
|
r.HandleFunc("/Plugin.Activate", t.activate)
|
||||||
r.HandleFunc("/"+AuthZApiRequest, t.auth)
|
r.HandleFunc("/"+AuthZApiRequest, t.auth)
|
||||||
r.HandleFunc("/"+AuthZApiResponse, t.auth)
|
r.HandleFunc("/"+AuthZApiResponse, t.auth)
|
||||||
t.listener, err = net.Listen("tcp", pluginAddress)
|
t.listener, _ = net.Listen("tcp", pluginAddress)
|
||||||
server := http.Server{Handler: r, Addr: pluginAddress}
|
server := http.Server{Handler: r, Addr: pluginAddress}
|
||||||
server.Serve(l)
|
server.Serve(l)
|
||||||
}
|
}
|
||||||
|
|
|
@ -168,6 +168,9 @@ func TestMoveToSubdir(t *testing.T) {
|
||||||
}
|
}
|
||||||
// validate that the files were moved to the subdirectory
|
// validate that the files were moved to the subdirectory
|
||||||
infos, err := ioutil.ReadDir(subDir)
|
infos, err := ioutil.ReadDir(subDir)
|
||||||
|
if err != nil {
|
||||||
|
t.Fatal(err)
|
||||||
|
}
|
||||||
if len(infos) != 4 {
|
if len(infos) != 4 {
|
||||||
t.Fatalf("Should be four files in the subdir after the migration: actual length: %d", len(infos))
|
t.Fatalf("Should be four files in the subdir after the migration: actual length: %d", len(infos))
|
||||||
}
|
}
|
||||||
|
|
|
@ -5,17 +5,10 @@ package directory
|
||||||
import (
|
import (
|
||||||
"os"
|
"os"
|
||||||
"path/filepath"
|
"path/filepath"
|
||||||
|
|
||||||
"github.com/docker/docker/pkg/longpath"
|
|
||||||
)
|
)
|
||||||
|
|
||||||
// Size walks a directory tree and returns its total size in bytes.
|
// Size walks a directory tree and returns its total size in bytes.
|
||||||
func Size(dir string) (size int64, err error) {
|
func Size(dir string) (size int64, err error) {
|
||||||
fixedPath, err := filepath.Abs(dir)
|
|
||||||
if err != nil {
|
|
||||||
return
|
|
||||||
}
|
|
||||||
fixedPath = longpath.AddPrefix(fixedPath)
|
|
||||||
err = filepath.Walk(dir, func(d string, fileInfo os.FileInfo, e error) error {
|
err = filepath.Walk(dir, func(d string, fileInfo os.FileInfo, e error) error {
|
||||||
// Ignore directory sizes
|
// Ignore directory sizes
|
||||||
if fileInfo == nil {
|
if fileInfo == nil {
|
||||||
|
|
|
@ -93,7 +93,7 @@ func (mj *JSONLog) MarshalJSONBuf(buf *bytes.Buffer) error {
|
||||||
ffjsonWriteJSONString(buf, mj.Log)
|
ffjsonWriteJSONString(buf, mj.Log)
|
||||||
}
|
}
|
||||||
if len(mj.Stream) != 0 {
|
if len(mj.Stream) != 0 {
|
||||||
if first == true {
|
if first {
|
||||||
first = false
|
first = false
|
||||||
} else {
|
} else {
|
||||||
buf.WriteString(`,`)
|
buf.WriteString(`,`)
|
||||||
|
@ -101,9 +101,7 @@ func (mj *JSONLog) MarshalJSONBuf(buf *bytes.Buffer) error {
|
||||||
buf.WriteString(`"stream":`)
|
buf.WriteString(`"stream":`)
|
||||||
ffjsonWriteJSONString(buf, mj.Stream)
|
ffjsonWriteJSONString(buf, mj.Stream)
|
||||||
}
|
}
|
||||||
if first == true {
|
if !first {
|
||||||
first = false
|
|
||||||
} else {
|
|
||||||
buf.WriteString(`,`)
|
buf.WriteString(`,`)
|
||||||
}
|
}
|
||||||
buf.WriteString(`"time":`)
|
buf.WriteString(`"time":`)
|
||||||
|
|
|
@ -39,7 +39,7 @@ func (mj *JSONLogs) MarshalJSONBuf(buf *bytes.Buffer) error {
|
||||||
ffjsonWriteJSONString(buf, mj.Stream)
|
ffjsonWriteJSONString(buf, mj.Stream)
|
||||||
}
|
}
|
||||||
if len(mj.RawAttrs) > 0 {
|
if len(mj.RawAttrs) > 0 {
|
||||||
if first == true {
|
if first {
|
||||||
first = false
|
first = false
|
||||||
} else {
|
} else {
|
||||||
buf.WriteString(`,`)
|
buf.WriteString(`,`)
|
||||||
|
@ -47,9 +47,7 @@ func (mj *JSONLogs) MarshalJSONBuf(buf *bytes.Buffer) error {
|
||||||
buf.WriteString(`"attrs":`)
|
buf.WriteString(`"attrs":`)
|
||||||
buf.Write(mj.RawAttrs)
|
buf.Write(mj.RawAttrs)
|
||||||
}
|
}
|
||||||
if first == true {
|
if !first {
|
||||||
first = false
|
|
||||||
} else {
|
|
||||||
buf.WriteString(`,`)
|
buf.WriteString(`,`)
|
||||||
}
|
}
|
||||||
buf.WriteString(`"time":`)
|
buf.WriteString(`"time":`)
|
||||||
|
|
|
@ -61,8 +61,7 @@ func ensureMountedAs(mountPoint, options string) error {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
mounted, err = Mounted(mountPoint)
|
if _, err = Mounted(mountPoint); err != nil {
|
||||||
if err != nil {
|
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
@ -112,8 +112,7 @@ func TestBufioWriterPoolPutAndGet(t *testing.T) {
|
||||||
buf.Reset()
|
buf.Reset()
|
||||||
BufioWriter32KPool.Put(writer)
|
BufioWriter32KPool.Put(writer)
|
||||||
// Try to write something
|
// Try to write something
|
||||||
written, err = writer.Write([]byte("barfoo"))
|
if _, err = writer.Write([]byte("barfoo")); err != nil {
|
||||||
if err != nil {
|
|
||||||
t.Fatal(err)
|
t.Fatal(err)
|
||||||
}
|
}
|
||||||
// If we now try to flush it, it should panic (the writer is nil)
|
// If we now try to flush it, it should panic (the writer is nil)
|
||||||
|
|
|
@ -23,8 +23,7 @@ func toShort(path string) (string, error) {
|
||||||
}
|
}
|
||||||
if n > uint32(len(b)) {
|
if n > uint32(len(b)) {
|
||||||
b = make([]uint16, n)
|
b = make([]uint16, n)
|
||||||
n, err = syscall.GetShortPathName(&p[0], &b[0], uint32(len(b)))
|
if _, err = syscall.GetShortPathName(&p[0], &b[0], uint32(len(b))); err != nil {
|
||||||
if err != nil {
|
|
||||||
return "", err
|
return "", err
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
|
@ -560,6 +560,10 @@ func Benchmark9kTar(b *testing.B) {
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
n, err := io.Copy(buf, fh)
|
n, err := io.Copy(buf, fh)
|
||||||
|
if err != nil {
|
||||||
|
b.Error(err)
|
||||||
|
return
|
||||||
|
}
|
||||||
fh.Close()
|
fh.Close()
|
||||||
|
|
||||||
reader := bytes.NewReader(buf.Bytes())
|
reader := bytes.NewReader(buf.Bytes())
|
||||||
|
@ -586,6 +590,10 @@ func Benchmark9kTarGzip(b *testing.B) {
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
n, err := io.Copy(buf, fh)
|
n, err := io.Copy(buf, fh)
|
||||||
|
if err != nil {
|
||||||
|
b.Error(err)
|
||||||
|
return
|
||||||
|
}
|
||||||
fh.Close()
|
fh.Close()
|
||||||
|
|
||||||
reader := bytes.NewReader(buf.Bytes())
|
reader := bytes.NewReader(buf.Bytes())
|
||||||
|
|
Loading…
Reference in a new issue