2022-08-15 05:33:45 -07:00
|
|
|
package common
|
|
|
|
|
|
|
|
import (
|
2022-08-16 23:06:28 -07:00
|
|
|
"errors"
|
2022-08-15 05:33:45 -07:00
|
|
|
|
|
|
|
gossipv1 "github.com/certusone/wormhole/node/pkg/proto/gossip/v1"
|
|
|
|
)
|
|
|
|
|
|
|
|
const ObsvReqChannelSize = 50
|
|
|
|
|
2022-08-16 23:06:28 -07:00
|
|
|
var ErrChanFull = errors.New("channel is full")
|
2022-08-15 05:33:45 -07:00
|
|
|
|
2022-08-16 23:06:28 -07:00
|
|
|
func PostObservationRequest(obsvReqSendC chan<- *gossipv1.ObservationRequest, req *gossipv1.ObservationRequest) error {
|
|
|
|
select {
|
|
|
|
case obsvReqSendC <- req:
|
|
|
|
return nil
|
|
|
|
default:
|
|
|
|
return ErrChanFull
|
|
|
|
}
|
2022-08-15 05:33:45 -07:00
|
|
|
}
|