]>
Commit | Line | Data |
---|---|---|
f2129093 | 1 | /* |
fba6bd1d | 2 | * Copyright (c) 2009, 2010, 2012, 2013 Nicira, Inc. |
f2129093 BP |
3 | * |
4 | * Licensed under the Apache License, Version 2.0 (the "License"); | |
5 | * you may not use this file except in compliance with the License. | |
6 | * You may obtain a copy of the License at: | |
7 | * | |
8 | * http://www.apache.org/licenses/LICENSE-2.0 | |
9 | * | |
10 | * Unless required by applicable law or agreed to in writing, software | |
11 | * distributed under the License is distributed on an "AS IS" BASIS, | |
12 | * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. | |
13 | * See the License for the specific language governing permissions and | |
14 | * limitations under the License. | |
15 | */ | |
16 | ||
17 | #ifndef JSONRPC_H | |
18 | #define JSONRPC_H 1 | |
19 | ||
20 | /* This is an implementation of the JSON-RPC 1.0 specification defined at | |
21 | * http://json-rpc.org/wiki/specification. */ | |
22 | ||
23 | #include <stdbool.h> | |
24 | #include <stddef.h> | |
f125905c | 25 | #include "openvswitch/types.h" |
f2129093 BP |
26 | |
27 | struct json; | |
28 | struct jsonrpc_msg; | |
0d11f523 | 29 | struct pstream; |
0b3e7a8b | 30 | struct reconnect_stats; |
f2129093 BP |
31 | struct stream; |
32 | \f | |
33 | /* API for a JSON-RPC stream. */ | |
34 | ||
efc295d2 | 35 | /* Default port numbers. |
0d11f523 | 36 | * |
efc295d2 | 37 | * OVSDB_OLD_PORT defines the original port number used by OVS. |
d4763d1d | 38 | * OVSDB_PORT defines the official port number assigned by IANA. */ |
efc295d2 JP |
39 | #define OVSDB_OLD_PORT 6632 |
40 | #define OVSDB_PORT 6640 | |
0d11f523 | 41 | |
f125905c MM |
42 | int jsonrpc_stream_open(const char *name, struct stream **, uint8_t dscp); |
43 | int jsonrpc_pstream_open(const char *name, struct pstream **, uint8_t dscp); | |
0d11f523 | 44 | |
f2129093 BP |
45 | struct jsonrpc *jsonrpc_open(struct stream *); |
46 | void jsonrpc_close(struct jsonrpc *); | |
47 | ||
48 | void jsonrpc_run(struct jsonrpc *); | |
49 | void jsonrpc_wait(struct jsonrpc *); | |
50 | ||
f2129093 BP |
51 | int jsonrpc_get_status(const struct jsonrpc *); |
52 | size_t jsonrpc_get_backlog(const struct jsonrpc *); | |
3a8d38c8 | 53 | unsigned int jsonrpc_get_received_bytes(const struct jsonrpc *); |
f2129093 BP |
54 | const char *jsonrpc_get_name(const struct jsonrpc *); |
55 | ||
56 | int jsonrpc_send(struct jsonrpc *, struct jsonrpc_msg *); | |
57 | int jsonrpc_recv(struct jsonrpc *, struct jsonrpc_msg **); | |
58 | void jsonrpc_recv_wait(struct jsonrpc *); | |
59 | ||
60 | int jsonrpc_send_block(struct jsonrpc *, struct jsonrpc_msg *); | |
61 | int jsonrpc_recv_block(struct jsonrpc *, struct jsonrpc_msg **); | |
d0632593 BP |
62 | int jsonrpc_transact_block(struct jsonrpc *, struct jsonrpc_msg *, |
63 | struct jsonrpc_msg **); | |
f2129093 BP |
64 | |
65 | /* Messages. */ | |
66 | enum jsonrpc_msg_type { | |
67 | JSONRPC_REQUEST, /* Request. */ | |
68 | JSONRPC_NOTIFY, /* Notification. */ | |
69 | JSONRPC_REPLY, /* Successful reply. */ | |
70 | JSONRPC_ERROR /* Error reply. */ | |
71 | }; | |
72 | ||
73 | struct jsonrpc_msg { | |
74 | enum jsonrpc_msg_type type; | |
75 | char *method; /* Request or notification only. */ | |
76 | struct json *params; /* Request or notification only. */ | |
77 | struct json *result; /* Successful reply only. */ | |
78 | struct json *error; /* Error reply only. */ | |
79 | struct json *id; /* Request or reply only. */ | |
80 | }; | |
81 | ||
82 | struct jsonrpc_msg *jsonrpc_create_request(const char *method, | |
20bed8be BP |
83 | struct json *params, |
84 | struct json **idp); | |
f2129093 BP |
85 | struct jsonrpc_msg *jsonrpc_create_notify(const char *method, |
86 | struct json *params); | |
87 | struct jsonrpc_msg *jsonrpc_create_reply(struct json *result, | |
88 | const struct json *id); | |
89 | struct jsonrpc_msg *jsonrpc_create_error(struct json *error, | |
90 | const struct json *id); | |
91 | ||
92 | const char *jsonrpc_msg_type_to_string(enum jsonrpc_msg_type); | |
93 | char *jsonrpc_msg_is_valid(const struct jsonrpc_msg *); | |
94 | void jsonrpc_msg_destroy(struct jsonrpc_msg *); | |
95 | ||
96 | char *jsonrpc_msg_from_json(struct json *, struct jsonrpc_msg **); | |
97 | struct json *jsonrpc_msg_to_json(struct jsonrpc_msg *); | |
dcbb691b BP |
98 | \f |
99 | /* A JSON-RPC session with reconnection. */ | |
100 | ||
fba6bd1d | 101 | struct jsonrpc_session *jsonrpc_session_open(const char *name, bool retry); |
e879d33e MM |
102 | struct jsonrpc_session *jsonrpc_session_open_unreliably(struct jsonrpc *, |
103 | uint8_t); | |
dcbb691b BP |
104 | void jsonrpc_session_close(struct jsonrpc_session *); |
105 | ||
106 | void jsonrpc_session_run(struct jsonrpc_session *); | |
107 | void jsonrpc_session_wait(struct jsonrpc_session *); | |
108 | ||
109 | size_t jsonrpc_session_get_backlog(const struct jsonrpc_session *); | |
110 | const char *jsonrpc_session_get_name(const struct jsonrpc_session *); | |
111 | ||
112 | int jsonrpc_session_send(struct jsonrpc_session *, struct jsonrpc_msg *); | |
113 | struct jsonrpc_msg *jsonrpc_session_recv(struct jsonrpc_session *); | |
114 | void jsonrpc_session_recv_wait(struct jsonrpc_session *); | |
115 | ||
4931f33a | 116 | bool jsonrpc_session_is_alive(const struct jsonrpc_session *); |
dcbb691b BP |
117 | bool jsonrpc_session_is_connected(const struct jsonrpc_session *); |
118 | unsigned int jsonrpc_session_get_seqno(const struct jsonrpc_session *); | |
0b3e7a8b | 119 | int jsonrpc_session_get_status(const struct jsonrpc_session *); |
fba6bd1d | 120 | int jsonrpc_session_get_last_error(const struct jsonrpc_session *); |
0b3e7a8b AE |
121 | void jsonrpc_session_get_reconnect_stats(const struct jsonrpc_session *, |
122 | struct reconnect_stats *); | |
123 | ||
705d7a39 | 124 | void jsonrpc_session_enable_reconnect(struct jsonrpc_session *); |
dcbb691b | 125 | void jsonrpc_session_force_reconnect(struct jsonrpc_session *); |
f2129093 | 126 | |
94db5407 | 127 | void jsonrpc_session_set_max_backoff(struct jsonrpc_session *, |
b5f0fe21 | 128 | int max_backoff); |
94db5407 BP |
129 | void jsonrpc_session_set_probe_interval(struct jsonrpc_session *, |
130 | int probe_interval); | |
f125905c MM |
131 | void jsonrpc_session_set_dscp(struct jsonrpc_session *, |
132 | uint8_t dscp); | |
d6db7b3c | 133 | const char *jsonrpc_session_get_id(const struct jsonrpc_session *); |
94db5407 | 134 | |
f2129093 | 135 | #endif /* jsonrpc.h */ |