projects
/
openvswitch
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
ofproto: Maximum value of "int" is INT_MAX, not UINT32_MAX.
[openvswitch]
/
lib
/
vconn.c
diff --git
a/lib/vconn.c
b/lib/vconn.c
index d8807fda3e521b46d9a975138f3c408ba6724661..99d5a54d4e8f572293d3f88a70e25365d49f87fa 100644
(file)
--- a/
lib/vconn.c
+++ b/
lib/vconn.c
@@
-25,6
+25,7
@@
#include <string.h>
#include "coverage.h"
#include "dynamic-string.h"
#include <string.h>
#include "coverage.h"
#include "dynamic-string.h"
+#include "fatal-signal.h"
#include "flow.h"
#include "ofp-print.h"
#include "ofpbuf.h"
#include "flow.h"
#include "ofp-print.h"
#include "ofpbuf.h"
@@
-273,6
+274,8
@@
vconn_open_block(const char *name, int min_version, struct vconn **vconnp)
struct vconn *vconn;
int error;
struct vconn *vconn;
int error;
+ fatal_signal_run();
+
error = vconn_open(name, min_version, &vconn);
while (error == EAGAIN) {
vconn_run(vconn);
error = vconn_open(name, min_version, &vconn);
while (error == EAGAIN) {
vconn_run(vconn);
@@
-607,6
+610,9
@@
int
vconn_send_block(struct vconn *vconn, struct ofpbuf *msg)
{
int retval;
vconn_send_block(struct vconn *vconn, struct ofpbuf *msg)
{
int retval;
+
+ fatal_signal_run();
+
while ((retval = vconn_send(vconn, msg)) == EAGAIN) {
vconn_run(vconn);
vconn_run_wait(vconn);
while ((retval = vconn_send(vconn, msg)) == EAGAIN) {
vconn_run(vconn);
vconn_run_wait(vconn);
@@
-621,6
+627,9
@@
int
vconn_recv_block(struct vconn *vconn, struct ofpbuf **msgp)
{
int retval;
vconn_recv_block(struct vconn *vconn, struct ofpbuf **msgp)
{
int retval;
+
+ fatal_signal_run();
+
while ((retval = vconn_recv(vconn, msgp)) == EAGAIN) {
vconn_run(vconn);
vconn_run_wait(vconn);
while ((retval = vconn_recv(vconn, msgp)) == EAGAIN) {
vconn_run(vconn);
vconn_run_wait(vconn);