X-Git-Url: https://pintos-os.org/cgi-bin/gitweb.cgi?a=blobdiff_plain;f=lib%2Fjsonrpc.h;h=b5acf8939e8f460ffb77d9c7f26cbb73a1486cfe;hb=020c93874e22c1c7492c30fe76a8e496571ede13;hp=ff04a547e35e71fe66641f3d8fdaa986a4e43647;hpb=c1ce8fbffb04e006a1698139132439ef0d7e57b2;p=openvswitch diff --git a/lib/jsonrpc.h b/lib/jsonrpc.h index ff04a547..b5acf893 100644 --- a/lib/jsonrpc.h +++ b/lib/jsonrpc.h @@ -1,5 +1,5 @@ /* - * Copyright (c) 2009, 2010, 2012 Nicira Networks. + * Copyright (c) 2009, 2010, 2012 Nicira, Inc. * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. @@ -22,6 +22,7 @@ #include #include +#include "openvswitch/types.h" struct json; struct jsonrpc_msg; @@ -38,8 +39,8 @@ struct stream; #define JSONRPC_TCP_PORT 6632 #define JSONRPC_SSL_PORT 6632 -int jsonrpc_stream_open(const char *name, struct stream **); -int jsonrpc_pstream_open(const char *name, struct pstream **); +int jsonrpc_stream_open(const char *name, struct stream **, uint8_t dscp); +int jsonrpc_pstream_open(const char *name, struct pstream **, uint8_t dscp); struct jsonrpc *jsonrpc_open(struct stream *); void jsonrpc_close(struct jsonrpc *); @@ -49,6 +50,7 @@ void jsonrpc_wait(struct jsonrpc *); int jsonrpc_get_status(const struct jsonrpc *); size_t jsonrpc_get_backlog(const struct jsonrpc *); +unsigned int jsonrpc_get_received_bytes(const struct jsonrpc *); const char *jsonrpc_get_name(const struct jsonrpc *); int jsonrpc_send(struct jsonrpc *, struct jsonrpc_msg *); @@ -97,7 +99,8 @@ 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 *); +struct jsonrpc_session *jsonrpc_session_open_unreliably(struct jsonrpc *, + uint8_t); void jsonrpc_session_close(struct jsonrpc_session *); void jsonrpc_session_run(struct jsonrpc_session *); @@ -123,5 +126,7 @@ void jsonrpc_session_set_max_backoff(struct jsonrpc_session *, int max_backofF); void jsonrpc_session_set_probe_interval(struct jsonrpc_session *, int probe_interval); +void jsonrpc_session_set_dscp(struct jsonrpc_session *, + uint8_t dscp); #endif /* jsonrpc.h */