X-Git-Url: https://pintos-os.org/cgi-bin/gitweb.cgi?a=blobdiff_plain;f=lib%2Fjsonrpc.c;h=a83dde9b5ae2b35f9ebc8b2a4bfa6f1940cf1f10;hb=52ce26ee3b13496f65132996120e59ec29ab64c2;hp=32d34b4f1a60fb2cab5ee33c453c927c9c76374d;hpb=36a7b32d790f2cee735520060a9b6221b7ae25ef;p=openvswitch diff --git a/lib/jsonrpc.c b/lib/jsonrpc.c index 32d34b4f..a83dde9b 100644 --- a/lib/jsonrpc.c +++ b/lib/jsonrpc.c @@ -32,9 +32,9 @@ #include "reconnect.h" #include "stream.h" #include "timeval.h" - -#define THIS_MODULE VLM_jsonrpc #include "vlog.h" + +VLOG_DEFINE_THIS_MODULE(jsonrpc); struct jsonrpc { struct stream *stream; @@ -903,8 +903,8 @@ jsonrpc_session_recv(struct jsonrpc_session *s) reply = jsonrpc_create_reply(json_clone(msg->params), msg->id); jsonrpc_session_send(s, reply); } else if (msg->type == JSONRPC_REPLY - && msg->id && msg->id->type == JSON_STRING - && !strcmp(msg->id->u.string, "echo")) { + && msg->id && msg->id->type == JSON_STRING + && !strcmp(msg->id->u.string, "echo")) { /* It's a reply to our echo request. Suppress it. */ } else { return msg; @@ -946,3 +946,16 @@ jsonrpc_session_force_reconnect(struct jsonrpc_session *s) { reconnect_force_reconnect(s->reconnect, time_msec()); } + +void +jsonrpc_session_set_max_backoff(struct jsonrpc_session *s, int max_backoff) +{ + reconnect_set_backoff(s->reconnect, 0, max_backoff); +} + +void +jsonrpc_session_set_probe_interval(struct jsonrpc_session *s, + int probe_interval) +{ + reconnect_set_probe_interval(s->reconnect, probe_interval); +}