mirror of
https://github.com/ipfs/kubo.git
synced 2025-07-03 13:00:37 +08:00
fixed dht race #270
This commit is contained in:
@ -417,14 +417,14 @@ func TestConnectCollision(t *testing.T) {
|
|||||||
|
|
||||||
done := make(chan struct{})
|
done := make(chan struct{})
|
||||||
go func() {
|
go func() {
|
||||||
_, err = dhtA.Connect(ctx, peerB)
|
_, err := dhtA.Connect(ctx, peerB)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
t.Fatal(err)
|
t.Fatal(err)
|
||||||
}
|
}
|
||||||
done <- struct{}{}
|
done <- struct{}{}
|
||||||
}()
|
}()
|
||||||
go func() {
|
go func() {
|
||||||
_, err = dhtB.Connect(ctx, peerA)
|
_, err := dhtB.Connect(ctx, peerA)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
t.Fatal(err)
|
t.Fatal(err)
|
||||||
}
|
}
|
||||||
|
@ -16,6 +16,7 @@ import (
|
|||||||
pb "github.com/jbenet/go-ipfs/routing/dht/pb"
|
pb "github.com/jbenet/go-ipfs/routing/dht/pb"
|
||||||
u "github.com/jbenet/go-ipfs/util"
|
u "github.com/jbenet/go-ipfs/util"
|
||||||
|
|
||||||
|
"sync"
|
||||||
"time"
|
"time"
|
||||||
)
|
)
|
||||||
|
|
||||||
@ -28,15 +29,24 @@ type mesHandleFunc func(msg.NetMessage) msg.NetMessage
|
|||||||
// fauxNet is a standin for a swarm.Network in order to more easily recreate
|
// fauxNet is a standin for a swarm.Network in order to more easily recreate
|
||||||
// different testing scenarios
|
// different testing scenarios
|
||||||
type fauxSender struct {
|
type fauxSender struct {
|
||||||
|
sync.Mutex
|
||||||
handlers []mesHandleFunc
|
handlers []mesHandleFunc
|
||||||
}
|
}
|
||||||
|
|
||||||
func (f *fauxSender) AddHandler(fn func(msg.NetMessage) msg.NetMessage) {
|
func (f *fauxSender) AddHandler(fn func(msg.NetMessage) msg.NetMessage) {
|
||||||
|
f.Lock()
|
||||||
|
defer f.Unlock()
|
||||||
|
|
||||||
f.handlers = append(f.handlers, fn)
|
f.handlers = append(f.handlers, fn)
|
||||||
}
|
}
|
||||||
|
|
||||||
func (f *fauxSender) SendRequest(ctx context.Context, m msg.NetMessage) (msg.NetMessage, error) {
|
func (f *fauxSender) SendRequest(ctx context.Context, m msg.NetMessage) (msg.NetMessage, error) {
|
||||||
for _, h := range f.handlers {
|
f.Lock()
|
||||||
|
handlers := make([]mesHandleFunc, len(f.handlers))
|
||||||
|
copy(handlers, f.handlers)
|
||||||
|
f.Unlock()
|
||||||
|
|
||||||
|
for _, h := range handlers {
|
||||||
reply := h(m)
|
reply := h(m)
|
||||||
if reply != nil {
|
if reply != nil {
|
||||||
return reply, nil
|
return reply, nil
|
||||||
@ -52,7 +62,12 @@ func (f *fauxSender) SendRequest(ctx context.Context, m msg.NetMessage) (msg.Net
|
|||||||
}
|
}
|
||||||
|
|
||||||
func (f *fauxSender) SendMessage(ctx context.Context, m msg.NetMessage) error {
|
func (f *fauxSender) SendMessage(ctx context.Context, m msg.NetMessage) error {
|
||||||
for _, h := range f.handlers {
|
f.Lock()
|
||||||
|
handlers := make([]mesHandleFunc, len(f.handlers))
|
||||||
|
copy(handlers, f.handlers)
|
||||||
|
f.Unlock()
|
||||||
|
|
||||||
|
for _, h := range handlers {
|
||||||
reply := h(m)
|
reply := h(m)
|
||||||
if reply != nil {
|
if reply != nil {
|
||||||
return nil
|
return nil
|
||||||
|
Reference in New Issue
Block a user