mirror of
https://github.com/octoleo/syncthing.git
synced 2024-12-22 19:08:58 +00:00
c6334e61aa
This adds the ability to have multiple concurrent connections to a single device. This is primarily useful when the network has multiple physical links for aggregated bandwidth. A single connection will never see a higher rate than a single link can give, but multiple connections are load-balanced over multiple links. It is also incidentally useful for older multi-core CPUs, where bandwidth could be limited by the TLS performance of a single CPU core -- using multiple connections achieves concurrency in the required crypto calculations... Co-authored-by: Simon Frei <freisim93@gmail.com> Co-authored-by: tomasz1986 <twilczynski@naver.com> Co-authored-by: bt90 <btom1990@googlemail.com>
80 lines
1.9 KiB
Go
80 lines
1.9 KiB
Go
// Copyright (C) 2014 The Protocol Authors.
|
|
|
|
//go:build windows
|
|
// +build windows
|
|
|
|
package protocol
|
|
|
|
// Windows uses backslashes as file separator
|
|
|
|
import (
|
|
"fmt"
|
|
"path/filepath"
|
|
"strings"
|
|
)
|
|
|
|
func makeNative(m rawModel) rawModel { return nativeModel{m} }
|
|
|
|
type nativeModel struct {
|
|
rawModel
|
|
}
|
|
|
|
func (m nativeModel) Index(folder string, files []FileInfo) error {
|
|
files = fixupFiles(files)
|
|
return m.rawModel.Index(folder, files)
|
|
}
|
|
|
|
func (m nativeModel) IndexUpdate(folder string, files []FileInfo) error {
|
|
files = fixupFiles(files)
|
|
return m.rawModel.IndexUpdate(folder, files)
|
|
}
|
|
|
|
func (m nativeModel) Request(folder, name string, blockNo, size int32, offset int64, hash []byte, weakHash uint32, fromTemporary bool) (RequestResponse, error) {
|
|
if strings.Contains(name, `\`) {
|
|
l.Warnf("Dropping request for %s, contains invalid path separator", name)
|
|
return nil, ErrNoSuchFile
|
|
}
|
|
|
|
name = filepath.FromSlash(name)
|
|
return m.rawModel.Request(folder, name, blockNo, size, offset, hash, weakHash, fromTemporary)
|
|
}
|
|
|
|
func fixupFiles(files []FileInfo) []FileInfo {
|
|
var out []FileInfo
|
|
for i := range files {
|
|
if strings.Contains(files[i].Name, `\`) {
|
|
msg := fmt.Sprintf("Dropping index entry for %s, contains invalid path separator", files[i].Name)
|
|
if files[i].Deleted {
|
|
// Dropping a deleted item doesn't have any consequences.
|
|
l.Debugln(msg)
|
|
} else {
|
|
l.Warnln(msg)
|
|
}
|
|
if out == nil {
|
|
// Most incoming updates won't contain anything invalid, so
|
|
// we delay the allocation and copy to output slice until we
|
|
// really need to do it, then copy all the so-far valid
|
|
// files to it.
|
|
out = make([]FileInfo, i, len(files)-1)
|
|
copy(out, files)
|
|
}
|
|
continue
|
|
}
|
|
|
|
// Fixup the path separators
|
|
files[i].Name = filepath.FromSlash(files[i].Name)
|
|
|
|
if out != nil {
|
|
out = append(out, files[i])
|
|
}
|
|
}
|
|
|
|
if out != nil {
|
|
// We did some filtering
|
|
return out
|
|
}
|
|
|
|
// Unchanged
|
|
return files
|
|
}
|