connection.go 30 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151
  1. // Code generated by counterfeiter. DO NOT EDIT.
  2. package mocks
  3. import (
  4. "context"
  5. "net"
  6. "sync"
  7. "time"
  8. "github.com/syncthing/syncthing/lib/protocol"
  9. )
  10. type Connection struct {
  11. CloseStub func(error)
  12. closeMutex sync.RWMutex
  13. closeArgsForCall []struct {
  14. arg1 error
  15. }
  16. ClosedStub func() bool
  17. closedMutex sync.RWMutex
  18. closedArgsForCall []struct {
  19. }
  20. closedReturns struct {
  21. result1 bool
  22. }
  23. closedReturnsOnCall map[int]struct {
  24. result1 bool
  25. }
  26. ClusterConfigStub func(protocol.ClusterConfig)
  27. clusterConfigMutex sync.RWMutex
  28. clusterConfigArgsForCall []struct {
  29. arg1 protocol.ClusterConfig
  30. }
  31. CryptoStub func() string
  32. cryptoMutex sync.RWMutex
  33. cryptoArgsForCall []struct {
  34. }
  35. cryptoReturns struct {
  36. result1 string
  37. }
  38. cryptoReturnsOnCall map[int]struct {
  39. result1 string
  40. }
  41. DownloadProgressStub func(context.Context, string, []protocol.FileDownloadProgressUpdate)
  42. downloadProgressMutex sync.RWMutex
  43. downloadProgressArgsForCall []struct {
  44. arg1 context.Context
  45. arg2 string
  46. arg3 []protocol.FileDownloadProgressUpdate
  47. }
  48. EstablishedAtStub func() time.Time
  49. establishedAtMutex sync.RWMutex
  50. establishedAtArgsForCall []struct {
  51. }
  52. establishedAtReturns struct {
  53. result1 time.Time
  54. }
  55. establishedAtReturnsOnCall map[int]struct {
  56. result1 time.Time
  57. }
  58. IDStub func() protocol.DeviceID
  59. iDMutex sync.RWMutex
  60. iDArgsForCall []struct {
  61. }
  62. iDReturns struct {
  63. result1 protocol.DeviceID
  64. }
  65. iDReturnsOnCall map[int]struct {
  66. result1 protocol.DeviceID
  67. }
  68. IndexStub func(context.Context, string, []protocol.FileInfo) error
  69. indexMutex sync.RWMutex
  70. indexArgsForCall []struct {
  71. arg1 context.Context
  72. arg2 string
  73. arg3 []protocol.FileInfo
  74. }
  75. indexReturns struct {
  76. result1 error
  77. }
  78. indexReturnsOnCall map[int]struct {
  79. result1 error
  80. }
  81. IndexUpdateStub func(context.Context, string, []protocol.FileInfo) error
  82. indexUpdateMutex sync.RWMutex
  83. indexUpdateArgsForCall []struct {
  84. arg1 context.Context
  85. arg2 string
  86. arg3 []protocol.FileInfo
  87. }
  88. indexUpdateReturns struct {
  89. result1 error
  90. }
  91. indexUpdateReturnsOnCall map[int]struct {
  92. result1 error
  93. }
  94. PriorityStub func() int
  95. priorityMutex sync.RWMutex
  96. priorityArgsForCall []struct {
  97. }
  98. priorityReturns struct {
  99. result1 int
  100. }
  101. priorityReturnsOnCall map[int]struct {
  102. result1 int
  103. }
  104. RemoteAddrStub func() net.Addr
  105. remoteAddrMutex sync.RWMutex
  106. remoteAddrArgsForCall []struct {
  107. }
  108. remoteAddrReturns struct {
  109. result1 net.Addr
  110. }
  111. remoteAddrReturnsOnCall map[int]struct {
  112. result1 net.Addr
  113. }
  114. RequestStub func(context.Context, string, string, int, int64, int, []byte, uint32, bool) ([]byte, error)
  115. requestMutex sync.RWMutex
  116. requestArgsForCall []struct {
  117. arg1 context.Context
  118. arg2 string
  119. arg3 string
  120. arg4 int
  121. arg5 int64
  122. arg6 int
  123. arg7 []byte
  124. arg8 uint32
  125. arg9 bool
  126. }
  127. requestReturns struct {
  128. result1 []byte
  129. result2 error
  130. }
  131. requestReturnsOnCall map[int]struct {
  132. result1 []byte
  133. result2 error
  134. }
  135. SetFolderPasswordsStub func(map[string]string)
  136. setFolderPasswordsMutex sync.RWMutex
  137. setFolderPasswordsArgsForCall []struct {
  138. arg1 map[string]string
  139. }
  140. StartStub func()
  141. startMutex sync.RWMutex
  142. startArgsForCall []struct {
  143. }
  144. StatisticsStub func() protocol.Statistics
  145. statisticsMutex sync.RWMutex
  146. statisticsArgsForCall []struct {
  147. }
  148. statisticsReturns struct {
  149. result1 protocol.Statistics
  150. }
  151. statisticsReturnsOnCall map[int]struct {
  152. result1 protocol.Statistics
  153. }
  154. StringStub func() string
  155. stringMutex sync.RWMutex
  156. stringArgsForCall []struct {
  157. }
  158. stringReturns struct {
  159. result1 string
  160. }
  161. stringReturnsOnCall map[int]struct {
  162. result1 string
  163. }
  164. TransportStub func() string
  165. transportMutex sync.RWMutex
  166. transportArgsForCall []struct {
  167. }
  168. transportReturns struct {
  169. result1 string
  170. }
  171. transportReturnsOnCall map[int]struct {
  172. result1 string
  173. }
  174. TypeStub func() string
  175. typeMutex sync.RWMutex
  176. typeArgsForCall []struct {
  177. }
  178. typeReturns struct {
  179. result1 string
  180. }
  181. typeReturnsOnCall map[int]struct {
  182. result1 string
  183. }
  184. invocations map[string][][]interface{}
  185. invocationsMutex sync.RWMutex
  186. }
  187. func (fake *Connection) Close(arg1 error) {
  188. fake.closeMutex.Lock()
  189. fake.closeArgsForCall = append(fake.closeArgsForCall, struct {
  190. arg1 error
  191. }{arg1})
  192. stub := fake.CloseStub
  193. fake.recordInvocation("Close", []interface{}{arg1})
  194. fake.closeMutex.Unlock()
  195. if stub != nil {
  196. fake.CloseStub(arg1)
  197. }
  198. }
  199. func (fake *Connection) CloseCallCount() int {
  200. fake.closeMutex.RLock()
  201. defer fake.closeMutex.RUnlock()
  202. return len(fake.closeArgsForCall)
  203. }
  204. func (fake *Connection) CloseCalls(stub func(error)) {
  205. fake.closeMutex.Lock()
  206. defer fake.closeMutex.Unlock()
  207. fake.CloseStub = stub
  208. }
  209. func (fake *Connection) CloseArgsForCall(i int) error {
  210. fake.closeMutex.RLock()
  211. defer fake.closeMutex.RUnlock()
  212. argsForCall := fake.closeArgsForCall[i]
  213. return argsForCall.arg1
  214. }
  215. func (fake *Connection) Closed() bool {
  216. fake.closedMutex.Lock()
  217. ret, specificReturn := fake.closedReturnsOnCall[len(fake.closedArgsForCall)]
  218. fake.closedArgsForCall = append(fake.closedArgsForCall, struct {
  219. }{})
  220. stub := fake.ClosedStub
  221. fakeReturns := fake.closedReturns
  222. fake.recordInvocation("Closed", []interface{}{})
  223. fake.closedMutex.Unlock()
  224. if stub != nil {
  225. return stub()
  226. }
  227. if specificReturn {
  228. return ret.result1
  229. }
  230. return fakeReturns.result1
  231. }
  232. func (fake *Connection) ClosedCallCount() int {
  233. fake.closedMutex.RLock()
  234. defer fake.closedMutex.RUnlock()
  235. return len(fake.closedArgsForCall)
  236. }
  237. func (fake *Connection) ClosedCalls(stub func() bool) {
  238. fake.closedMutex.Lock()
  239. defer fake.closedMutex.Unlock()
  240. fake.ClosedStub = stub
  241. }
  242. func (fake *Connection) ClosedReturns(result1 bool) {
  243. fake.closedMutex.Lock()
  244. defer fake.closedMutex.Unlock()
  245. fake.ClosedStub = nil
  246. fake.closedReturns = struct {
  247. result1 bool
  248. }{result1}
  249. }
  250. func (fake *Connection) ClosedReturnsOnCall(i int, result1 bool) {
  251. fake.closedMutex.Lock()
  252. defer fake.closedMutex.Unlock()
  253. fake.ClosedStub = nil
  254. if fake.closedReturnsOnCall == nil {
  255. fake.closedReturnsOnCall = make(map[int]struct {
  256. result1 bool
  257. })
  258. }
  259. fake.closedReturnsOnCall[i] = struct {
  260. result1 bool
  261. }{result1}
  262. }
  263. func (fake *Connection) ClusterConfig(arg1 protocol.ClusterConfig) {
  264. fake.clusterConfigMutex.Lock()
  265. fake.clusterConfigArgsForCall = append(fake.clusterConfigArgsForCall, struct {
  266. arg1 protocol.ClusterConfig
  267. }{arg1})
  268. stub := fake.ClusterConfigStub
  269. fake.recordInvocation("ClusterConfig", []interface{}{arg1})
  270. fake.clusterConfigMutex.Unlock()
  271. if stub != nil {
  272. fake.ClusterConfigStub(arg1)
  273. }
  274. }
  275. func (fake *Connection) ClusterConfigCallCount() int {
  276. fake.clusterConfigMutex.RLock()
  277. defer fake.clusterConfigMutex.RUnlock()
  278. return len(fake.clusterConfigArgsForCall)
  279. }
  280. func (fake *Connection) ClusterConfigCalls(stub func(protocol.ClusterConfig)) {
  281. fake.clusterConfigMutex.Lock()
  282. defer fake.clusterConfigMutex.Unlock()
  283. fake.ClusterConfigStub = stub
  284. }
  285. func (fake *Connection) ClusterConfigArgsForCall(i int) protocol.ClusterConfig {
  286. fake.clusterConfigMutex.RLock()
  287. defer fake.clusterConfigMutex.RUnlock()
  288. argsForCall := fake.clusterConfigArgsForCall[i]
  289. return argsForCall.arg1
  290. }
  291. func (fake *Connection) Crypto() string {
  292. fake.cryptoMutex.Lock()
  293. ret, specificReturn := fake.cryptoReturnsOnCall[len(fake.cryptoArgsForCall)]
  294. fake.cryptoArgsForCall = append(fake.cryptoArgsForCall, struct {
  295. }{})
  296. stub := fake.CryptoStub
  297. fakeReturns := fake.cryptoReturns
  298. fake.recordInvocation("Crypto", []interface{}{})
  299. fake.cryptoMutex.Unlock()
  300. if stub != nil {
  301. return stub()
  302. }
  303. if specificReturn {
  304. return ret.result1
  305. }
  306. return fakeReturns.result1
  307. }
  308. func (fake *Connection) CryptoCallCount() int {
  309. fake.cryptoMutex.RLock()
  310. defer fake.cryptoMutex.RUnlock()
  311. return len(fake.cryptoArgsForCall)
  312. }
  313. func (fake *Connection) CryptoCalls(stub func() string) {
  314. fake.cryptoMutex.Lock()
  315. defer fake.cryptoMutex.Unlock()
  316. fake.CryptoStub = stub
  317. }
  318. func (fake *Connection) CryptoReturns(result1 string) {
  319. fake.cryptoMutex.Lock()
  320. defer fake.cryptoMutex.Unlock()
  321. fake.CryptoStub = nil
  322. fake.cryptoReturns = struct {
  323. result1 string
  324. }{result1}
  325. }
  326. func (fake *Connection) CryptoReturnsOnCall(i int, result1 string) {
  327. fake.cryptoMutex.Lock()
  328. defer fake.cryptoMutex.Unlock()
  329. fake.CryptoStub = nil
  330. if fake.cryptoReturnsOnCall == nil {
  331. fake.cryptoReturnsOnCall = make(map[int]struct {
  332. result1 string
  333. })
  334. }
  335. fake.cryptoReturnsOnCall[i] = struct {
  336. result1 string
  337. }{result1}
  338. }
  339. func (fake *Connection) DownloadProgress(arg1 context.Context, arg2 string, arg3 []protocol.FileDownloadProgressUpdate) {
  340. var arg3Copy []protocol.FileDownloadProgressUpdate
  341. if arg3 != nil {
  342. arg3Copy = make([]protocol.FileDownloadProgressUpdate, len(arg3))
  343. copy(arg3Copy, arg3)
  344. }
  345. fake.downloadProgressMutex.Lock()
  346. fake.downloadProgressArgsForCall = append(fake.downloadProgressArgsForCall, struct {
  347. arg1 context.Context
  348. arg2 string
  349. arg3 []protocol.FileDownloadProgressUpdate
  350. }{arg1, arg2, arg3Copy})
  351. stub := fake.DownloadProgressStub
  352. fake.recordInvocation("DownloadProgress", []interface{}{arg1, arg2, arg3Copy})
  353. fake.downloadProgressMutex.Unlock()
  354. if stub != nil {
  355. fake.DownloadProgressStub(arg1, arg2, arg3)
  356. }
  357. }
  358. func (fake *Connection) DownloadProgressCallCount() int {
  359. fake.downloadProgressMutex.RLock()
  360. defer fake.downloadProgressMutex.RUnlock()
  361. return len(fake.downloadProgressArgsForCall)
  362. }
  363. func (fake *Connection) DownloadProgressCalls(stub func(context.Context, string, []protocol.FileDownloadProgressUpdate)) {
  364. fake.downloadProgressMutex.Lock()
  365. defer fake.downloadProgressMutex.Unlock()
  366. fake.DownloadProgressStub = stub
  367. }
  368. func (fake *Connection) DownloadProgressArgsForCall(i int) (context.Context, string, []protocol.FileDownloadProgressUpdate) {
  369. fake.downloadProgressMutex.RLock()
  370. defer fake.downloadProgressMutex.RUnlock()
  371. argsForCall := fake.downloadProgressArgsForCall[i]
  372. return argsForCall.arg1, argsForCall.arg2, argsForCall.arg3
  373. }
  374. func (fake *Connection) EstablishedAt() time.Time {
  375. fake.establishedAtMutex.Lock()
  376. ret, specificReturn := fake.establishedAtReturnsOnCall[len(fake.establishedAtArgsForCall)]
  377. fake.establishedAtArgsForCall = append(fake.establishedAtArgsForCall, struct {
  378. }{})
  379. stub := fake.EstablishedAtStub
  380. fakeReturns := fake.establishedAtReturns
  381. fake.recordInvocation("EstablishedAt", []interface{}{})
  382. fake.establishedAtMutex.Unlock()
  383. if stub != nil {
  384. return stub()
  385. }
  386. if specificReturn {
  387. return ret.result1
  388. }
  389. return fakeReturns.result1
  390. }
  391. func (fake *Connection) EstablishedAtCallCount() int {
  392. fake.establishedAtMutex.RLock()
  393. defer fake.establishedAtMutex.RUnlock()
  394. return len(fake.establishedAtArgsForCall)
  395. }
  396. func (fake *Connection) EstablishedAtCalls(stub func() time.Time) {
  397. fake.establishedAtMutex.Lock()
  398. defer fake.establishedAtMutex.Unlock()
  399. fake.EstablishedAtStub = stub
  400. }
  401. func (fake *Connection) EstablishedAtReturns(result1 time.Time) {
  402. fake.establishedAtMutex.Lock()
  403. defer fake.establishedAtMutex.Unlock()
  404. fake.EstablishedAtStub = nil
  405. fake.establishedAtReturns = struct {
  406. result1 time.Time
  407. }{result1}
  408. }
  409. func (fake *Connection) EstablishedAtReturnsOnCall(i int, result1 time.Time) {
  410. fake.establishedAtMutex.Lock()
  411. defer fake.establishedAtMutex.Unlock()
  412. fake.EstablishedAtStub = nil
  413. if fake.establishedAtReturnsOnCall == nil {
  414. fake.establishedAtReturnsOnCall = make(map[int]struct {
  415. result1 time.Time
  416. })
  417. }
  418. fake.establishedAtReturnsOnCall[i] = struct {
  419. result1 time.Time
  420. }{result1}
  421. }
  422. func (fake *Connection) ID() protocol.DeviceID {
  423. fake.iDMutex.Lock()
  424. ret, specificReturn := fake.iDReturnsOnCall[len(fake.iDArgsForCall)]
  425. fake.iDArgsForCall = append(fake.iDArgsForCall, struct {
  426. }{})
  427. stub := fake.IDStub
  428. fakeReturns := fake.iDReturns
  429. fake.recordInvocation("ID", []interface{}{})
  430. fake.iDMutex.Unlock()
  431. if stub != nil {
  432. return stub()
  433. }
  434. if specificReturn {
  435. return ret.result1
  436. }
  437. return fakeReturns.result1
  438. }
  439. func (fake *Connection) IDCallCount() int {
  440. fake.iDMutex.RLock()
  441. defer fake.iDMutex.RUnlock()
  442. return len(fake.iDArgsForCall)
  443. }
  444. func (fake *Connection) IDCalls(stub func() protocol.DeviceID) {
  445. fake.iDMutex.Lock()
  446. defer fake.iDMutex.Unlock()
  447. fake.IDStub = stub
  448. }
  449. func (fake *Connection) IDReturns(result1 protocol.DeviceID) {
  450. fake.iDMutex.Lock()
  451. defer fake.iDMutex.Unlock()
  452. fake.IDStub = nil
  453. fake.iDReturns = struct {
  454. result1 protocol.DeviceID
  455. }{result1}
  456. }
  457. func (fake *Connection) IDReturnsOnCall(i int, result1 protocol.DeviceID) {
  458. fake.iDMutex.Lock()
  459. defer fake.iDMutex.Unlock()
  460. fake.IDStub = nil
  461. if fake.iDReturnsOnCall == nil {
  462. fake.iDReturnsOnCall = make(map[int]struct {
  463. result1 protocol.DeviceID
  464. })
  465. }
  466. fake.iDReturnsOnCall[i] = struct {
  467. result1 protocol.DeviceID
  468. }{result1}
  469. }
  470. func (fake *Connection) Index(arg1 context.Context, arg2 string, arg3 []protocol.FileInfo) error {
  471. var arg3Copy []protocol.FileInfo
  472. if arg3 != nil {
  473. arg3Copy = make([]protocol.FileInfo, len(arg3))
  474. copy(arg3Copy, arg3)
  475. }
  476. fake.indexMutex.Lock()
  477. ret, specificReturn := fake.indexReturnsOnCall[len(fake.indexArgsForCall)]
  478. fake.indexArgsForCall = append(fake.indexArgsForCall, struct {
  479. arg1 context.Context
  480. arg2 string
  481. arg3 []protocol.FileInfo
  482. }{arg1, arg2, arg3Copy})
  483. stub := fake.IndexStub
  484. fakeReturns := fake.indexReturns
  485. fake.recordInvocation("Index", []interface{}{arg1, arg2, arg3Copy})
  486. fake.indexMutex.Unlock()
  487. if stub != nil {
  488. return stub(arg1, arg2, arg3)
  489. }
  490. if specificReturn {
  491. return ret.result1
  492. }
  493. return fakeReturns.result1
  494. }
  495. func (fake *Connection) IndexCallCount() int {
  496. fake.indexMutex.RLock()
  497. defer fake.indexMutex.RUnlock()
  498. return len(fake.indexArgsForCall)
  499. }
  500. func (fake *Connection) IndexCalls(stub func(context.Context, string, []protocol.FileInfo) error) {
  501. fake.indexMutex.Lock()
  502. defer fake.indexMutex.Unlock()
  503. fake.IndexStub = stub
  504. }
  505. func (fake *Connection) IndexArgsForCall(i int) (context.Context, string, []protocol.FileInfo) {
  506. fake.indexMutex.RLock()
  507. defer fake.indexMutex.RUnlock()
  508. argsForCall := fake.indexArgsForCall[i]
  509. return argsForCall.arg1, argsForCall.arg2, argsForCall.arg3
  510. }
  511. func (fake *Connection) IndexReturns(result1 error) {
  512. fake.indexMutex.Lock()
  513. defer fake.indexMutex.Unlock()
  514. fake.IndexStub = nil
  515. fake.indexReturns = struct {
  516. result1 error
  517. }{result1}
  518. }
  519. func (fake *Connection) IndexReturnsOnCall(i int, result1 error) {
  520. fake.indexMutex.Lock()
  521. defer fake.indexMutex.Unlock()
  522. fake.IndexStub = nil
  523. if fake.indexReturnsOnCall == nil {
  524. fake.indexReturnsOnCall = make(map[int]struct {
  525. result1 error
  526. })
  527. }
  528. fake.indexReturnsOnCall[i] = struct {
  529. result1 error
  530. }{result1}
  531. }
  532. func (fake *Connection) IndexUpdate(arg1 context.Context, arg2 string, arg3 []protocol.FileInfo) error {
  533. var arg3Copy []protocol.FileInfo
  534. if arg3 != nil {
  535. arg3Copy = make([]protocol.FileInfo, len(arg3))
  536. copy(arg3Copy, arg3)
  537. }
  538. fake.indexUpdateMutex.Lock()
  539. ret, specificReturn := fake.indexUpdateReturnsOnCall[len(fake.indexUpdateArgsForCall)]
  540. fake.indexUpdateArgsForCall = append(fake.indexUpdateArgsForCall, struct {
  541. arg1 context.Context
  542. arg2 string
  543. arg3 []protocol.FileInfo
  544. }{arg1, arg2, arg3Copy})
  545. stub := fake.IndexUpdateStub
  546. fakeReturns := fake.indexUpdateReturns
  547. fake.recordInvocation("IndexUpdate", []interface{}{arg1, arg2, arg3Copy})
  548. fake.indexUpdateMutex.Unlock()
  549. if stub != nil {
  550. return stub(arg1, arg2, arg3)
  551. }
  552. if specificReturn {
  553. return ret.result1
  554. }
  555. return fakeReturns.result1
  556. }
  557. func (fake *Connection) IndexUpdateCallCount() int {
  558. fake.indexUpdateMutex.RLock()
  559. defer fake.indexUpdateMutex.RUnlock()
  560. return len(fake.indexUpdateArgsForCall)
  561. }
  562. func (fake *Connection) IndexUpdateCalls(stub func(context.Context, string, []protocol.FileInfo) error) {
  563. fake.indexUpdateMutex.Lock()
  564. defer fake.indexUpdateMutex.Unlock()
  565. fake.IndexUpdateStub = stub
  566. }
  567. func (fake *Connection) IndexUpdateArgsForCall(i int) (context.Context, string, []protocol.FileInfo) {
  568. fake.indexUpdateMutex.RLock()
  569. defer fake.indexUpdateMutex.RUnlock()
  570. argsForCall := fake.indexUpdateArgsForCall[i]
  571. return argsForCall.arg1, argsForCall.arg2, argsForCall.arg3
  572. }
  573. func (fake *Connection) IndexUpdateReturns(result1 error) {
  574. fake.indexUpdateMutex.Lock()
  575. defer fake.indexUpdateMutex.Unlock()
  576. fake.IndexUpdateStub = nil
  577. fake.indexUpdateReturns = struct {
  578. result1 error
  579. }{result1}
  580. }
  581. func (fake *Connection) IndexUpdateReturnsOnCall(i int, result1 error) {
  582. fake.indexUpdateMutex.Lock()
  583. defer fake.indexUpdateMutex.Unlock()
  584. fake.IndexUpdateStub = nil
  585. if fake.indexUpdateReturnsOnCall == nil {
  586. fake.indexUpdateReturnsOnCall = make(map[int]struct {
  587. result1 error
  588. })
  589. }
  590. fake.indexUpdateReturnsOnCall[i] = struct {
  591. result1 error
  592. }{result1}
  593. }
  594. func (fake *Connection) Priority() int {
  595. fake.priorityMutex.Lock()
  596. ret, specificReturn := fake.priorityReturnsOnCall[len(fake.priorityArgsForCall)]
  597. fake.priorityArgsForCall = append(fake.priorityArgsForCall, struct {
  598. }{})
  599. stub := fake.PriorityStub
  600. fakeReturns := fake.priorityReturns
  601. fake.recordInvocation("Priority", []interface{}{})
  602. fake.priorityMutex.Unlock()
  603. if stub != nil {
  604. return stub()
  605. }
  606. if specificReturn {
  607. return ret.result1
  608. }
  609. return fakeReturns.result1
  610. }
  611. func (fake *Connection) PriorityCallCount() int {
  612. fake.priorityMutex.RLock()
  613. defer fake.priorityMutex.RUnlock()
  614. return len(fake.priorityArgsForCall)
  615. }
  616. func (fake *Connection) PriorityCalls(stub func() int) {
  617. fake.priorityMutex.Lock()
  618. defer fake.priorityMutex.Unlock()
  619. fake.PriorityStub = stub
  620. }
  621. func (fake *Connection) PriorityReturns(result1 int) {
  622. fake.priorityMutex.Lock()
  623. defer fake.priorityMutex.Unlock()
  624. fake.PriorityStub = nil
  625. fake.priorityReturns = struct {
  626. result1 int
  627. }{result1}
  628. }
  629. func (fake *Connection) PriorityReturnsOnCall(i int, result1 int) {
  630. fake.priorityMutex.Lock()
  631. defer fake.priorityMutex.Unlock()
  632. fake.PriorityStub = nil
  633. if fake.priorityReturnsOnCall == nil {
  634. fake.priorityReturnsOnCall = make(map[int]struct {
  635. result1 int
  636. })
  637. }
  638. fake.priorityReturnsOnCall[i] = struct {
  639. result1 int
  640. }{result1}
  641. }
  642. func (fake *Connection) RemoteAddr() net.Addr {
  643. fake.remoteAddrMutex.Lock()
  644. ret, specificReturn := fake.remoteAddrReturnsOnCall[len(fake.remoteAddrArgsForCall)]
  645. fake.remoteAddrArgsForCall = append(fake.remoteAddrArgsForCall, struct {
  646. }{})
  647. stub := fake.RemoteAddrStub
  648. fakeReturns := fake.remoteAddrReturns
  649. fake.recordInvocation("RemoteAddr", []interface{}{})
  650. fake.remoteAddrMutex.Unlock()
  651. if stub != nil {
  652. return stub()
  653. }
  654. if specificReturn {
  655. return ret.result1
  656. }
  657. return fakeReturns.result1
  658. }
  659. func (fake *Connection) RemoteAddrCallCount() int {
  660. fake.remoteAddrMutex.RLock()
  661. defer fake.remoteAddrMutex.RUnlock()
  662. return len(fake.remoteAddrArgsForCall)
  663. }
  664. func (fake *Connection) RemoteAddrCalls(stub func() net.Addr) {
  665. fake.remoteAddrMutex.Lock()
  666. defer fake.remoteAddrMutex.Unlock()
  667. fake.RemoteAddrStub = stub
  668. }
  669. func (fake *Connection) RemoteAddrReturns(result1 net.Addr) {
  670. fake.remoteAddrMutex.Lock()
  671. defer fake.remoteAddrMutex.Unlock()
  672. fake.RemoteAddrStub = nil
  673. fake.remoteAddrReturns = struct {
  674. result1 net.Addr
  675. }{result1}
  676. }
  677. func (fake *Connection) RemoteAddrReturnsOnCall(i int, result1 net.Addr) {
  678. fake.remoteAddrMutex.Lock()
  679. defer fake.remoteAddrMutex.Unlock()
  680. fake.RemoteAddrStub = nil
  681. if fake.remoteAddrReturnsOnCall == nil {
  682. fake.remoteAddrReturnsOnCall = make(map[int]struct {
  683. result1 net.Addr
  684. })
  685. }
  686. fake.remoteAddrReturnsOnCall[i] = struct {
  687. result1 net.Addr
  688. }{result1}
  689. }
  690. func (fake *Connection) Request(arg1 context.Context, arg2 string, arg3 string, arg4 int, arg5 int64, arg6 int, arg7 []byte, arg8 uint32, arg9 bool) ([]byte, error) {
  691. var arg7Copy []byte
  692. if arg7 != nil {
  693. arg7Copy = make([]byte, len(arg7))
  694. copy(arg7Copy, arg7)
  695. }
  696. fake.requestMutex.Lock()
  697. ret, specificReturn := fake.requestReturnsOnCall[len(fake.requestArgsForCall)]
  698. fake.requestArgsForCall = append(fake.requestArgsForCall, struct {
  699. arg1 context.Context
  700. arg2 string
  701. arg3 string
  702. arg4 int
  703. arg5 int64
  704. arg6 int
  705. arg7 []byte
  706. arg8 uint32
  707. arg9 bool
  708. }{arg1, arg2, arg3, arg4, arg5, arg6, arg7Copy, arg8, arg9})
  709. stub := fake.RequestStub
  710. fakeReturns := fake.requestReturns
  711. fake.recordInvocation("Request", []interface{}{arg1, arg2, arg3, arg4, arg5, arg6, arg7Copy, arg8, arg9})
  712. fake.requestMutex.Unlock()
  713. if stub != nil {
  714. return stub(arg1, arg2, arg3, arg4, arg5, arg6, arg7, arg8, arg9)
  715. }
  716. if specificReturn {
  717. return ret.result1, ret.result2
  718. }
  719. return fakeReturns.result1, fakeReturns.result2
  720. }
  721. func (fake *Connection) RequestCallCount() int {
  722. fake.requestMutex.RLock()
  723. defer fake.requestMutex.RUnlock()
  724. return len(fake.requestArgsForCall)
  725. }
  726. func (fake *Connection) RequestCalls(stub func(context.Context, string, string, int, int64, int, []byte, uint32, bool) ([]byte, error)) {
  727. fake.requestMutex.Lock()
  728. defer fake.requestMutex.Unlock()
  729. fake.RequestStub = stub
  730. }
  731. func (fake *Connection) RequestArgsForCall(i int) (context.Context, string, string, int, int64, int, []byte, uint32, bool) {
  732. fake.requestMutex.RLock()
  733. defer fake.requestMutex.RUnlock()
  734. argsForCall := fake.requestArgsForCall[i]
  735. return argsForCall.arg1, argsForCall.arg2, argsForCall.arg3, argsForCall.arg4, argsForCall.arg5, argsForCall.arg6, argsForCall.arg7, argsForCall.arg8, argsForCall.arg9
  736. }
  737. func (fake *Connection) RequestReturns(result1 []byte, result2 error) {
  738. fake.requestMutex.Lock()
  739. defer fake.requestMutex.Unlock()
  740. fake.RequestStub = nil
  741. fake.requestReturns = struct {
  742. result1 []byte
  743. result2 error
  744. }{result1, result2}
  745. }
  746. func (fake *Connection) RequestReturnsOnCall(i int, result1 []byte, result2 error) {
  747. fake.requestMutex.Lock()
  748. defer fake.requestMutex.Unlock()
  749. fake.RequestStub = nil
  750. if fake.requestReturnsOnCall == nil {
  751. fake.requestReturnsOnCall = make(map[int]struct {
  752. result1 []byte
  753. result2 error
  754. })
  755. }
  756. fake.requestReturnsOnCall[i] = struct {
  757. result1 []byte
  758. result2 error
  759. }{result1, result2}
  760. }
  761. func (fake *Connection) SetFolderPasswords(arg1 map[string]string) {
  762. fake.setFolderPasswordsMutex.Lock()
  763. fake.setFolderPasswordsArgsForCall = append(fake.setFolderPasswordsArgsForCall, struct {
  764. arg1 map[string]string
  765. }{arg1})
  766. stub := fake.SetFolderPasswordsStub
  767. fake.recordInvocation("SetFolderPasswords", []interface{}{arg1})
  768. fake.setFolderPasswordsMutex.Unlock()
  769. if stub != nil {
  770. fake.SetFolderPasswordsStub(arg1)
  771. }
  772. }
  773. func (fake *Connection) SetFolderPasswordsCallCount() int {
  774. fake.setFolderPasswordsMutex.RLock()
  775. defer fake.setFolderPasswordsMutex.RUnlock()
  776. return len(fake.setFolderPasswordsArgsForCall)
  777. }
  778. func (fake *Connection) SetFolderPasswordsCalls(stub func(map[string]string)) {
  779. fake.setFolderPasswordsMutex.Lock()
  780. defer fake.setFolderPasswordsMutex.Unlock()
  781. fake.SetFolderPasswordsStub = stub
  782. }
  783. func (fake *Connection) SetFolderPasswordsArgsForCall(i int) map[string]string {
  784. fake.setFolderPasswordsMutex.RLock()
  785. defer fake.setFolderPasswordsMutex.RUnlock()
  786. argsForCall := fake.setFolderPasswordsArgsForCall[i]
  787. return argsForCall.arg1
  788. }
  789. func (fake *Connection) Start() {
  790. fake.startMutex.Lock()
  791. fake.startArgsForCall = append(fake.startArgsForCall, struct {
  792. }{})
  793. stub := fake.StartStub
  794. fake.recordInvocation("Start", []interface{}{})
  795. fake.startMutex.Unlock()
  796. if stub != nil {
  797. fake.StartStub()
  798. }
  799. }
  800. func (fake *Connection) StartCallCount() int {
  801. fake.startMutex.RLock()
  802. defer fake.startMutex.RUnlock()
  803. return len(fake.startArgsForCall)
  804. }
  805. func (fake *Connection) StartCalls(stub func()) {
  806. fake.startMutex.Lock()
  807. defer fake.startMutex.Unlock()
  808. fake.StartStub = stub
  809. }
  810. func (fake *Connection) Statistics() protocol.Statistics {
  811. fake.statisticsMutex.Lock()
  812. ret, specificReturn := fake.statisticsReturnsOnCall[len(fake.statisticsArgsForCall)]
  813. fake.statisticsArgsForCall = append(fake.statisticsArgsForCall, struct {
  814. }{})
  815. stub := fake.StatisticsStub
  816. fakeReturns := fake.statisticsReturns
  817. fake.recordInvocation("Statistics", []interface{}{})
  818. fake.statisticsMutex.Unlock()
  819. if stub != nil {
  820. return stub()
  821. }
  822. if specificReturn {
  823. return ret.result1
  824. }
  825. return fakeReturns.result1
  826. }
  827. func (fake *Connection) StatisticsCallCount() int {
  828. fake.statisticsMutex.RLock()
  829. defer fake.statisticsMutex.RUnlock()
  830. return len(fake.statisticsArgsForCall)
  831. }
  832. func (fake *Connection) StatisticsCalls(stub func() protocol.Statistics) {
  833. fake.statisticsMutex.Lock()
  834. defer fake.statisticsMutex.Unlock()
  835. fake.StatisticsStub = stub
  836. }
  837. func (fake *Connection) StatisticsReturns(result1 protocol.Statistics) {
  838. fake.statisticsMutex.Lock()
  839. defer fake.statisticsMutex.Unlock()
  840. fake.StatisticsStub = nil
  841. fake.statisticsReturns = struct {
  842. result1 protocol.Statistics
  843. }{result1}
  844. }
  845. func (fake *Connection) StatisticsReturnsOnCall(i int, result1 protocol.Statistics) {
  846. fake.statisticsMutex.Lock()
  847. defer fake.statisticsMutex.Unlock()
  848. fake.StatisticsStub = nil
  849. if fake.statisticsReturnsOnCall == nil {
  850. fake.statisticsReturnsOnCall = make(map[int]struct {
  851. result1 protocol.Statistics
  852. })
  853. }
  854. fake.statisticsReturnsOnCall[i] = struct {
  855. result1 protocol.Statistics
  856. }{result1}
  857. }
  858. func (fake *Connection) String() string {
  859. fake.stringMutex.Lock()
  860. ret, specificReturn := fake.stringReturnsOnCall[len(fake.stringArgsForCall)]
  861. fake.stringArgsForCall = append(fake.stringArgsForCall, struct {
  862. }{})
  863. stub := fake.StringStub
  864. fakeReturns := fake.stringReturns
  865. fake.recordInvocation("String", []interface{}{})
  866. fake.stringMutex.Unlock()
  867. if stub != nil {
  868. return stub()
  869. }
  870. if specificReturn {
  871. return ret.result1
  872. }
  873. return fakeReturns.result1
  874. }
  875. func (fake *Connection) StringCallCount() int {
  876. fake.stringMutex.RLock()
  877. defer fake.stringMutex.RUnlock()
  878. return len(fake.stringArgsForCall)
  879. }
  880. func (fake *Connection) StringCalls(stub func() string) {
  881. fake.stringMutex.Lock()
  882. defer fake.stringMutex.Unlock()
  883. fake.StringStub = stub
  884. }
  885. func (fake *Connection) StringReturns(result1 string) {
  886. fake.stringMutex.Lock()
  887. defer fake.stringMutex.Unlock()
  888. fake.StringStub = nil
  889. fake.stringReturns = struct {
  890. result1 string
  891. }{result1}
  892. }
  893. func (fake *Connection) StringReturnsOnCall(i int, result1 string) {
  894. fake.stringMutex.Lock()
  895. defer fake.stringMutex.Unlock()
  896. fake.StringStub = nil
  897. if fake.stringReturnsOnCall == nil {
  898. fake.stringReturnsOnCall = make(map[int]struct {
  899. result1 string
  900. })
  901. }
  902. fake.stringReturnsOnCall[i] = struct {
  903. result1 string
  904. }{result1}
  905. }
  906. func (fake *Connection) Transport() string {
  907. fake.transportMutex.Lock()
  908. ret, specificReturn := fake.transportReturnsOnCall[len(fake.transportArgsForCall)]
  909. fake.transportArgsForCall = append(fake.transportArgsForCall, struct {
  910. }{})
  911. stub := fake.TransportStub
  912. fakeReturns := fake.transportReturns
  913. fake.recordInvocation("Transport", []interface{}{})
  914. fake.transportMutex.Unlock()
  915. if stub != nil {
  916. return stub()
  917. }
  918. if specificReturn {
  919. return ret.result1
  920. }
  921. return fakeReturns.result1
  922. }
  923. func (fake *Connection) TransportCallCount() int {
  924. fake.transportMutex.RLock()
  925. defer fake.transportMutex.RUnlock()
  926. return len(fake.transportArgsForCall)
  927. }
  928. func (fake *Connection) TransportCalls(stub func() string) {
  929. fake.transportMutex.Lock()
  930. defer fake.transportMutex.Unlock()
  931. fake.TransportStub = stub
  932. }
  933. func (fake *Connection) TransportReturns(result1 string) {
  934. fake.transportMutex.Lock()
  935. defer fake.transportMutex.Unlock()
  936. fake.TransportStub = nil
  937. fake.transportReturns = struct {
  938. result1 string
  939. }{result1}
  940. }
  941. func (fake *Connection) TransportReturnsOnCall(i int, result1 string) {
  942. fake.transportMutex.Lock()
  943. defer fake.transportMutex.Unlock()
  944. fake.TransportStub = nil
  945. if fake.transportReturnsOnCall == nil {
  946. fake.transportReturnsOnCall = make(map[int]struct {
  947. result1 string
  948. })
  949. }
  950. fake.transportReturnsOnCall[i] = struct {
  951. result1 string
  952. }{result1}
  953. }
  954. func (fake *Connection) Type() string {
  955. fake.typeMutex.Lock()
  956. ret, specificReturn := fake.typeReturnsOnCall[len(fake.typeArgsForCall)]
  957. fake.typeArgsForCall = append(fake.typeArgsForCall, struct {
  958. }{})
  959. stub := fake.TypeStub
  960. fakeReturns := fake.typeReturns
  961. fake.recordInvocation("Type", []interface{}{})
  962. fake.typeMutex.Unlock()
  963. if stub != nil {
  964. return stub()
  965. }
  966. if specificReturn {
  967. return ret.result1
  968. }
  969. return fakeReturns.result1
  970. }
  971. func (fake *Connection) TypeCallCount() int {
  972. fake.typeMutex.RLock()
  973. defer fake.typeMutex.RUnlock()
  974. return len(fake.typeArgsForCall)
  975. }
  976. func (fake *Connection) TypeCalls(stub func() string) {
  977. fake.typeMutex.Lock()
  978. defer fake.typeMutex.Unlock()
  979. fake.TypeStub = stub
  980. }
  981. func (fake *Connection) TypeReturns(result1 string) {
  982. fake.typeMutex.Lock()
  983. defer fake.typeMutex.Unlock()
  984. fake.TypeStub = nil
  985. fake.typeReturns = struct {
  986. result1 string
  987. }{result1}
  988. }
  989. func (fake *Connection) TypeReturnsOnCall(i int, result1 string) {
  990. fake.typeMutex.Lock()
  991. defer fake.typeMutex.Unlock()
  992. fake.TypeStub = nil
  993. if fake.typeReturnsOnCall == nil {
  994. fake.typeReturnsOnCall = make(map[int]struct {
  995. result1 string
  996. })
  997. }
  998. fake.typeReturnsOnCall[i] = struct {
  999. result1 string
  1000. }{result1}
  1001. }
  1002. func (fake *Connection) Invocations() map[string][][]interface{} {
  1003. fake.invocationsMutex.RLock()
  1004. defer fake.invocationsMutex.RUnlock()
  1005. fake.closeMutex.RLock()
  1006. defer fake.closeMutex.RUnlock()
  1007. fake.closedMutex.RLock()
  1008. defer fake.closedMutex.RUnlock()
  1009. fake.clusterConfigMutex.RLock()
  1010. defer fake.clusterConfigMutex.RUnlock()
  1011. fake.cryptoMutex.RLock()
  1012. defer fake.cryptoMutex.RUnlock()
  1013. fake.downloadProgressMutex.RLock()
  1014. defer fake.downloadProgressMutex.RUnlock()
  1015. fake.establishedAtMutex.RLock()
  1016. defer fake.establishedAtMutex.RUnlock()
  1017. fake.iDMutex.RLock()
  1018. defer fake.iDMutex.RUnlock()
  1019. fake.indexMutex.RLock()
  1020. defer fake.indexMutex.RUnlock()
  1021. fake.indexUpdateMutex.RLock()
  1022. defer fake.indexUpdateMutex.RUnlock()
  1023. fake.priorityMutex.RLock()
  1024. defer fake.priorityMutex.RUnlock()
  1025. fake.remoteAddrMutex.RLock()
  1026. defer fake.remoteAddrMutex.RUnlock()
  1027. fake.requestMutex.RLock()
  1028. defer fake.requestMutex.RUnlock()
  1029. fake.setFolderPasswordsMutex.RLock()
  1030. defer fake.setFolderPasswordsMutex.RUnlock()
  1031. fake.startMutex.RLock()
  1032. defer fake.startMutex.RUnlock()
  1033. fake.statisticsMutex.RLock()
  1034. defer fake.statisticsMutex.RUnlock()
  1035. fake.stringMutex.RLock()
  1036. defer fake.stringMutex.RUnlock()
  1037. fake.transportMutex.RLock()
  1038. defer fake.transportMutex.RUnlock()
  1039. fake.typeMutex.RLock()
  1040. defer fake.typeMutex.RUnlock()
  1041. copiedInvocations := map[string][][]interface{}{}
  1042. for key, value := range fake.invocations {
  1043. copiedInvocations[key] = value
  1044. }
  1045. return copiedInvocations
  1046. }
  1047. func (fake *Connection) recordInvocation(key string, args []interface{}) {
  1048. fake.invocationsMutex.Lock()
  1049. defer fake.invocationsMutex.Unlock()
  1050. if fake.invocations == nil {
  1051. fake.invocations = map[string][][]interface{}{}
  1052. }
  1053. if fake.invocations[key] == nil {
  1054. fake.invocations[key] = [][]interface{}{}
  1055. }
  1056. fake.invocations[key] = append(fake.invocations[key], args)
  1057. }
  1058. var _ protocol.Connection = new(Connection)