]>
git.proxmox.com Git - ovs.git/blob - ofproto/status.c
2 * Copyright (c) 2008, 2009 Nicira Networks.
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:
8 * http://www.apache.org/licenses/LICENSE-2.0
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.
19 #include <arpa/inet.h>
25 #include "dynamic-string.h"
29 #include "openflow/nicira-ext.h"
36 #define THIS_MODULE VLM_status
39 struct status_category
{
42 void (*cb
)(struct status_reply
*, void *aux
);
46 struct switch_status
{
48 struct status_category
*config_cat
;
49 struct status_category
*switch_cat
;
50 struct list categories
;
54 struct status_category
*category
;
60 switch_status_handle_request(struct switch_status
*ss
, struct rconn
*rconn
,
61 struct nicira_header
*request
)
63 struct status_category
*c
;
64 struct nicira_header
*reply
;
65 struct status_reply sr
;
69 sr
.request
.string
= (void *) (request
+ 1);
70 sr
.request
.length
= ntohs(request
->header
.length
) - sizeof *request
;
72 LIST_FOR_EACH (c
, struct status_category
, node
, &ss
->categories
) {
73 if (!memcmp(c
->name
, sr
.request
.string
,
74 MIN(strlen(c
->name
), sr
.request
.length
))) {
79 reply
= make_openflow_xid(sizeof *reply
+ sr
.output
.length
,
80 OFPT_VENDOR
, request
->header
.xid
, &b
);
81 reply
->vendor
= htonl(NX_VENDOR_ID
);
82 reply
->subtype
= htonl(NXT_STATUS_REPLY
);
83 memcpy(reply
+ 1, sr
.output
.string
, sr
.output
.length
);
84 retval
= rconn_send(rconn
, b
, NULL
);
85 if (retval
&& retval
!= EAGAIN
) {
86 VLOG_WARN("send failed (%s)", strerror(retval
));
88 ds_destroy(&sr
.output
);
93 rconn_status_cb(struct status_reply
*sr
, void *rconn_
)
95 struct rconn
*rconn
= rconn_
;
96 time_t now
= time_now();
97 uint32_t remote_ip
= rconn_get_remote_ip(rconn
);
98 uint32_t local_ip
= rconn_get_local_ip(rconn
);
100 status_reply_put(sr
, "name=%s", rconn_get_name(rconn
));
102 status_reply_put(sr
, "remote-ip="IP_FMT
, IP_ARGS(&remote_ip
));
103 status_reply_put(sr
, "remote-port=%d",
104 ntohs(rconn_get_remote_port(rconn
)));
105 status_reply_put(sr
, "local-ip="IP_FMT
, IP_ARGS(&local_ip
));
106 status_reply_put(sr
, "local-port=%d",
107 ntohs(rconn_get_local_port(rconn
)));
109 status_reply_put(sr
, "state=%s", rconn_get_state(rconn
));
110 status_reply_put(sr
, "backoff=%d", rconn_get_backoff(rconn
));
111 status_reply_put(sr
, "probe-interval=%d", rconn_get_probe_interval(rconn
));
112 status_reply_put(sr
, "is-connected=%s",
113 rconn_is_connected(rconn
) ? "true" : "false");
114 status_reply_put(sr
, "sent-msgs=%u", rconn_packets_sent(rconn
));
115 status_reply_put(sr
, "received-msgs=%u", rconn_packets_received(rconn
));
116 status_reply_put(sr
, "attempted-connections=%u",
117 rconn_get_attempted_connections(rconn
));
118 status_reply_put(sr
, "successful-connections=%u",
119 rconn_get_successful_connections(rconn
));
120 status_reply_put(sr
, "last-connection=%ld",
121 (long int) (now
- rconn_get_last_connection(rconn
)));
122 status_reply_put(sr
, "last-received=%ld",
123 (long int) (now
- rconn_get_last_received(rconn
)));
124 status_reply_put(sr
, "time-connected=%lu",
125 rconn_get_total_time_connected(rconn
));
126 status_reply_put(sr
, "state-elapsed=%u", rconn_get_state_elapsed(rconn
));
130 config_status_cb(struct status_reply
*sr
, void *ofproto_
)
132 const struct ofproto
*ofproto
= ofproto_
;
133 uint64_t datapath_id
, mgmt_id
;
134 struct svec listeners
;
135 int probe_interval
, max_backoff
;
138 datapath_id
= ofproto_get_datapath_id(ofproto
);
140 status_reply_put(sr
, "datapath-id=%"PRIx64
, datapath_id
);
143 mgmt_id
= ofproto_get_mgmt_id(ofproto
);
145 status_reply_put(sr
, "mgmt-id=%"PRIx64
, mgmt_id
);
148 svec_init(&listeners
);
149 ofproto_get_listeners(ofproto
, &listeners
);
150 for (i
= 0; i
< listeners
.n
; i
++) {
151 status_reply_put(sr
, "management%zu=%s", i
, listeners
.names
[i
]);
153 svec_destroy(&listeners
);
155 probe_interval
= ofproto_get_probe_interval(ofproto
);
156 if (probe_interval
) {
157 status_reply_put(sr
, "probe-interval=%d", probe_interval
);
160 max_backoff
= ofproto_get_max_backoff(ofproto
);
162 status_reply_put(sr
, "max-backoff=%d", max_backoff
);
167 switch_status_cb(struct status_reply
*sr
, void *ss_
)
169 struct switch_status
*ss
= ss_
;
170 time_t now
= time_now();
172 status_reply_put(sr
, "now=%ld", (long int) now
);
173 status_reply_put(sr
, "uptime=%ld", (long int) (now
- ss
->booted
));
174 status_reply_put(sr
, "pid=%ld", (long int) getpid());
177 struct switch_status
*
178 switch_status_create(const struct ofproto
*ofproto
)
180 struct switch_status
*ss
= xcalloc(1, sizeof *ss
);
181 ss
->booted
= time_now();
182 list_init(&ss
->categories
);
183 ss
->config_cat
= switch_status_register(ss
, "config", config_status_cb
,
185 ss
->switch_cat
= switch_status_register(ss
, "switch", switch_status_cb
,
191 switch_status_destroy(struct switch_status
*ss
)
194 /* Orphan any remaining categories, so that unregistering them later
195 * won't write to bad memory. */
196 struct status_category
*c
, *next
;
197 LIST_FOR_EACH_SAFE (c
, next
,
198 struct status_category
, node
, &ss
->categories
) {
201 switch_status_unregister(ss
->config_cat
);
202 switch_status_unregister(ss
->switch_cat
);
207 struct status_category
*
208 switch_status_register(struct switch_status
*ss
,
209 const char *category
,
210 status_cb_func
*cb
, void *aux
)
212 struct status_category
*c
= xmalloc(sizeof *c
);
215 c
->name
= xstrdup(category
);
216 list_push_back(&ss
->categories
, &c
->node
);
221 switch_status_unregister(struct status_category
*c
)
224 if (!list_is_empty(&c
->node
)) {
225 list_remove(&c
->node
);
233 status_reply_put(struct status_reply
*sr
, const char *content
, ...)
235 size_t old_length
= sr
->output
.length
;
239 /* Append the status reply to the output. */
240 ds_put_format(&sr
->output
, "%s.", sr
->category
->name
);
241 va_start(args
, content
);
242 ds_put_format_valist(&sr
->output
, content
, args
);
244 if (ds_last(&sr
->output
) != '\n') {
245 ds_put_char(&sr
->output
, '\n');
248 /* Drop what we just added if it doesn't match the request. */
249 added
= sr
->output
.length
- old_length
;
250 if (added
< sr
->request
.length
251 || memcmp(&sr
->output
.string
[old_length
],
252 sr
->request
.string
, sr
->request
.length
)) {
253 ds_truncate(&sr
->output
, old_length
);