diff --git a/cmd/getndf.go b/cmd/getndf.go index 4a4658e543bd6f344838bd54ca96fb3aab766f05..e794fb4d38b6f3d7e0ca82b2b3a2576afef0d6d6 100644 --- a/cmd/getndf.go +++ b/cmd/getndf.go @@ -26,8 +26,8 @@ import ( "gitlab.com/xx_network/primitives/utils" ) -const opensslCertDL = ("openssl s_client -showcerts -connect ip:port < " + - "/dev/null 2>&1 | openssl x509 -outform PEM > certfile.pem") +const opensslCertDL = "openssl s_client -showcerts -connect ip:port < " + + "/dev/null 2>&1 | openssl x509 -outform PEM > certfile.pem" // getNDFCmd user discovery subcommand, allowing user lookup and registration for // allowing others to search. @@ -36,8 +36,8 @@ const opensslCertDL = ("openssl s_client -showcerts -connect ip:port < " + // commands. var getNDFCmd = &cobra.Command{ Use: "getndf", - Short: ("Download the network definition file from the network " + - "and print it."), + Short: "Download the network definition file from the network " + + "and print it.", Args: cobra.NoArgs, Run: func(cmd *cobra.Command, args []string) { gwHost := viper.GetString("gwhost") @@ -67,8 +67,8 @@ var getNDFCmd = &cobra.Command{ Partial: &pb.NDFHash{ Hash: nil, }, - LastUpdate: uint64(0), - ClientID: id.DummyUser.Marshal(), + LastUpdate: uint64(0), + ReceptionID: id.DummyUser.Marshal(), } resp, err := comms.SendPoll(host, pollMsg) if err != nil { diff --git a/network/message/garbled_test.go b/network/message/garbled_test.go index 7b5dd1864db860264860b1d8d71ccb2ff3633d58..3eba869110b15355a0cc3b8035480e530d67916e 100644 --- a/network/message/garbled_test.go +++ b/network/message/garbled_test.go @@ -64,7 +64,7 @@ func TestManager_CheckGarbledMessages(t *testing.T) { }, nil) e2ekv := i.Session.E2e() - err = e2ekv.AddPartner(sess2.GetUser().ID, sess2.E2e().GetDHPublicKey(), e2ekv.GetDHPrivateKey(), + err = e2ekv.AddPartner(sess2.GetUser().ReceptionID, sess2.E2e().GetDHPublicKey(), e2ekv.GetDHPrivateKey(), params.GetDefaultE2ESessionParams(), params.GetDefaultE2ESessionParams()) if err != nil { @@ -72,7 +72,7 @@ func TestManager_CheckGarbledMessages(t *testing.T) { t.FailNow() } - err = sess2.E2e().AddPartner(sess1.GetUser().ID, + err = sess2.E2e().AddPartner(sess1.GetUser().ReceptionID, sess1.E2e().GetDHPublicKey(), sess2.E2e().GetDHPrivateKey(), params.GetDefaultE2ESessionParams(), params.GetDefaultE2ESessionParams()) diff --git a/network/rounds/check.go b/network/rounds/check.go index 81568b75b8d43c167aeac408155cf1cd88ed7862..d029546f32603e3f20fa4c3e37c9d257993bb581 100644 --- a/network/rounds/check.go +++ b/network/rounds/check.go @@ -45,7 +45,7 @@ func (m *Manager) Checker(roundID id.Round, filters []*RemoteFilter, identity re } //find filters that could have the round - var potentialFilters []*bloom.Bloom + var potentialFilters []*bloom.Ring for _, filter := range filters { if filter.FirstRound() <= roundID && filter.LastRound() >= roundID { diff --git a/network/rounds/remoteFilters.go b/network/rounds/remoteFilters.go index 3209a8261008dde0004319198d80e43e823b73c4..13749312b0b02c77bbe87d923e3a75ab3102e9cb 100644 --- a/network/rounds/remoteFilters.go +++ b/network/rounds/remoteFilters.go @@ -17,10 +17,10 @@ func NewRemoteFilter(data *mixmessages.ClientBloom) *RemoteFilter { type RemoteFilter struct { data *mixmessages.ClientBloom - filter *bloom.Bloom + filter *bloom.Ring } -func (rf *RemoteFilter) GetFilter() *bloom.Bloom { +func (rf *RemoteFilter) GetFilter() *bloom.Ring { if rf.filter == nil { var err error diff --git a/storage/e2e/session.go b/storage/e2e/session.go index 6feedbebb95a7ecf86d2bd3e2e0248c2b7b8947d..43eacbf80f676c1eeefbab5adcb395b31cbcd08a 100644 --- a/storage/e2e/session.go +++ b/storage/e2e/session.go @@ -562,7 +562,7 @@ func (s *Session) generate(kv *versioned.KV) *versioned.KV { numKeys = keysTTL + uint32(p.NumRekeys) } - s.ttl = uint32(s.params.NumRekeys) + s.ttl = uint32(s.e2eParams.NumRekeys) //create the new state vectors. This will cause disk operations storing them