build: Enable gometalinter "unconvert" check
This commit is contained in:
parent
744c2e82b5
commit
47f22ff3e5
2
build.go
2
build.go
@ -301,6 +301,7 @@ func runCommand(cmd string, target target) {
|
|||||||
ok = gometalinter("ineffassign", dirs) && ok
|
ok = gometalinter("ineffassign", dirs) && ok
|
||||||
ok = gometalinter("unused", dirs) && ok
|
ok = gometalinter("unused", dirs) && ok
|
||||||
ok = gometalinter("staticcheck", dirs) && ok
|
ok = gometalinter("staticcheck", dirs) && ok
|
||||||
|
ok = gometalinter("unconvert", dirs) && ok
|
||||||
if !ok {
|
if !ok {
|
||||||
os.Exit(1)
|
os.Exit(1)
|
||||||
}
|
}
|
||||||
@ -366,6 +367,7 @@ func setup() {
|
|||||||
"github.com/FiloSottile/gvt",
|
"github.com/FiloSottile/gvt",
|
||||||
"github.com/golang/lint/golint",
|
"github.com/golang/lint/golint",
|
||||||
"github.com/gordonklaus/ineffassign",
|
"github.com/gordonklaus/ineffassign",
|
||||||
|
"github.com/mdempsky/unconvert",
|
||||||
"github.com/mitchellh/go-wordwrap",
|
"github.com/mitchellh/go-wordwrap",
|
||||||
"github.com/opennota/check/cmd/...",
|
"github.com/opennota/check/cmd/...",
|
||||||
"github.com/tsenart/deadcode",
|
"github.com/tsenart/deadcode",
|
||||||
|
|||||||
@ -140,7 +140,7 @@ func parsePort(input string) int {
|
|||||||
if port < 1 || port > 65535 {
|
if port < 1 || port > 65535 {
|
||||||
die(input + " is not a valid port\nExpected value between 1 and 65535")
|
die(input + " is not a valid port\nExpected value between 1 and 65535")
|
||||||
}
|
}
|
||||||
return int(port)
|
return port
|
||||||
}
|
}
|
||||||
|
|
||||||
func validAddress(input string) {
|
func validAddress(input string) {
|
||||||
|
|||||||
@ -66,7 +66,7 @@ func generateFiles(dir string, files, maxexp int, srcname string) error {
|
|||||||
}
|
}
|
||||||
|
|
||||||
func generateOneFile(fd io.ReadSeeker, p1 string, s int64) error {
|
func generateOneFile(fd io.ReadSeeker, p1 string, s int64) error {
|
||||||
src := io.LimitReader(&inifiteReader{fd}, int64(s))
|
src := io.LimitReader(&inifiteReader{fd}, s)
|
||||||
dst, err := os.Create(p1)
|
dst, err := os.Create(p1)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return err
|
return err
|
||||||
|
|||||||
@ -249,13 +249,13 @@ func handleRequest(w http.ResponseWriter, r *http.Request) {
|
|||||||
w.Header().Set("Access-Control-Allow-Origin", "*")
|
w.Header().Set("Access-Control-Allow-Origin", "*")
|
||||||
switch r.Method {
|
switch r.Method {
|
||||||
case "GET":
|
case "GET":
|
||||||
if limit(r.RemoteAddr, getLRUCache, getMut, getLimit, int64(getLimitBurst)) {
|
if limit(r.RemoteAddr, getLRUCache, getMut, getLimit, getLimitBurst) {
|
||||||
w.WriteHeader(429)
|
w.WriteHeader(429)
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
handleGetRequest(w, r)
|
handleGetRequest(w, r)
|
||||||
case "POST":
|
case "POST":
|
||||||
if limit(r.RemoteAddr, postLRUCache, postMut, postLimit, int64(postLimitBurst)) {
|
if limit(r.RemoteAddr, postLRUCache, postMut, postLimit, postLimitBurst) {
|
||||||
w.WriteHeader(429)
|
w.WriteHeader(429)
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|||||||
@ -216,7 +216,7 @@ done:
|
|||||||
func (s *session) GetClientInvitationMessage() protocol.SessionInvitation {
|
func (s *session) GetClientInvitationMessage() protocol.SessionInvitation {
|
||||||
return protocol.SessionInvitation{
|
return protocol.SessionInvitation{
|
||||||
From: s.serverid[:],
|
From: s.serverid[:],
|
||||||
Key: []byte(s.clientkey),
|
Key: s.clientkey,
|
||||||
Address: sessionAddress,
|
Address: sessionAddress,
|
||||||
Port: sessionPort,
|
Port: sessionPort,
|
||||||
ServerSocket: false,
|
ServerSocket: false,
|
||||||
@ -226,7 +226,7 @@ func (s *session) GetClientInvitationMessage() protocol.SessionInvitation {
|
|||||||
func (s *session) GetServerInvitationMessage() protocol.SessionInvitation {
|
func (s *session) GetServerInvitationMessage() protocol.SessionInvitation {
|
||||||
return protocol.SessionInvitation{
|
return protocol.SessionInvitation{
|
||||||
From: s.clientid[:],
|
From: s.clientid[:],
|
||||||
Key: []byte(s.serverkey),
|
Key: s.serverkey,
|
||||||
Address: sessionAddress,
|
Address: sessionAddress,
|
||||||
Port: sessionPort,
|
Port: sessionPort,
|
||||||
ServerSocket: true,
|
ServerSocket: true,
|
||||||
|
|||||||
@ -1070,7 +1070,7 @@ func getFreePort(host string, ports ...int) (int, error) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
func standbyMonitor() {
|
func standbyMonitor() {
|
||||||
restartDelay := time.Duration(60 * time.Second)
|
restartDelay := 60 * time.Second
|
||||||
now := time.Now()
|
now := time.Now()
|
||||||
for {
|
for {
|
||||||
time.Sleep(10 * time.Second)
|
time.Sleep(10 * time.Second)
|
||||||
|
|||||||
@ -209,7 +209,7 @@ func blockKeyInto(o, hash []byte, folder uint32, file string) []byte {
|
|||||||
}
|
}
|
||||||
o[0] = KeyTypeBlock
|
o[0] = KeyTypeBlock
|
||||||
binary.BigEndian.PutUint32(o[keyPrefixLen:], folder)
|
binary.BigEndian.PutUint32(o[keyPrefixLen:], folder)
|
||||||
copy(o[keyPrefixLen+keyFolderLen:], []byte(hash))
|
copy(o[keyPrefixLen+keyFolderLen:], hash)
|
||||||
copy(o[keyPrefixLen+keyFolderLen+keyHashLen:], []byte(file))
|
copy(o[keyPrefixLen+keyFolderLen+keyHashLen:], []byte(file))
|
||||||
return o
|
return o
|
||||||
}
|
}
|
||||||
|
|||||||
@ -635,7 +635,7 @@ func (db *Instance) deviceKeyInto(k []byte, folder, device, file []byte) []byte
|
|||||||
k[0] = KeyTypeDevice
|
k[0] = KeyTypeDevice
|
||||||
binary.BigEndian.PutUint32(k[keyPrefixLen:], db.folderIdx.ID(folder))
|
binary.BigEndian.PutUint32(k[keyPrefixLen:], db.folderIdx.ID(folder))
|
||||||
binary.BigEndian.PutUint32(k[keyPrefixLen+keyFolderLen:], db.deviceIdx.ID(device))
|
binary.BigEndian.PutUint32(k[keyPrefixLen+keyFolderLen:], db.deviceIdx.ID(device))
|
||||||
copy(k[keyPrefixLen+keyFolderLen+keyDeviceLen:], []byte(file))
|
copy(k[keyPrefixLen+keyFolderLen+keyDeviceLen:], file)
|
||||||
return k[:reqLen]
|
return k[:reqLen]
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -670,7 +670,7 @@ func (db *Instance) globalKey(folder, file []byte) []byte {
|
|||||||
k := make([]byte, keyPrefixLen+keyFolderLen+len(file))
|
k := make([]byte, keyPrefixLen+keyFolderLen+len(file))
|
||||||
k[0] = KeyTypeGlobal
|
k[0] = KeyTypeGlobal
|
||||||
binary.BigEndian.PutUint32(k[keyPrefixLen:], db.folderIdx.ID(folder))
|
binary.BigEndian.PutUint32(k[keyPrefixLen:], db.folderIdx.ID(folder))
|
||||||
copy(k[keyPrefixLen+keyFolderLen:], []byte(file))
|
copy(k[keyPrefixLen+keyFolderLen:], file)
|
||||||
return k
|
return k
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@ -522,7 +522,7 @@ func (c *rawConnection) handleRequest(req Request) {
|
|||||||
buf = make([]byte, size)
|
buf = make([]byte, size)
|
||||||
}
|
}
|
||||||
|
|
||||||
err := c.receiver.Request(c.id, req.Folder, req.Name, int64(req.Offset), req.Hash, req.FromTemporary, buf)
|
err := c.receiver.Request(c.id, req.Folder, req.Name, req.Offset, req.Hash, req.FromTemporary, buf)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
c.send(&Response{
|
c.send(&Response{
|
||||||
ID: req.ID,
|
ID: req.ID,
|
||||||
|
|||||||
@ -56,7 +56,7 @@ func Blocks(r io.Reader, blocksize int, sizehint int64, counter Counter) ([]prot
|
|||||||
}
|
}
|
||||||
|
|
||||||
if counter != nil {
|
if counter != nil {
|
||||||
counter.Update(int64(n))
|
counter.Update(n)
|
||||||
}
|
}
|
||||||
|
|
||||||
// Carve out a hash-sized chunk of "hashes" to store the hash for this
|
// Carve out a hash-sized chunk of "hashes" to store the hash for this
|
||||||
@ -72,7 +72,7 @@ func Blocks(r io.Reader, blocksize int, sizehint int64, counter Counter) ([]prot
|
|||||||
}
|
}
|
||||||
|
|
||||||
blocks = append(blocks, b)
|
blocks = append(blocks, b)
|
||||||
offset += int64(n)
|
offset += n
|
||||||
|
|
||||||
hf.Reset()
|
hf.Reset()
|
||||||
whf.Reset()
|
whf.Reset()
|
||||||
|
|||||||
@ -163,7 +163,7 @@ func (w *walker) walk() (chan protocol.FileInfo, error) {
|
|||||||
|
|
||||||
for file := range toHashChan {
|
for file := range toHashChan {
|
||||||
filesToHash = append(filesToHash, file)
|
filesToHash = append(filesToHash, file)
|
||||||
total += int64(file.Size)
|
total += file.Size
|
||||||
}
|
}
|
||||||
|
|
||||||
realToHashChan := make(chan protocol.FileInfo)
|
realToHashChan := make(chan protocol.FileInfo)
|
||||||
|
|||||||
@ -17,7 +17,7 @@ import (
|
|||||||
)
|
)
|
||||||
|
|
||||||
var (
|
var (
|
||||||
threshold = time.Duration(100 * time.Millisecond)
|
threshold = 100 * time.Millisecond
|
||||||
l = logger.DefaultLogger.NewFacility("sync", "Mutexes")
|
l = logger.DefaultLogger.NewFacility("sync", "Mutexes")
|
||||||
|
|
||||||
// We make an exception in this package and have an actual "if debug { ...
|
// We make an exception in this package and have an actual "if debug { ...
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user