From 8eeea02997bde3844e173949f36fde33d939472b Mon Sep 17 00:00:00 2001 From: Sarah Jamie Lewis Date: Tue, 14 Jul 2020 14:59:08 -0700 Subject: [PATCH] Update Signature --- networks/tor/BaseOnionService.go | 4 ++-- persistence/test.dbgi | Bin 0 -> 32768 bytes service.go | 2 +- .../tapir_malicious_remote_integration_test.go | 2 +- 4 files changed, 4 insertions(+), 4 deletions(-) create mode 100644 persistence/test.dbgi diff --git a/networks/tor/BaseOnionService.go b/networks/tor/BaseOnionService.go index 98ed5ee..fe9c2e5 100644 --- a/networks/tor/BaseOnionService.go +++ b/networks/tor/BaseOnionService.go @@ -106,7 +106,7 @@ func (s *BaseOnionService) Connect(hostname string, app tapir.Application) (bool } log.Debugf("Connected to %v [%v]", hostname, connectionID) - s.connections.Store(connectionID, tapir.NewConnection(s.id, hostname, true, conn, app.NewInstance(), s)) + s.connections.Store(connectionID, tapir.NewConnection(s, s.id, hostname, true, conn, app.NewInstance())) return true, nil } log.Debugf("Error connecting to %v %v", hostname, err) @@ -137,7 +137,7 @@ func (s *BaseOnionService) Listen(app tapir.Application) error { if err == nil { tempHostname := s.getNewConnectionID() log.Debugf("Accepted connection from %v", tempHostname) - s.connections.Store(tempHostname, tapir.NewConnection(s.id, tempHostname, false, conn, app.NewInstance(), s)) + s.connections.Store(tempHostname, tapir.NewConnection(s, s.id, tempHostname, false, conn, app.NewInstance())) } else { log.Debugf("Error accepting connection %v", err) return err diff --git a/persistence/test.dbgi b/persistence/test.dbgi new file mode 100644 index 0000000000000000000000000000000000000000..040d2d0043705f54f315a0f018f4c338fc1d22c0 GIT binary patch literal 32768 zcmeI(Jx;?g6aZjTex^!vXJJNcOe~0lAfZZRf~Hbw8G4W&jysf*sv9=(lRyH&(5f9i zONpJtiLGyYeojhVIjZ&YwZH6@_Tc;d`Zyie#!0O|`{s6gb#^%)t>2=bng9U;1PBly zK!5-N0t5&U*dKv|I+fqz|A_Bn#)q{L@qb*O-YwoQR@XPtPfdUT0RjXF5FkK+009C7 z2<(qQ#P_|_tpt>FN&T1j{x%=e@nh3I=f;mE-YO5vTm5{Lm4wN#eHf4KUxrV!W;&TQ z`IbU}009C72oNAZfB*pk1PJU*AoBNv)U5=>K7iQgzq5%Mm;eC+1PBlyK!5-N0t5&U z*qA`X`;p22n*Tq~qx_Zs-`GTahyVcs1PBlyK!5-N0t5&U*qT7(`6K@y{{zInfUOPe z!vqKrAV7cs0RjXF5FkK+009C72oNAZfB*pk1PBlyK!5-N0t5&UAV7cs0RjXF5FkK+ Iz`q4P04I|f@Bjb+ literal 0 HcmV?d00001 diff --git a/service.go b/service.go index 22452b2..4534644 100644 --- a/service.go +++ b/service.go @@ -58,7 +58,7 @@ type connection struct { } // NewConnection creates a new Connection -func NewConnection(id *primitives.Identity, hostname string, outbound bool, conn io.ReadWriteCloser, app Application, service Service) Connection { +func NewConnection(service Service, id *primitives.Identity, hostname string, outbound bool, conn io.ReadWriteCloser, app Application) Connection { connection := new(connection) connection.hostname = hostname connection.conn = conn diff --git a/testing/tapir_malicious_remote_integration_test.go b/testing/tapir_malicious_remote_integration_test.go index 5e4b8cb..e80ab95 100644 --- a/testing/tapir_malicious_remote_integration_test.go +++ b/testing/tapir_malicious_remote_integration_test.go @@ -64,7 +64,7 @@ func TestTapirMaliciousRemote(t *testing.T) { log.Infof("closing ACN...") acn.Close() sg.Wait() - time.Sleep(time.Second * 2) + time.Sleep(time.Second * 5) // wait for goroutines to finish... log.Infof("Number of goroutines open at close: %d", runtime.NumGoroutine()) if numRoutinesStart != runtime.NumGoroutine() { t.Errorf("Potential goroutine leak: Num Start:%v NumEnd: %v", numRoutinesStart, runtime.NumGoroutine())