X-Git-Url: https://pintos-os.org/cgi-bin/gitweb.cgi?a=blobdiff_plain;ds=sidebyside;f=lib%2Fjsonrpc.h;h=ae8b9de3137b7333761a01b39ae895cf17d9cd57;hb=26ad129e69fc7c800630dbd541dc2dcc8150c3a4;hp=e6d11ac511c48d9bf94f4dc92ba24e27846874f6;hpb=d0632593feacc7942fa1650baf07e1e0b8dd1676;p=openvswitch diff --git a/lib/jsonrpc.h b/lib/jsonrpc.h index e6d11ac5..ae8b9de3 100644 --- a/lib/jsonrpc.h +++ b/lib/jsonrpc.h @@ -67,7 +67,8 @@ struct jsonrpc_msg { }; struct jsonrpc_msg *jsonrpc_create_request(const char *method, - struct json *params); + struct json *params, + struct json **idp); struct jsonrpc_msg *jsonrpc_create_notify(const char *method, struct json *params); struct jsonrpc_msg *jsonrpc_create_reply(struct json *result, @@ -81,5 +82,26 @@ void jsonrpc_msg_destroy(struct jsonrpc_msg *); char *jsonrpc_msg_from_json(struct json *, struct jsonrpc_msg **); struct json *jsonrpc_msg_to_json(struct jsonrpc_msg *); + +/* A JSON-RPC session with reconnection. */ + +struct jsonrpc_session *jsonrpc_session_open(const char *name); +struct jsonrpc_session *jsonrpc_session_open_unreliably(struct jsonrpc *); +void jsonrpc_session_close(struct jsonrpc_session *); + +void jsonrpc_session_run(struct jsonrpc_session *); +void jsonrpc_session_wait(struct jsonrpc_session *); + +size_t jsonrpc_session_get_backlog(const struct jsonrpc_session *); +const char *jsonrpc_session_get_name(const struct jsonrpc_session *); + +int jsonrpc_session_send(struct jsonrpc_session *, struct jsonrpc_msg *); +struct jsonrpc_msg *jsonrpc_session_recv(struct jsonrpc_session *); +void jsonrpc_session_recv_wait(struct jsonrpc_session *); + +bool jsonrpc_session_is_alive(const struct jsonrpc_session *); +bool jsonrpc_session_is_connected(const struct jsonrpc_session *); +unsigned int jsonrpc_session_get_seqno(const struct jsonrpc_session *); +void jsonrpc_session_force_reconnect(struct jsonrpc_session *); #endif /* jsonrpc.h */