Rename FolderConfiguration.Directory to FolderConfiguration.Path
This commit is contained in:
@@ -34,7 +34,7 @@ type Configuration struct {
|
||||
|
||||
type FolderConfiguration struct {
|
||||
ID string `xml:"id,attr"`
|
||||
Directory string `xml:"directory,attr"`
|
||||
Path string `xml:"path,attr"`
|
||||
Devices []FolderDeviceConfiguration `xml:"device"`
|
||||
ReadOnly bool `xml:"ro,attr"`
|
||||
RescanIntervalS int `xml:"rescanIntervalS,attr" default:"60"`
|
||||
@@ -306,7 +306,7 @@ func (cfg *Configuration) prepare(myID protocol.DeviceID) {
|
||||
for i := range cfg.Folders {
|
||||
folder := &cfg.Folders[i]
|
||||
|
||||
if len(folder.Directory) == 0 {
|
||||
if len(folder.Path) == 0 {
|
||||
folder.Invalid = "no directory configured"
|
||||
continue
|
||||
}
|
||||
|
||||
@@ -56,7 +56,7 @@ func TestDeviceConfig(t *testing.T) {
|
||||
expectedFolders := []FolderConfiguration{
|
||||
{
|
||||
ID: "test",
|
||||
Directory: "~/Sync",
|
||||
Path: "~/Sync",
|
||||
Devices: []FolderDeviceConfiguration{{DeviceID: device1}, {DeviceID: device4}},
|
||||
ReadOnly: true,
|
||||
RescanIntervalS: 600,
|
||||
|
||||
@@ -150,7 +150,7 @@ func (m *Model) StartFolderRW(folder string) {
|
||||
|
||||
p := Puller{
|
||||
folder: folder,
|
||||
dir: cfg.Directory,
|
||||
dir: cfg.Path,
|
||||
scanIntv: time.Duration(cfg.RescanIntervalS) * time.Second,
|
||||
model: m,
|
||||
}
|
||||
@@ -160,7 +160,7 @@ func (m *Model) StartFolderRW(folder string) {
|
||||
if !ok {
|
||||
l.Fatalf("Requested versioning type %q that does not exist", cfg.Versioning.Type)
|
||||
}
|
||||
p.versioner = factory(folder, cfg.Directory, cfg.Versioning.Params)
|
||||
p.versioner = factory(folder, cfg.Path, cfg.Versioning.Params)
|
||||
}
|
||||
|
||||
go p.Serve()
|
||||
@@ -623,7 +623,7 @@ func (m *Model) Request(deviceID protocol.DeviceID, folder, name string, offset
|
||||
l.Debugf("%v REQ(in): %s: %q / %q o=%d s=%d", m, deviceID, folder, name, offset, size)
|
||||
}
|
||||
m.fmut.RLock()
|
||||
fn := filepath.Join(m.folderCfgs[folder].Directory, name)
|
||||
fn := filepath.Join(m.folderCfgs[folder].Path, name)
|
||||
m.fmut.RUnlock()
|
||||
fd, err := os.Open(fn) // XXX: Inefficient, should cache fd?
|
||||
if err != nil {
|
||||
@@ -693,7 +693,7 @@ func (m *Model) GetIgnores(folder string) ([]string, error) {
|
||||
m.fmut.Lock()
|
||||
defer m.fmut.Unlock()
|
||||
|
||||
fd, err := os.Open(filepath.Join(cfg.Directory, ".stignore"))
|
||||
fd, err := os.Open(filepath.Join(cfg.Path, ".stignore"))
|
||||
if err != nil {
|
||||
if os.IsNotExist(err) {
|
||||
return lines, nil
|
||||
@@ -717,7 +717,7 @@ func (m *Model) SetIgnores(folder string, content []string) error {
|
||||
return fmt.Errorf("Folder %s does not exist", folder)
|
||||
}
|
||||
|
||||
fd, err := ioutil.TempFile(cfg.Directory, ".syncthing.stignore-"+folder)
|
||||
fd, err := ioutil.TempFile(cfg.Path, ".syncthing.stignore-"+folder)
|
||||
if err != nil {
|
||||
l.Warnln("Saving .stignore:", err)
|
||||
return err
|
||||
@@ -738,7 +738,7 @@ func (m *Model) SetIgnores(folder string, content []string) error {
|
||||
return err
|
||||
}
|
||||
|
||||
file := filepath.Join(cfg.Directory, ".stignore")
|
||||
file := filepath.Join(cfg.Path, ".stignore")
|
||||
err = osutil.Rename(fd.Name(), file)
|
||||
if err != nil {
|
||||
l.Warnln("Saving .stignore:", err)
|
||||
@@ -963,7 +963,7 @@ func (m *Model) CleanFolders() {
|
||||
m.fmut.RLock()
|
||||
var dirs = make([]string, 0, len(m.folderCfgs))
|
||||
for _, cfg := range m.folderCfgs {
|
||||
dirs = append(dirs, cfg.Directory)
|
||||
dirs = append(dirs, cfg.Path)
|
||||
}
|
||||
m.fmut.RUnlock()
|
||||
|
||||
@@ -993,7 +993,7 @@ func (m *Model) ScanFolderSub(folder, sub string) error {
|
||||
|
||||
m.fmut.RLock()
|
||||
fs, ok := m.folderFiles[folder]
|
||||
dir := m.folderCfgs[folder].Directory
|
||||
dir := m.folderCfgs[folder].Path
|
||||
|
||||
ignores, _ := ignore.Load(filepath.Join(dir, ".stignore"))
|
||||
m.folderIgnores[folder] = ignores
|
||||
|
||||
@@ -58,7 +58,7 @@ func init() {
|
||||
func TestRequest(t *testing.T) {
|
||||
db, _ := leveldb.Open(storage.NewMemStorage(), nil)
|
||||
m := NewModel("/tmp", &config.Configuration{}, "device", "syncthing", "dev", db)
|
||||
m.AddFolder(config.FolderConfiguration{ID: "default", Directory: "testdata"})
|
||||
m.AddFolder(config.FolderConfiguration{ID: "default", Path: "testdata"})
|
||||
m.ScanFolder("default")
|
||||
|
||||
bs, err := m.Request(device1, "default", "foo", 0, 6)
|
||||
@@ -95,7 +95,7 @@ func genFiles(n int) []protocol.FileInfo {
|
||||
func BenchmarkIndex10000(b *testing.B) {
|
||||
db, _ := leveldb.Open(storage.NewMemStorage(), nil)
|
||||
m := NewModel("/tmp", nil, "device", "syncthing", "dev", db)
|
||||
m.AddFolder(config.FolderConfiguration{ID: "default", Directory: "testdata"})
|
||||
m.AddFolder(config.FolderConfiguration{ID: "default", Path: "testdata"})
|
||||
m.ScanFolder("default")
|
||||
files := genFiles(10000)
|
||||
|
||||
@@ -108,7 +108,7 @@ func BenchmarkIndex10000(b *testing.B) {
|
||||
func BenchmarkIndex00100(b *testing.B) {
|
||||
db, _ := leveldb.Open(storage.NewMemStorage(), nil)
|
||||
m := NewModel("/tmp", nil, "device", "syncthing", "dev", db)
|
||||
m.AddFolder(config.FolderConfiguration{ID: "default", Directory: "testdata"})
|
||||
m.AddFolder(config.FolderConfiguration{ID: "default", Path: "testdata"})
|
||||
m.ScanFolder("default")
|
||||
files := genFiles(100)
|
||||
|
||||
@@ -121,7 +121,7 @@ func BenchmarkIndex00100(b *testing.B) {
|
||||
func BenchmarkIndexUpdate10000f10000(b *testing.B) {
|
||||
db, _ := leveldb.Open(storage.NewMemStorage(), nil)
|
||||
m := NewModel("/tmp", nil, "device", "syncthing", "dev", db)
|
||||
m.AddFolder(config.FolderConfiguration{ID: "default", Directory: "testdata"})
|
||||
m.AddFolder(config.FolderConfiguration{ID: "default", Path: "testdata"})
|
||||
m.ScanFolder("default")
|
||||
files := genFiles(10000)
|
||||
m.Index(device1, "default", files)
|
||||
@@ -135,7 +135,7 @@ func BenchmarkIndexUpdate10000f10000(b *testing.B) {
|
||||
func BenchmarkIndexUpdate10000f00100(b *testing.B) {
|
||||
db, _ := leveldb.Open(storage.NewMemStorage(), nil)
|
||||
m := NewModel("/tmp", nil, "device", "syncthing", "dev", db)
|
||||
m.AddFolder(config.FolderConfiguration{ID: "default", Directory: "testdata"})
|
||||
m.AddFolder(config.FolderConfiguration{ID: "default", Path: "testdata"})
|
||||
m.ScanFolder("default")
|
||||
files := genFiles(10000)
|
||||
m.Index(device1, "default", files)
|
||||
@@ -150,7 +150,7 @@ func BenchmarkIndexUpdate10000f00100(b *testing.B) {
|
||||
func BenchmarkIndexUpdate10000f00001(b *testing.B) {
|
||||
db, _ := leveldb.Open(storage.NewMemStorage(), nil)
|
||||
m := NewModel("/tmp", nil, "device", "syncthing", "dev", db)
|
||||
m.AddFolder(config.FolderConfiguration{ID: "default", Directory: "testdata"})
|
||||
m.AddFolder(config.FolderConfiguration{ID: "default", Path: "testdata"})
|
||||
m.ScanFolder("default")
|
||||
files := genFiles(10000)
|
||||
m.Index(device1, "default", files)
|
||||
@@ -208,7 +208,7 @@ func (FakeConnection) Statistics() protocol.Statistics {
|
||||
func BenchmarkRequest(b *testing.B) {
|
||||
db, _ := leveldb.Open(storage.NewMemStorage(), nil)
|
||||
m := NewModel("/tmp", nil, "device", "syncthing", "dev", db)
|
||||
m.AddFolder(config.FolderConfiguration{ID: "default", Directory: "testdata"})
|
||||
m.AddFolder(config.FolderConfiguration{ID: "default", Path: "testdata"})
|
||||
m.ScanFolder("default")
|
||||
|
||||
const n = 1000
|
||||
@@ -380,7 +380,7 @@ func TestIgnores(t *testing.T) {
|
||||
|
||||
db, _ := leveldb.Open(storage.NewMemStorage(), nil)
|
||||
m := NewModel("/tmp", nil, "device", "syncthing", "dev", db)
|
||||
m.AddFolder(config.FolderConfiguration{ID: "default", Directory: "testdata"})
|
||||
m.AddFolder(config.FolderConfiguration{ID: "default", Path: "testdata"})
|
||||
|
||||
expected := []string{
|
||||
".*",
|
||||
@@ -440,7 +440,7 @@ func TestIgnores(t *testing.T) {
|
||||
t.Error("No error")
|
||||
}
|
||||
|
||||
m.AddFolder(config.FolderConfiguration{ID: "fresh", Directory: "XXX"})
|
||||
m.AddFolder(config.FolderConfiguration{ID: "fresh", Path: "XXX"})
|
||||
ignores, err = m.GetIgnores("fresh")
|
||||
if err != nil {
|
||||
t.Error(err)
|
||||
|
||||
Reference in New Issue
Block a user