server: Don't use buffered channels

This ensures minimal delay between sending a transact response and the update notification being sent via monitor Signed-off-by: Dave Tucker <[email protected]>
ovn-org · Jun 1, 2021 · aa08686 · aa08686
1 parent dd88da9
commit aa08686
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/server/monitor.go b/server/monitor.go
@@ -37,7 +37,7 @@ func newMonitor(id string, request map[string]*ovsdb.MonitorRequest, client *rpc
 		id:      id,
 		request: request,
 		client:  client,
-		updates: make(chan ovsdb.TableUpdates, 10240),
+		updates: make(chan ovsdb.TableUpdates),
 		stopCh:  make(chan struct{}, 1),
 	}
 	go m.sendUpdates()

diff --git a/server/server.go b/server/server.go
@@ -41,7 +41,7 @@ func NewOvsdbServer(db Database, models ...DatabaseModel) (*OvsdbServer, error)
 		modelsMutex:  sync.RWMutex{},
 		monitors:     make(map[*rpc2.Client]*connectionMonitors),
 		monitorMutex: sync.RWMutex{},
-		dbUpdates:    make(chan ovsdb.TableUpdates, 10240),
+		dbUpdates:    make(chan ovsdb.TableUpdates),
 	}
 	o.modelsMutex.Lock()
 	for _, model := range models {