manager.go 11 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442
  1. // Code generated by counterfeiter. DO NOT EDIT.
  2. package mocks
  3. import (
  4. "context"
  5. "sync"
  6. "github.com/syncthing/syncthing/lib/discover"
  7. "github.com/syncthing/syncthing/lib/protocol"
  8. )
  9. type Manager struct {
  10. CacheStub func() map[protocol.DeviceID]discover.CacheEntry
  11. cacheMutex sync.RWMutex
  12. cacheArgsForCall []struct {
  13. }
  14. cacheReturns struct {
  15. result1 map[protocol.DeviceID]discover.CacheEntry
  16. }
  17. cacheReturnsOnCall map[int]struct {
  18. result1 map[protocol.DeviceID]discover.CacheEntry
  19. }
  20. ChildErrorsStub func() map[string]error
  21. childErrorsMutex sync.RWMutex
  22. childErrorsArgsForCall []struct {
  23. }
  24. childErrorsReturns struct {
  25. result1 map[string]error
  26. }
  27. childErrorsReturnsOnCall map[int]struct {
  28. result1 map[string]error
  29. }
  30. ErrorStub func() error
  31. errorMutex sync.RWMutex
  32. errorArgsForCall []struct {
  33. }
  34. errorReturns struct {
  35. result1 error
  36. }
  37. errorReturnsOnCall map[int]struct {
  38. result1 error
  39. }
  40. LookupStub func(context.Context, protocol.DeviceID) ([]string, error)
  41. lookupMutex sync.RWMutex
  42. lookupArgsForCall []struct {
  43. arg1 context.Context
  44. arg2 protocol.DeviceID
  45. }
  46. lookupReturns struct {
  47. result1 []string
  48. result2 error
  49. }
  50. lookupReturnsOnCall map[int]struct {
  51. result1 []string
  52. result2 error
  53. }
  54. ServeStub func(context.Context) error
  55. serveMutex sync.RWMutex
  56. serveArgsForCall []struct {
  57. arg1 context.Context
  58. }
  59. serveReturns struct {
  60. result1 error
  61. }
  62. serveReturnsOnCall map[int]struct {
  63. result1 error
  64. }
  65. StringStub func() string
  66. stringMutex sync.RWMutex
  67. stringArgsForCall []struct {
  68. }
  69. stringReturns struct {
  70. result1 string
  71. }
  72. stringReturnsOnCall map[int]struct {
  73. result1 string
  74. }
  75. invocations map[string][][]interface{}
  76. invocationsMutex sync.RWMutex
  77. }
  78. func (fake *Manager) Cache() map[protocol.DeviceID]discover.CacheEntry {
  79. fake.cacheMutex.Lock()
  80. ret, specificReturn := fake.cacheReturnsOnCall[len(fake.cacheArgsForCall)]
  81. fake.cacheArgsForCall = append(fake.cacheArgsForCall, struct {
  82. }{})
  83. stub := fake.CacheStub
  84. fakeReturns := fake.cacheReturns
  85. fake.recordInvocation("Cache", []interface{}{})
  86. fake.cacheMutex.Unlock()
  87. if stub != nil {
  88. return stub()
  89. }
  90. if specificReturn {
  91. return ret.result1
  92. }
  93. return fakeReturns.result1
  94. }
  95. func (fake *Manager) CacheCallCount() int {
  96. fake.cacheMutex.RLock()
  97. defer fake.cacheMutex.RUnlock()
  98. return len(fake.cacheArgsForCall)
  99. }
  100. func (fake *Manager) CacheCalls(stub func() map[protocol.DeviceID]discover.CacheEntry) {
  101. fake.cacheMutex.Lock()
  102. defer fake.cacheMutex.Unlock()
  103. fake.CacheStub = stub
  104. }
  105. func (fake *Manager) CacheReturns(result1 map[protocol.DeviceID]discover.CacheEntry) {
  106. fake.cacheMutex.Lock()
  107. defer fake.cacheMutex.Unlock()
  108. fake.CacheStub = nil
  109. fake.cacheReturns = struct {
  110. result1 map[protocol.DeviceID]discover.CacheEntry
  111. }{result1}
  112. }
  113. func (fake *Manager) CacheReturnsOnCall(i int, result1 map[protocol.DeviceID]discover.CacheEntry) {
  114. fake.cacheMutex.Lock()
  115. defer fake.cacheMutex.Unlock()
  116. fake.CacheStub = nil
  117. if fake.cacheReturnsOnCall == nil {
  118. fake.cacheReturnsOnCall = make(map[int]struct {
  119. result1 map[protocol.DeviceID]discover.CacheEntry
  120. })
  121. }
  122. fake.cacheReturnsOnCall[i] = struct {
  123. result1 map[protocol.DeviceID]discover.CacheEntry
  124. }{result1}
  125. }
  126. func (fake *Manager) ChildErrors() map[string]error {
  127. fake.childErrorsMutex.Lock()
  128. ret, specificReturn := fake.childErrorsReturnsOnCall[len(fake.childErrorsArgsForCall)]
  129. fake.childErrorsArgsForCall = append(fake.childErrorsArgsForCall, struct {
  130. }{})
  131. stub := fake.ChildErrorsStub
  132. fakeReturns := fake.childErrorsReturns
  133. fake.recordInvocation("ChildErrors", []interface{}{})
  134. fake.childErrorsMutex.Unlock()
  135. if stub != nil {
  136. return stub()
  137. }
  138. if specificReturn {
  139. return ret.result1
  140. }
  141. return fakeReturns.result1
  142. }
  143. func (fake *Manager) ChildErrorsCallCount() int {
  144. fake.childErrorsMutex.RLock()
  145. defer fake.childErrorsMutex.RUnlock()
  146. return len(fake.childErrorsArgsForCall)
  147. }
  148. func (fake *Manager) ChildErrorsCalls(stub func() map[string]error) {
  149. fake.childErrorsMutex.Lock()
  150. defer fake.childErrorsMutex.Unlock()
  151. fake.ChildErrorsStub = stub
  152. }
  153. func (fake *Manager) ChildErrorsReturns(result1 map[string]error) {
  154. fake.childErrorsMutex.Lock()
  155. defer fake.childErrorsMutex.Unlock()
  156. fake.ChildErrorsStub = nil
  157. fake.childErrorsReturns = struct {
  158. result1 map[string]error
  159. }{result1}
  160. }
  161. func (fake *Manager) ChildErrorsReturnsOnCall(i int, result1 map[string]error) {
  162. fake.childErrorsMutex.Lock()
  163. defer fake.childErrorsMutex.Unlock()
  164. fake.ChildErrorsStub = nil
  165. if fake.childErrorsReturnsOnCall == nil {
  166. fake.childErrorsReturnsOnCall = make(map[int]struct {
  167. result1 map[string]error
  168. })
  169. }
  170. fake.childErrorsReturnsOnCall[i] = struct {
  171. result1 map[string]error
  172. }{result1}
  173. }
  174. func (fake *Manager) Error() error {
  175. fake.errorMutex.Lock()
  176. ret, specificReturn := fake.errorReturnsOnCall[len(fake.errorArgsForCall)]
  177. fake.errorArgsForCall = append(fake.errorArgsForCall, struct {
  178. }{})
  179. stub := fake.ErrorStub
  180. fakeReturns := fake.errorReturns
  181. fake.recordInvocation("Error", []interface{}{})
  182. fake.errorMutex.Unlock()
  183. if stub != nil {
  184. return stub()
  185. }
  186. if specificReturn {
  187. return ret.result1
  188. }
  189. return fakeReturns.result1
  190. }
  191. func (fake *Manager) ErrorCallCount() int {
  192. fake.errorMutex.RLock()
  193. defer fake.errorMutex.RUnlock()
  194. return len(fake.errorArgsForCall)
  195. }
  196. func (fake *Manager) ErrorCalls(stub func() error) {
  197. fake.errorMutex.Lock()
  198. defer fake.errorMutex.Unlock()
  199. fake.ErrorStub = stub
  200. }
  201. func (fake *Manager) ErrorReturns(result1 error) {
  202. fake.errorMutex.Lock()
  203. defer fake.errorMutex.Unlock()
  204. fake.ErrorStub = nil
  205. fake.errorReturns = struct {
  206. result1 error
  207. }{result1}
  208. }
  209. func (fake *Manager) ErrorReturnsOnCall(i int, result1 error) {
  210. fake.errorMutex.Lock()
  211. defer fake.errorMutex.Unlock()
  212. fake.ErrorStub = nil
  213. if fake.errorReturnsOnCall == nil {
  214. fake.errorReturnsOnCall = make(map[int]struct {
  215. result1 error
  216. })
  217. }
  218. fake.errorReturnsOnCall[i] = struct {
  219. result1 error
  220. }{result1}
  221. }
  222. func (fake *Manager) Lookup(arg1 context.Context, arg2 protocol.DeviceID) ([]string, error) {
  223. fake.lookupMutex.Lock()
  224. ret, specificReturn := fake.lookupReturnsOnCall[len(fake.lookupArgsForCall)]
  225. fake.lookupArgsForCall = append(fake.lookupArgsForCall, struct {
  226. arg1 context.Context
  227. arg2 protocol.DeviceID
  228. }{arg1, arg2})
  229. stub := fake.LookupStub
  230. fakeReturns := fake.lookupReturns
  231. fake.recordInvocation("Lookup", []interface{}{arg1, arg2})
  232. fake.lookupMutex.Unlock()
  233. if stub != nil {
  234. return stub(arg1, arg2)
  235. }
  236. if specificReturn {
  237. return ret.result1, ret.result2
  238. }
  239. return fakeReturns.result1, fakeReturns.result2
  240. }
  241. func (fake *Manager) LookupCallCount() int {
  242. fake.lookupMutex.RLock()
  243. defer fake.lookupMutex.RUnlock()
  244. return len(fake.lookupArgsForCall)
  245. }
  246. func (fake *Manager) LookupCalls(stub func(context.Context, protocol.DeviceID) ([]string, error)) {
  247. fake.lookupMutex.Lock()
  248. defer fake.lookupMutex.Unlock()
  249. fake.LookupStub = stub
  250. }
  251. func (fake *Manager) LookupArgsForCall(i int) (context.Context, protocol.DeviceID) {
  252. fake.lookupMutex.RLock()
  253. defer fake.lookupMutex.RUnlock()
  254. argsForCall := fake.lookupArgsForCall[i]
  255. return argsForCall.arg1, argsForCall.arg2
  256. }
  257. func (fake *Manager) LookupReturns(result1 []string, result2 error) {
  258. fake.lookupMutex.Lock()
  259. defer fake.lookupMutex.Unlock()
  260. fake.LookupStub = nil
  261. fake.lookupReturns = struct {
  262. result1 []string
  263. result2 error
  264. }{result1, result2}
  265. }
  266. func (fake *Manager) LookupReturnsOnCall(i int, result1 []string, result2 error) {
  267. fake.lookupMutex.Lock()
  268. defer fake.lookupMutex.Unlock()
  269. fake.LookupStub = nil
  270. if fake.lookupReturnsOnCall == nil {
  271. fake.lookupReturnsOnCall = make(map[int]struct {
  272. result1 []string
  273. result2 error
  274. })
  275. }
  276. fake.lookupReturnsOnCall[i] = struct {
  277. result1 []string
  278. result2 error
  279. }{result1, result2}
  280. }
  281. func (fake *Manager) Serve(arg1 context.Context) error {
  282. fake.serveMutex.Lock()
  283. ret, specificReturn := fake.serveReturnsOnCall[len(fake.serveArgsForCall)]
  284. fake.serveArgsForCall = append(fake.serveArgsForCall, struct {
  285. arg1 context.Context
  286. }{arg1})
  287. stub := fake.ServeStub
  288. fakeReturns := fake.serveReturns
  289. fake.recordInvocation("Serve", []interface{}{arg1})
  290. fake.serveMutex.Unlock()
  291. if stub != nil {
  292. return stub(arg1)
  293. }
  294. if specificReturn {
  295. return ret.result1
  296. }
  297. return fakeReturns.result1
  298. }
  299. func (fake *Manager) ServeCallCount() int {
  300. fake.serveMutex.RLock()
  301. defer fake.serveMutex.RUnlock()
  302. return len(fake.serveArgsForCall)
  303. }
  304. func (fake *Manager) ServeCalls(stub func(context.Context) error) {
  305. fake.serveMutex.Lock()
  306. defer fake.serveMutex.Unlock()
  307. fake.ServeStub = stub
  308. }
  309. func (fake *Manager) ServeArgsForCall(i int) context.Context {
  310. fake.serveMutex.RLock()
  311. defer fake.serveMutex.RUnlock()
  312. argsForCall := fake.serveArgsForCall[i]
  313. return argsForCall.arg1
  314. }
  315. func (fake *Manager) ServeReturns(result1 error) {
  316. fake.serveMutex.Lock()
  317. defer fake.serveMutex.Unlock()
  318. fake.ServeStub = nil
  319. fake.serveReturns = struct {
  320. result1 error
  321. }{result1}
  322. }
  323. func (fake *Manager) ServeReturnsOnCall(i int, result1 error) {
  324. fake.serveMutex.Lock()
  325. defer fake.serveMutex.Unlock()
  326. fake.ServeStub = nil
  327. if fake.serveReturnsOnCall == nil {
  328. fake.serveReturnsOnCall = make(map[int]struct {
  329. result1 error
  330. })
  331. }
  332. fake.serveReturnsOnCall[i] = struct {
  333. result1 error
  334. }{result1}
  335. }
  336. func (fake *Manager) String() string {
  337. fake.stringMutex.Lock()
  338. ret, specificReturn := fake.stringReturnsOnCall[len(fake.stringArgsForCall)]
  339. fake.stringArgsForCall = append(fake.stringArgsForCall, struct {
  340. }{})
  341. stub := fake.StringStub
  342. fakeReturns := fake.stringReturns
  343. fake.recordInvocation("String", []interface{}{})
  344. fake.stringMutex.Unlock()
  345. if stub != nil {
  346. return stub()
  347. }
  348. if specificReturn {
  349. return ret.result1
  350. }
  351. return fakeReturns.result1
  352. }
  353. func (fake *Manager) StringCallCount() int {
  354. fake.stringMutex.RLock()
  355. defer fake.stringMutex.RUnlock()
  356. return len(fake.stringArgsForCall)
  357. }
  358. func (fake *Manager) StringCalls(stub func() string) {
  359. fake.stringMutex.Lock()
  360. defer fake.stringMutex.Unlock()
  361. fake.StringStub = stub
  362. }
  363. func (fake *Manager) StringReturns(result1 string) {
  364. fake.stringMutex.Lock()
  365. defer fake.stringMutex.Unlock()
  366. fake.StringStub = nil
  367. fake.stringReturns = struct {
  368. result1 string
  369. }{result1}
  370. }
  371. func (fake *Manager) StringReturnsOnCall(i int, result1 string) {
  372. fake.stringMutex.Lock()
  373. defer fake.stringMutex.Unlock()
  374. fake.StringStub = nil
  375. if fake.stringReturnsOnCall == nil {
  376. fake.stringReturnsOnCall = make(map[int]struct {
  377. result1 string
  378. })
  379. }
  380. fake.stringReturnsOnCall[i] = struct {
  381. result1 string
  382. }{result1}
  383. }
  384. func (fake *Manager) Invocations() map[string][][]interface{} {
  385. fake.invocationsMutex.RLock()
  386. defer fake.invocationsMutex.RUnlock()
  387. copiedInvocations := map[string][][]interface{}{}
  388. for key, value := range fake.invocations {
  389. copiedInvocations[key] = value
  390. }
  391. return copiedInvocations
  392. }
  393. func (fake *Manager) recordInvocation(key string, args []interface{}) {
  394. fake.invocationsMutex.Lock()
  395. defer fake.invocationsMutex.Unlock()
  396. if fake.invocations == nil {
  397. fake.invocations = map[string][][]interface{}{}
  398. }
  399. if fake.invocations[key] == nil {
  400. fake.invocations[key] = [][]interface{}{}
  401. }
  402. fake.invocations[key] = append(fake.invocations[key], args)
  403. }
  404. var _ discover.Manager = new(Manager)