Open jkmar opened 1 year ago
var reqs []*protos.EnodebdUpdateCbsdRequest send.DpLogs() storage.WithinTx(db, func(tx *sql.Tx) (any, error) { cache := sq.NewStmtCache(tx) for _, r := range reqs { fetchCbsd(cache) diff() update(chate) } }) send.DpLogs(...)
func (c *cbsdManager) EnodebdUpdateCbsd(ctx context.Context, request *protos.EnodebdUpdateCbsdRequest) (*protos.CBSDStateResult, error) { c := make(chan *protos.EnodebdUpdateCbsdRequest) c <- request r := <-response }