mirror of
https://github.com/octoleo/syncthing.git
synced 2024-12-23 03:18:59 +00:00
ab0eb909a2
* lib/connections: Cache isLAN decision for later external access. The check whether a remote device's address is on a local network currently happens when handling the Hello message, to configure the limiters. Save the result to the ConnectionInfo and pass it out as part of the model's ConnectionInfo struct in ConnectionStats(). * gui: Use provided connection attribute to distinguish LAN / WAN. Replace the dumb IP address check which didn't catch common cases and actually could contradict what the backend decided. That could have been confusing if the GUI says WAN, but the limiter is not actually applied because the backend thinks it's a LAN. Add strings for QUIC and relay connections to also differentiate between LAN and WAN. * gui: Redefine reception level icons for all connection types. Move the mapping to the JS code, as it is much easier to handle multiple switch cases by fall-through there. QUIC is regarded no less than TCP anymore. LAN and WAN make the difference between levels 4 / 3 and 2 / 1: {TCP,QUIC} LAN --> {TCP,QUIC} WAN --> Relay LAN --> Relay WAN --> Disconnected.
556 lines
14 KiB
Go
556 lines
14 KiB
Go
// Code generated by counterfeiter. DO NOT EDIT.
|
|
package protocol
|
|
|
|
import (
|
|
"net"
|
|
"sync"
|
|
"time"
|
|
)
|
|
|
|
type mockedConnectionInfo struct {
|
|
CryptoStub func() string
|
|
cryptoMutex sync.RWMutex
|
|
cryptoArgsForCall []struct {
|
|
}
|
|
cryptoReturns struct {
|
|
result1 string
|
|
}
|
|
cryptoReturnsOnCall map[int]struct {
|
|
result1 string
|
|
}
|
|
EstablishedAtStub func() time.Time
|
|
establishedAtMutex sync.RWMutex
|
|
establishedAtArgsForCall []struct {
|
|
}
|
|
establishedAtReturns struct {
|
|
result1 time.Time
|
|
}
|
|
establishedAtReturnsOnCall map[int]struct {
|
|
result1 time.Time
|
|
}
|
|
IsLocalStub func() bool
|
|
isLocalMutex sync.RWMutex
|
|
isLocalArgsForCall []struct {
|
|
}
|
|
isLocalReturns struct {
|
|
result1 bool
|
|
}
|
|
isLocalReturnsOnCall map[int]struct {
|
|
result1 bool
|
|
}
|
|
PriorityStub func() int
|
|
priorityMutex sync.RWMutex
|
|
priorityArgsForCall []struct {
|
|
}
|
|
priorityReturns struct {
|
|
result1 int
|
|
}
|
|
priorityReturnsOnCall map[int]struct {
|
|
result1 int
|
|
}
|
|
RemoteAddrStub func() net.Addr
|
|
remoteAddrMutex sync.RWMutex
|
|
remoteAddrArgsForCall []struct {
|
|
}
|
|
remoteAddrReturns struct {
|
|
result1 net.Addr
|
|
}
|
|
remoteAddrReturnsOnCall map[int]struct {
|
|
result1 net.Addr
|
|
}
|
|
StringStub func() string
|
|
stringMutex sync.RWMutex
|
|
stringArgsForCall []struct {
|
|
}
|
|
stringReturns struct {
|
|
result1 string
|
|
}
|
|
stringReturnsOnCall map[int]struct {
|
|
result1 string
|
|
}
|
|
TransportStub func() string
|
|
transportMutex sync.RWMutex
|
|
transportArgsForCall []struct {
|
|
}
|
|
transportReturns struct {
|
|
result1 string
|
|
}
|
|
transportReturnsOnCall map[int]struct {
|
|
result1 string
|
|
}
|
|
TypeStub func() string
|
|
typeMutex sync.RWMutex
|
|
typeArgsForCall []struct {
|
|
}
|
|
typeReturns struct {
|
|
result1 string
|
|
}
|
|
typeReturnsOnCall map[int]struct {
|
|
result1 string
|
|
}
|
|
invocations map[string][][]interface{}
|
|
invocationsMutex sync.RWMutex
|
|
}
|
|
|
|
func (fake *mockedConnectionInfo) Crypto() string {
|
|
fake.cryptoMutex.Lock()
|
|
ret, specificReturn := fake.cryptoReturnsOnCall[len(fake.cryptoArgsForCall)]
|
|
fake.cryptoArgsForCall = append(fake.cryptoArgsForCall, struct {
|
|
}{})
|
|
stub := fake.CryptoStub
|
|
fakeReturns := fake.cryptoReturns
|
|
fake.recordInvocation("Crypto", []interface{}{})
|
|
fake.cryptoMutex.Unlock()
|
|
if stub != nil {
|
|
return stub()
|
|
}
|
|
if specificReturn {
|
|
return ret.result1
|
|
}
|
|
return fakeReturns.result1
|
|
}
|
|
|
|
func (fake *mockedConnectionInfo) CryptoCallCount() int {
|
|
fake.cryptoMutex.RLock()
|
|
defer fake.cryptoMutex.RUnlock()
|
|
return len(fake.cryptoArgsForCall)
|
|
}
|
|
|
|
func (fake *mockedConnectionInfo) CryptoCalls(stub func() string) {
|
|
fake.cryptoMutex.Lock()
|
|
defer fake.cryptoMutex.Unlock()
|
|
fake.CryptoStub = stub
|
|
}
|
|
|
|
func (fake *mockedConnectionInfo) CryptoReturns(result1 string) {
|
|
fake.cryptoMutex.Lock()
|
|
defer fake.cryptoMutex.Unlock()
|
|
fake.CryptoStub = nil
|
|
fake.cryptoReturns = struct {
|
|
result1 string
|
|
}{result1}
|
|
}
|
|
|
|
func (fake *mockedConnectionInfo) CryptoReturnsOnCall(i int, result1 string) {
|
|
fake.cryptoMutex.Lock()
|
|
defer fake.cryptoMutex.Unlock()
|
|
fake.CryptoStub = nil
|
|
if fake.cryptoReturnsOnCall == nil {
|
|
fake.cryptoReturnsOnCall = make(map[int]struct {
|
|
result1 string
|
|
})
|
|
}
|
|
fake.cryptoReturnsOnCall[i] = struct {
|
|
result1 string
|
|
}{result1}
|
|
}
|
|
|
|
func (fake *mockedConnectionInfo) EstablishedAt() time.Time {
|
|
fake.establishedAtMutex.Lock()
|
|
ret, specificReturn := fake.establishedAtReturnsOnCall[len(fake.establishedAtArgsForCall)]
|
|
fake.establishedAtArgsForCall = append(fake.establishedAtArgsForCall, struct {
|
|
}{})
|
|
stub := fake.EstablishedAtStub
|
|
fakeReturns := fake.establishedAtReturns
|
|
fake.recordInvocation("EstablishedAt", []interface{}{})
|
|
fake.establishedAtMutex.Unlock()
|
|
if stub != nil {
|
|
return stub()
|
|
}
|
|
if specificReturn {
|
|
return ret.result1
|
|
}
|
|
return fakeReturns.result1
|
|
}
|
|
|
|
func (fake *mockedConnectionInfo) EstablishedAtCallCount() int {
|
|
fake.establishedAtMutex.RLock()
|
|
defer fake.establishedAtMutex.RUnlock()
|
|
return len(fake.establishedAtArgsForCall)
|
|
}
|
|
|
|
func (fake *mockedConnectionInfo) EstablishedAtCalls(stub func() time.Time) {
|
|
fake.establishedAtMutex.Lock()
|
|
defer fake.establishedAtMutex.Unlock()
|
|
fake.EstablishedAtStub = stub
|
|
}
|
|
|
|
func (fake *mockedConnectionInfo) EstablishedAtReturns(result1 time.Time) {
|
|
fake.establishedAtMutex.Lock()
|
|
defer fake.establishedAtMutex.Unlock()
|
|
fake.EstablishedAtStub = nil
|
|
fake.establishedAtReturns = struct {
|
|
result1 time.Time
|
|
}{result1}
|
|
}
|
|
|
|
func (fake *mockedConnectionInfo) EstablishedAtReturnsOnCall(i int, result1 time.Time) {
|
|
fake.establishedAtMutex.Lock()
|
|
defer fake.establishedAtMutex.Unlock()
|
|
fake.EstablishedAtStub = nil
|
|
if fake.establishedAtReturnsOnCall == nil {
|
|
fake.establishedAtReturnsOnCall = make(map[int]struct {
|
|
result1 time.Time
|
|
})
|
|
}
|
|
fake.establishedAtReturnsOnCall[i] = struct {
|
|
result1 time.Time
|
|
}{result1}
|
|
}
|
|
|
|
func (fake *mockedConnectionInfo) IsLocal() bool {
|
|
fake.isLocalMutex.Lock()
|
|
ret, specificReturn := fake.isLocalReturnsOnCall[len(fake.isLocalArgsForCall)]
|
|
fake.isLocalArgsForCall = append(fake.isLocalArgsForCall, struct {
|
|
}{})
|
|
stub := fake.IsLocalStub
|
|
fakeReturns := fake.isLocalReturns
|
|
fake.recordInvocation("IsLocal", []interface{}{})
|
|
fake.isLocalMutex.Unlock()
|
|
if stub != nil {
|
|
return stub()
|
|
}
|
|
if specificReturn {
|
|
return ret.result1
|
|
}
|
|
return fakeReturns.result1
|
|
}
|
|
|
|
func (fake *mockedConnectionInfo) IsLocalCallCount() int {
|
|
fake.isLocalMutex.RLock()
|
|
defer fake.isLocalMutex.RUnlock()
|
|
return len(fake.isLocalArgsForCall)
|
|
}
|
|
|
|
func (fake *mockedConnectionInfo) IsLocalCalls(stub func() bool) {
|
|
fake.isLocalMutex.Lock()
|
|
defer fake.isLocalMutex.Unlock()
|
|
fake.IsLocalStub = stub
|
|
}
|
|
|
|
func (fake *mockedConnectionInfo) IsLocalReturns(result1 bool) {
|
|
fake.isLocalMutex.Lock()
|
|
defer fake.isLocalMutex.Unlock()
|
|
fake.IsLocalStub = nil
|
|
fake.isLocalReturns = struct {
|
|
result1 bool
|
|
}{result1}
|
|
}
|
|
|
|
func (fake *mockedConnectionInfo) IsLocalReturnsOnCall(i int, result1 bool) {
|
|
fake.isLocalMutex.Lock()
|
|
defer fake.isLocalMutex.Unlock()
|
|
fake.IsLocalStub = nil
|
|
if fake.isLocalReturnsOnCall == nil {
|
|
fake.isLocalReturnsOnCall = make(map[int]struct {
|
|
result1 bool
|
|
})
|
|
}
|
|
fake.isLocalReturnsOnCall[i] = struct {
|
|
result1 bool
|
|
}{result1}
|
|
}
|
|
|
|
func (fake *mockedConnectionInfo) Priority() int {
|
|
fake.priorityMutex.Lock()
|
|
ret, specificReturn := fake.priorityReturnsOnCall[len(fake.priorityArgsForCall)]
|
|
fake.priorityArgsForCall = append(fake.priorityArgsForCall, struct {
|
|
}{})
|
|
stub := fake.PriorityStub
|
|
fakeReturns := fake.priorityReturns
|
|
fake.recordInvocation("Priority", []interface{}{})
|
|
fake.priorityMutex.Unlock()
|
|
if stub != nil {
|
|
return stub()
|
|
}
|
|
if specificReturn {
|
|
return ret.result1
|
|
}
|
|
return fakeReturns.result1
|
|
}
|
|
|
|
func (fake *mockedConnectionInfo) PriorityCallCount() int {
|
|
fake.priorityMutex.RLock()
|
|
defer fake.priorityMutex.RUnlock()
|
|
return len(fake.priorityArgsForCall)
|
|
}
|
|
|
|
func (fake *mockedConnectionInfo) PriorityCalls(stub func() int) {
|
|
fake.priorityMutex.Lock()
|
|
defer fake.priorityMutex.Unlock()
|
|
fake.PriorityStub = stub
|
|
}
|
|
|
|
func (fake *mockedConnectionInfo) PriorityReturns(result1 int) {
|
|
fake.priorityMutex.Lock()
|
|
defer fake.priorityMutex.Unlock()
|
|
fake.PriorityStub = nil
|
|
fake.priorityReturns = struct {
|
|
result1 int
|
|
}{result1}
|
|
}
|
|
|
|
func (fake *mockedConnectionInfo) PriorityReturnsOnCall(i int, result1 int) {
|
|
fake.priorityMutex.Lock()
|
|
defer fake.priorityMutex.Unlock()
|
|
fake.PriorityStub = nil
|
|
if fake.priorityReturnsOnCall == nil {
|
|
fake.priorityReturnsOnCall = make(map[int]struct {
|
|
result1 int
|
|
})
|
|
}
|
|
fake.priorityReturnsOnCall[i] = struct {
|
|
result1 int
|
|
}{result1}
|
|
}
|
|
|
|
func (fake *mockedConnectionInfo) RemoteAddr() net.Addr {
|
|
fake.remoteAddrMutex.Lock()
|
|
ret, specificReturn := fake.remoteAddrReturnsOnCall[len(fake.remoteAddrArgsForCall)]
|
|
fake.remoteAddrArgsForCall = append(fake.remoteAddrArgsForCall, struct {
|
|
}{})
|
|
stub := fake.RemoteAddrStub
|
|
fakeReturns := fake.remoteAddrReturns
|
|
fake.recordInvocation("RemoteAddr", []interface{}{})
|
|
fake.remoteAddrMutex.Unlock()
|
|
if stub != nil {
|
|
return stub()
|
|
}
|
|
if specificReturn {
|
|
return ret.result1
|
|
}
|
|
return fakeReturns.result1
|
|
}
|
|
|
|
func (fake *mockedConnectionInfo) RemoteAddrCallCount() int {
|
|
fake.remoteAddrMutex.RLock()
|
|
defer fake.remoteAddrMutex.RUnlock()
|
|
return len(fake.remoteAddrArgsForCall)
|
|
}
|
|
|
|
func (fake *mockedConnectionInfo) RemoteAddrCalls(stub func() net.Addr) {
|
|
fake.remoteAddrMutex.Lock()
|
|
defer fake.remoteAddrMutex.Unlock()
|
|
fake.RemoteAddrStub = stub
|
|
}
|
|
|
|
func (fake *mockedConnectionInfo) RemoteAddrReturns(result1 net.Addr) {
|
|
fake.remoteAddrMutex.Lock()
|
|
defer fake.remoteAddrMutex.Unlock()
|
|
fake.RemoteAddrStub = nil
|
|
fake.remoteAddrReturns = struct {
|
|
result1 net.Addr
|
|
}{result1}
|
|
}
|
|
|
|
func (fake *mockedConnectionInfo) RemoteAddrReturnsOnCall(i int, result1 net.Addr) {
|
|
fake.remoteAddrMutex.Lock()
|
|
defer fake.remoteAddrMutex.Unlock()
|
|
fake.RemoteAddrStub = nil
|
|
if fake.remoteAddrReturnsOnCall == nil {
|
|
fake.remoteAddrReturnsOnCall = make(map[int]struct {
|
|
result1 net.Addr
|
|
})
|
|
}
|
|
fake.remoteAddrReturnsOnCall[i] = struct {
|
|
result1 net.Addr
|
|
}{result1}
|
|
}
|
|
|
|
func (fake *mockedConnectionInfo) String() string {
|
|
fake.stringMutex.Lock()
|
|
ret, specificReturn := fake.stringReturnsOnCall[len(fake.stringArgsForCall)]
|
|
fake.stringArgsForCall = append(fake.stringArgsForCall, struct {
|
|
}{})
|
|
stub := fake.StringStub
|
|
fakeReturns := fake.stringReturns
|
|
fake.recordInvocation("String", []interface{}{})
|
|
fake.stringMutex.Unlock()
|
|
if stub != nil {
|
|
return stub()
|
|
}
|
|
if specificReturn {
|
|
return ret.result1
|
|
}
|
|
return fakeReturns.result1
|
|
}
|
|
|
|
func (fake *mockedConnectionInfo) StringCallCount() int {
|
|
fake.stringMutex.RLock()
|
|
defer fake.stringMutex.RUnlock()
|
|
return len(fake.stringArgsForCall)
|
|
}
|
|
|
|
func (fake *mockedConnectionInfo) StringCalls(stub func() string) {
|
|
fake.stringMutex.Lock()
|
|
defer fake.stringMutex.Unlock()
|
|
fake.StringStub = stub
|
|
}
|
|
|
|
func (fake *mockedConnectionInfo) StringReturns(result1 string) {
|
|
fake.stringMutex.Lock()
|
|
defer fake.stringMutex.Unlock()
|
|
fake.StringStub = nil
|
|
fake.stringReturns = struct {
|
|
result1 string
|
|
}{result1}
|
|
}
|
|
|
|
func (fake *mockedConnectionInfo) StringReturnsOnCall(i int, result1 string) {
|
|
fake.stringMutex.Lock()
|
|
defer fake.stringMutex.Unlock()
|
|
fake.StringStub = nil
|
|
if fake.stringReturnsOnCall == nil {
|
|
fake.stringReturnsOnCall = make(map[int]struct {
|
|
result1 string
|
|
})
|
|
}
|
|
fake.stringReturnsOnCall[i] = struct {
|
|
result1 string
|
|
}{result1}
|
|
}
|
|
|
|
func (fake *mockedConnectionInfo) Transport() string {
|
|
fake.transportMutex.Lock()
|
|
ret, specificReturn := fake.transportReturnsOnCall[len(fake.transportArgsForCall)]
|
|
fake.transportArgsForCall = append(fake.transportArgsForCall, struct {
|
|
}{})
|
|
stub := fake.TransportStub
|
|
fakeReturns := fake.transportReturns
|
|
fake.recordInvocation("Transport", []interface{}{})
|
|
fake.transportMutex.Unlock()
|
|
if stub != nil {
|
|
return stub()
|
|
}
|
|
if specificReturn {
|
|
return ret.result1
|
|
}
|
|
return fakeReturns.result1
|
|
}
|
|
|
|
func (fake *mockedConnectionInfo) TransportCallCount() int {
|
|
fake.transportMutex.RLock()
|
|
defer fake.transportMutex.RUnlock()
|
|
return len(fake.transportArgsForCall)
|
|
}
|
|
|
|
func (fake *mockedConnectionInfo) TransportCalls(stub func() string) {
|
|
fake.transportMutex.Lock()
|
|
defer fake.transportMutex.Unlock()
|
|
fake.TransportStub = stub
|
|
}
|
|
|
|
func (fake *mockedConnectionInfo) TransportReturns(result1 string) {
|
|
fake.transportMutex.Lock()
|
|
defer fake.transportMutex.Unlock()
|
|
fake.TransportStub = nil
|
|
fake.transportReturns = struct {
|
|
result1 string
|
|
}{result1}
|
|
}
|
|
|
|
func (fake *mockedConnectionInfo) TransportReturnsOnCall(i int, result1 string) {
|
|
fake.transportMutex.Lock()
|
|
defer fake.transportMutex.Unlock()
|
|
fake.TransportStub = nil
|
|
if fake.transportReturnsOnCall == nil {
|
|
fake.transportReturnsOnCall = make(map[int]struct {
|
|
result1 string
|
|
})
|
|
}
|
|
fake.transportReturnsOnCall[i] = struct {
|
|
result1 string
|
|
}{result1}
|
|
}
|
|
|
|
func (fake *mockedConnectionInfo) Type() string {
|
|
fake.typeMutex.Lock()
|
|
ret, specificReturn := fake.typeReturnsOnCall[len(fake.typeArgsForCall)]
|
|
fake.typeArgsForCall = append(fake.typeArgsForCall, struct {
|
|
}{})
|
|
stub := fake.TypeStub
|
|
fakeReturns := fake.typeReturns
|
|
fake.recordInvocation("Type", []interface{}{})
|
|
fake.typeMutex.Unlock()
|
|
if stub != nil {
|
|
return stub()
|
|
}
|
|
if specificReturn {
|
|
return ret.result1
|
|
}
|
|
return fakeReturns.result1
|
|
}
|
|
|
|
func (fake *mockedConnectionInfo) TypeCallCount() int {
|
|
fake.typeMutex.RLock()
|
|
defer fake.typeMutex.RUnlock()
|
|
return len(fake.typeArgsForCall)
|
|
}
|
|
|
|
func (fake *mockedConnectionInfo) TypeCalls(stub func() string) {
|
|
fake.typeMutex.Lock()
|
|
defer fake.typeMutex.Unlock()
|
|
fake.TypeStub = stub
|
|
}
|
|
|
|
func (fake *mockedConnectionInfo) TypeReturns(result1 string) {
|
|
fake.typeMutex.Lock()
|
|
defer fake.typeMutex.Unlock()
|
|
fake.TypeStub = nil
|
|
fake.typeReturns = struct {
|
|
result1 string
|
|
}{result1}
|
|
}
|
|
|
|
func (fake *mockedConnectionInfo) TypeReturnsOnCall(i int, result1 string) {
|
|
fake.typeMutex.Lock()
|
|
defer fake.typeMutex.Unlock()
|
|
fake.TypeStub = nil
|
|
if fake.typeReturnsOnCall == nil {
|
|
fake.typeReturnsOnCall = make(map[int]struct {
|
|
result1 string
|
|
})
|
|
}
|
|
fake.typeReturnsOnCall[i] = struct {
|
|
result1 string
|
|
}{result1}
|
|
}
|
|
|
|
func (fake *mockedConnectionInfo) Invocations() map[string][][]interface{} {
|
|
fake.invocationsMutex.RLock()
|
|
defer fake.invocationsMutex.RUnlock()
|
|
fake.cryptoMutex.RLock()
|
|
defer fake.cryptoMutex.RUnlock()
|
|
fake.establishedAtMutex.RLock()
|
|
defer fake.establishedAtMutex.RUnlock()
|
|
fake.isLocalMutex.RLock()
|
|
defer fake.isLocalMutex.RUnlock()
|
|
fake.priorityMutex.RLock()
|
|
defer fake.priorityMutex.RUnlock()
|
|
fake.remoteAddrMutex.RLock()
|
|
defer fake.remoteAddrMutex.RUnlock()
|
|
fake.stringMutex.RLock()
|
|
defer fake.stringMutex.RUnlock()
|
|
fake.transportMutex.RLock()
|
|
defer fake.transportMutex.RUnlock()
|
|
fake.typeMutex.RLock()
|
|
defer fake.typeMutex.RUnlock()
|
|
copiedInvocations := map[string][][]interface{}{}
|
|
for key, value := range fake.invocations {
|
|
copiedInvocations[key] = value
|
|
}
|
|
return copiedInvocations
|
|
}
|
|
|
|
func (fake *mockedConnectionInfo) recordInvocation(key string, args []interface{}) {
|
|
fake.invocationsMutex.Lock()
|
|
defer fake.invocationsMutex.Unlock()
|
|
if fake.invocations == nil {
|
|
fake.invocations = map[string][][]interface{}{}
|
|
}
|
|
if fake.invocations[key] == nil {
|
|
fake.invocations[key] = [][]interface{}{}
|
|
}
|
|
fake.invocations[key] = append(fake.invocations[key], args)
|
|
}
|