syncthing/message.go

127 lines
2.4 KiB
Go
Raw Normal View History

2015-01-13 13:31:14 +01:00
// Copyright (C) 2014 The Protocol Authors.
2014-09-22 21:42:11 +02:00
2015-02-06 22:34:51 +01:00
//go:generate -command genxdr go run ../syncthing/Godeps/_workspace/src/github.com/calmh/xdr/cmd/genxdr/main.go
//go:generate genxdr -o message_xdr.go message.go
2014-09-22 21:42:11 +02:00
package protocol
import "fmt"
type IndexMessage struct {
2015-03-08 17:55:01 +01:00
Folder string
Files []FileInfo
Flags uint32
Options []Option // max:64
2014-09-22 21:42:11 +02:00
}
type FileInfo struct {
Name string // max:8192
Flags uint32
Modified int64
2015-03-20 09:58:32 +01:00
Version Vector
LocalVersion int64
2014-09-22 21:42:11 +02:00
Blocks []BlockInfo
}
func (f FileInfo) String() string {
2015-03-20 09:58:32 +01:00
return fmt.Sprintf("File{Name:%q, Flags:0%o, Modified:%d, Version:%v, Size:%d, Blocks:%v}",
2014-09-22 21:42:11 +02:00
f.Name, f.Flags, f.Modified, f.Version, f.Size(), f.Blocks)
}
func (f FileInfo) Size() (bytes int64) {
2014-11-05 00:22:15 +01:00
if f.IsDeleted() || f.IsDirectory() {
2014-09-22 21:42:11 +02:00
return 128
}
for _, b := range f.Blocks {
bytes += int64(b.Size)
}
return
}
func (f FileInfo) IsDeleted() bool {
2014-11-05 00:22:15 +01:00
return f.Flags&FlagDeleted != 0
2014-09-22 21:42:11 +02:00
}
func (f FileInfo) IsInvalid() bool {
2014-11-05 00:22:15 +01:00
return f.Flags&FlagInvalid != 0
2014-10-06 22:57:33 +02:00
}
func (f FileInfo) IsDirectory() bool {
2014-11-05 00:22:15 +01:00
return f.Flags&FlagDirectory != 0
}
func (f FileInfo) IsSymlink() bool {
return f.Flags&FlagSymlink != 0
}
2014-11-05 00:22:15 +01:00
func (f FileInfo) HasPermissionBits() bool {
return f.Flags&FlagNoPermBits == 0
2014-09-22 21:42:11 +02:00
}
type BlockInfo struct {
Offset int64 // noencode (cache only)
Size int32
2014-09-22 21:42:11 +02:00
Hash []byte // max:64
}
func (b BlockInfo) String() string {
return fmt.Sprintf("Block{%d/%d/%x}", b.Offset, b.Size, b.Hash)
}
type RequestMessage struct {
Folder string // max:64
Name string // max:8192
Offset int64
Size int32
Hash []byte // max:64
Flags uint32
Options []Option // max:64
2014-09-22 21:42:11 +02:00
}
type ResponseMessage struct {
2015-02-06 22:34:51 +01:00
Data []byte
Code int32
2014-09-22 21:42:11 +02:00
}
type ClusterConfigMessage struct {
2015-03-09 21:21:20 +01:00
ClientName string // max:64
ClientVersion string // max:64
2015-03-08 17:55:01 +01:00
Folders []Folder
2014-09-28 13:05:25 +02:00
Options []Option // max:64
2014-09-22 21:42:11 +02:00
}
func (o *ClusterConfigMessage) GetOption(key string) string {
for _, option := range o.Options {
if option.Key == key {
return option.Value
}
}
return ""
}
type Folder struct {
2014-10-20 22:45:26 +02:00
ID string // max:64
Devices []Device
Flags uint32
Options []Option // max:64
2014-09-22 21:42:11 +02:00
}
type Device struct {
2014-09-22 21:42:11 +02:00
ID []byte // max:32
MaxLocalVersion int64
Flags uint32
Options []Option // max:64
2014-09-22 21:42:11 +02:00
}
type Option struct {
Key string // max:64
Value string // max:1024
}
type CloseMessage struct {
Reason string // max:1024
Code int32
2014-09-22 21:42:11 +02:00
}
type EmptyMessage struct{}