Skip to content
Snippets Groups Projects
Commit e2fc8272 authored by Benjamin Wenger's avatar Benjamin Wenger
Browse files

added a pritn fo all received bloom fitlers

parent 028610ea
No related branches found
No related tags found
No related merge requests found
...@@ -95,7 +95,7 @@ func (m *manager) follow(rng csprng.Source, comms followNetworkComms) { ...@@ -95,7 +95,7 @@ func (m *manager) follow(rng csprng.Source, comms followNetworkComms) {
} }
jww.DEBUG.Printf("Executing poll for %v(%s) range: %s-%s(%s) from %s", jww.DEBUG.Printf("Executing poll for %v(%s) range: %s-%s(%s) from %s",
identity.EphId.Int64(), identity.Source, identity.StartRequest, identity.EphId.Int64(), identity.Source, identity.StartRequest,
identity.EndRequest, identity.EndRequest.Sub(identity.StartRequest), gwHost) identity.EndRequest, identity.EndRequest.Sub(identity.StartRequest), gwHost.GetId())
pollResp, err := comms.SendPoll(gwHost, &pollReq) pollResp, err := comms.SendPoll(gwHost, &pollReq)
if err != nil { if err != nil {
...@@ -207,6 +207,7 @@ func (m *manager) follow(rng csprng.Source, comms followNetworkComms) { ...@@ -207,6 +207,7 @@ func (m *manager) follow(rng csprng.Source, comms followNetworkComms) {
//prepare the filter objects for processing //prepare the filter objects for processing
filterList := make([]*rounds.RemoteFilter, filtersEnd-filtersStart) filterList := make([]*rounds.RemoteFilter, filtersEnd-filtersStart)
for i := filtersStart; i < filtersEnd; i++ { for i := filtersStart; i < filtersEnd; i++ {
jww.INFO.Printf("ima spam blooms: first: %d, last: %s, filter: %v", pollResp.Filters.Filters[i].FirstRound, pollResp.Filters.Filters[i].FirstRound+uint64(pollResp.Filters.Filters[i].RoundRange), pollResp.Filters.Filters[i].Filter)
filterList[i-filtersStart] = rounds.NewRemoteFilter(pollResp.Filters.Filters[i]) filterList[i-filtersStart] = rounds.NewRemoteFilter(pollResp.Filters.Filters[i])
} }
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment