struct list sessions; /* List of "struct ovsdb_jsonrpc_session"s. */
unsigned int n_sessions, max_sessions;
- unsigned int max_triggers;
struct pstream **listeners;
size_t n_listeners, allocated_listeners;
struct ovsdb_jsonrpc_server *server = xzalloc(sizeof *server);
server->db = db;
server->max_sessions = 64;
- server->max_triggers = 64;
list_init(&server->sessions);
return server;
}
-int
-ovsdb_jsonrpc_server_listen(struct ovsdb_jsonrpc_server *svr, const char *name)
+void
+ovsdb_jsonrpc_server_listen(struct ovsdb_jsonrpc_server *svr,
+ struct pstream *pstream)
{
- struct pstream *pstream;
- int error;
-
- error = pstream_open(name, &pstream);
- if (error) {
- return error;
- }
-
if (svr->n_listeners >= svr->allocated_listeners) {
svr->listeners = x2nrealloc(svr->listeners, &svr->allocated_listeners,
sizeof *svr->listeners);
}
svr->listeners[svr->n_listeners++] = pstream;
- return 0;
}
void