mirror of
https://github.com/octoleo/syncthing.git
synced 2025-01-05 08:02:13 +00:00
This commit is contained in:
parent
fbd445fe0a
commit
dfbbb286fc
@ -76,3 +76,19 @@ func rel(path, prefix string) string {
|
|||||||
}
|
}
|
||||||
|
|
||||||
var evalSymlinks = filepath.EvalSymlinks
|
var evalSymlinks = filepath.EvalSymlinks
|
||||||
|
|
||||||
|
// watchPaths adjust the folder root for use with the notify backend and the
|
||||||
|
// corresponding absolute path to be passed to notify to watch name.
|
||||||
|
func (f *BasicFilesystem) watchPaths(name string) (string, string, error) {
|
||||||
|
root, err := evalSymlinks(f.root)
|
||||||
|
if err != nil {
|
||||||
|
return "", "", err
|
||||||
|
}
|
||||||
|
|
||||||
|
absName, err := rooted(name, root)
|
||||||
|
if err != nil {
|
||||||
|
return "", "", err
|
||||||
|
}
|
||||||
|
|
||||||
|
return filepath.Join(absName, "..."), root, nil
|
||||||
|
}
|
||||||
|
@ -11,8 +11,6 @@ package fs
|
|||||||
import (
|
import (
|
||||||
"context"
|
"context"
|
||||||
"errors"
|
"errors"
|
||||||
"path/filepath"
|
|
||||||
"runtime"
|
|
||||||
|
|
||||||
"github.com/syncthing/notify"
|
"github.com/syncthing/notify"
|
||||||
)
|
)
|
||||||
@ -57,28 +55,6 @@ func (f *BasicFilesystem) Watch(name string, ignore Matcher, ctx context.Context
|
|||||||
return outChan, nil
|
return outChan, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
// watchPaths adjust the folder root for use with the notify backend and the
|
|
||||||
// corresponding absolute path to be passed to notify to watch name.
|
|
||||||
func (f *BasicFilesystem) watchPaths(name string) (string, string, error) {
|
|
||||||
root, err := evalSymlinks(f.root)
|
|
||||||
if err != nil {
|
|
||||||
return "", "", err
|
|
||||||
}
|
|
||||||
|
|
||||||
// Remove `\\?\` prefix if the path is just a drive letter as a dirty
|
|
||||||
// fix for https://github.com/syncthing/syncthing/issues/5578
|
|
||||||
if runtime.GOOS == "windows" && filepath.Clean(name) == "." && len(root) <= 7 && len(root) > 4 && root[:4] == `\\?\` {
|
|
||||||
root = root[4:]
|
|
||||||
}
|
|
||||||
|
|
||||||
absName, err := rooted(name, root)
|
|
||||||
if err != nil {
|
|
||||||
return "", "", err
|
|
||||||
}
|
|
||||||
|
|
||||||
return filepath.Join(absName, "..."), root, nil
|
|
||||||
}
|
|
||||||
|
|
||||||
func (f *BasicFilesystem) watchLoop(name, evalRoot string, backendChan chan notify.EventInfo, outChan chan<- Event, ignore Matcher, ctx context.Context) {
|
func (f *BasicFilesystem) watchLoop(name, evalRoot string, backendChan chan notify.EventInfo, outChan chan<- Event, ignore Matcher, ctx context.Context) {
|
||||||
for {
|
for {
|
||||||
// Detect channel overflow
|
// Detect channel overflow
|
||||||
|
@ -222,3 +222,28 @@ func evalSymlinks(in string) (string, error) {
|
|||||||
}
|
}
|
||||||
return longFilenameSupport(out), nil
|
return longFilenameSupport(out), nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// watchPaths adjust the folder root for use with the notify backend and the
|
||||||
|
// corresponding absolute path to be passed to notify to watch name.
|
||||||
|
func (f *BasicFilesystem) watchPaths(name string) (string, string, error) {
|
||||||
|
root, err := evalSymlinks(f.root)
|
||||||
|
if err != nil {
|
||||||
|
return "", "", err
|
||||||
|
}
|
||||||
|
|
||||||
|
// Remove `\\?\` prefix if the path is just a drive letter as a dirty
|
||||||
|
// fix for https://github.com/syncthing/syncthing/issues/5578
|
||||||
|
if filepath.Clean(name) == "." && len(root) <= 7 && len(root) > 4 && root[:4] == `\\?\` {
|
||||||
|
root = root[4:]
|
||||||
|
}
|
||||||
|
|
||||||
|
absName, err := rooted(name, root)
|
||||||
|
if err != nil {
|
||||||
|
return "", "", err
|
||||||
|
}
|
||||||
|
|
||||||
|
root = f.resolveWin83(root)
|
||||||
|
absName = f.resolveWin83(absName)
|
||||||
|
|
||||||
|
return filepath.Join(absName, "..."), root, nil
|
||||||
|
}
|
||||||
|
@ -44,6 +44,10 @@ func TestWindowsPaths(t *testing.T) {
|
|||||||
|
|
||||||
func TestResolveWindows83(t *testing.T) {
|
func TestResolveWindows83(t *testing.T) {
|
||||||
fs, dir := setup(t)
|
fs, dir := setup(t)
|
||||||
|
if isMaybeWin83(dir) {
|
||||||
|
dir = fs.resolveWin83(dir)
|
||||||
|
fs = newBasicFilesystem(dir)
|
||||||
|
}
|
||||||
defer os.RemoveAll(dir)
|
defer os.RemoveAll(dir)
|
||||||
|
|
||||||
shortAbs, _ := fs.rooted("LFDATA~1")
|
shortAbs, _ := fs.rooted("LFDATA~1")
|
||||||
@ -71,6 +75,10 @@ func TestResolveWindows83(t *testing.T) {
|
|||||||
|
|
||||||
func TestIsWindows83(t *testing.T) {
|
func TestIsWindows83(t *testing.T) {
|
||||||
fs, dir := setup(t)
|
fs, dir := setup(t)
|
||||||
|
if isMaybeWin83(dir) {
|
||||||
|
dir = fs.resolveWin83(dir)
|
||||||
|
fs = newBasicFilesystem(dir)
|
||||||
|
}
|
||||||
defer os.RemoveAll(dir)
|
defer os.RemoveAll(dir)
|
||||||
|
|
||||||
tempTop, _ := fs.rooted(TempName("baz"))
|
tempTop, _ := fs.rooted(TempName("baz"))
|
||||||
|
Loading…
Reference in New Issue
Block a user