connection.go 32 KB

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