manager.go 11 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454
  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. fake.cacheMutex.RLock()
  388. defer fake.cacheMutex.RUnlock()
  389. fake.childErrorsMutex.RLock()
  390. defer fake.childErrorsMutex.RUnlock()
  391. fake.errorMutex.RLock()
  392. defer fake.errorMutex.RUnlock()
  393. fake.lookupMutex.RLock()
  394. defer fake.lookupMutex.RUnlock()
  395. fake.serveMutex.RLock()
  396. defer fake.serveMutex.RUnlock()
  397. fake.stringMutex.RLock()
  398. defer fake.stringMutex.RUnlock()
  399. copiedInvocations := map[string][][]interface{}{}
  400. for key, value := range fake.invocations {
  401. copiedInvocations[key] = value
  402. }
  403. return copiedInvocations
  404. }
  405. func (fake *Manager) recordInvocation(key string, args []interface{}) {
  406. fake.invocationsMutex.Lock()
  407. defer fake.invocationsMutex.Unlock()
  408. if fake.invocations == nil {
  409. fake.invocations = map[string][][]interface{}{}
  410. }
  411. if fake.invocations[key] == nil {
  412. fake.invocations[key] = [][]interface{}{}
  413. }
  414. fake.invocations[key] = append(fake.invocations[key], args)
  415. }
  416. var _ discover.Manager = new(Manager)