forks/go-ethereum
1
0
Fork 1
mirror of https://github.com/ethereum/go-ethereum.git synced 2026-08-20 10:52:25 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

beacon/light/request: gofmt -w -s

Browse source
This commit is contained in:
Felix Lange 2024-03-06 14:49:57 +01:00
parent dc5e897b56
commit b6674378ae
1 changed files with 6 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
beacon/light/request/scheduler_test.go
View file

@ -21,10 +21,10 @@ func TestEventFilter(t *testing.T) {
s.RegisterServer(srv) s.RegisterServer(srv)
s.testWaitCh <- struct{}{} s.testWaitCh <- struct{}{}
module1.expProcess(t, []Event{ module1.expProcess(t, []Event{
Event{Type: EvRegistered, Server: srv}, {Type: EvRegistered, Server: srv},
}) })
module2.expProcess(t, []Event{ module2.expProcess(t, []Event{
Event{Type: EvRegistered, Server: srv}, {Type: EvRegistered, Server: srv},
}) })
// let module1 send a request // let module1 send a request
srv.canRequest = 1 srv.canRequest = 1
@ -38,7 +38,7 @@ func TestEventFilter(t *testing.T) {
srv.eventCb(Event{Type: EvTimeout, Data: RequestResponse{ID: 1, Request: testRequest}}) srv.eventCb(Event{Type: EvTimeout, Data: RequestResponse{ID: 1, Request: testRequest}})
s.testWaitCh <- struct{}{} s.testWaitCh <- struct{}{}
module1.expProcess(t, []Event{ module1.expProcess(t, []Event{
Event{Type: EvTimeout, Server: srv, Data: RequestResponse{ID: 1, Request: testRequest}}, {Type: EvTimeout, Server: srv, Data: RequestResponse{ID: 1, Request: testRequest}},
}) })
module2.expProcess(t, nil) module2.expProcess(t, nil)
// unregister server; both modules should receive server event // unregister server; both modules should receive server event
@ -46,11 +46,11 @@ func TestEventFilter(t *testing.T) {
s.testWaitCh <- struct{}{} s.testWaitCh <- struct{}{}
module1.expProcess(t, []Event{ module1.expProcess(t, []Event{
// module1 should also receive EvFail on its pending request // module1 should also receive EvFail on its pending request
Event{Type: EvFail, Server: srv, Data: RequestResponse{ID: 1, Request: testRequest}}, {Type: EvFail, Server: srv, Data: RequestResponse{ID: 1, Request: testRequest}},
Event{Type: EvUnregistered, Server: srv}, {Type: EvUnregistered, Server: srv},
}) })
module2.expProcess(t, []Event{ module2.expProcess(t, []Event{
Event{Type: EvUnregistered, Server: srv}, {Type: EvUnregistered, Server: srv},
}) })
// response after server unregistered; should be discarded // response after server unregistered; should be discarded
srv.eventCb(Event{Type: EvResponse, Data: RequestResponse{ID: 1, Request: testRequest, Response: testResponse}}) srv.eventCb(Event{Type: EvResponse, Data: RequestResponse{ID: 1, Request: testRequest, Response: testResponse}})