Lines 453-459
Link Here
|
453 |
@@ -1003,7 +1209,12 @@ dp_netdev_port_input(struct dp_netdev *dp, struct dp_netdev_port *port, |
453 |
@@ -1003,7 +1209,12 @@ dp_netdev_port_input(struct dp_netdev *dp, struct dp_netdev_port *port, |
454 |
return; |
454 |
return; |
455 |
} |
455 |
} |
456 |
flow_extract(packet, 0, 0, port->port_no, &key); |
456 |
flow_extract(packet, 0, 0, odp_port_to_ofp_port(port->port_no), &key); |
457 |
+#ifdef THREADED |
457 |
+#ifdef THREADED |
458 |
+ pthread_mutex_lock(&dp->table_mutex); |
458 |
+ pthread_mutex_lock(&dp->table_mutex); |
459 |
+ flow = dp_netdev_lookup_flow_locked(dp, &key); |
459 |
+ flow = dp_netdev_lookup_flow_locked(dp, &key); |
Lines 1205-1223
Link Here
|
1205 |
int netdev_drain(struct netdev *); |
1205 |
int netdev_drain(struct netdev *); |
1206 |
int netdev_send(struct netdev *, const struct ofpbuf *); |
1206 |
int netdev_send(struct netdev *, const struct ofpbuf *); |
1207 |
diff --git lib/route-table-bsd.c lib/route-table-bsd.c |
|
|
1208 |
index c145091..1c29071 100644 |
1209 |
--- lib/route-table-bsd.c |
1210 |
+++ lib/route-table-bsd.c |
1211 |
@@ -29,6 +29,8 @@ |
1212 |
#include <string.h> |
1213 |
#include <unistd.h> |
1214 |
|
1215 |
+#include "vlog.h" |
1216 |
+ |
1217 |
VLOG_DEFINE_THIS_MODULE(route_table); |
1218 |
|
1219 |
static int pid; |
1220 |
diff --git lib/vlog.c lib/vlog.c |
1207 |
diff --git lib/vlog.c lib/vlog.c |
1221 |
index 899072e..b6bd4ef 100644 |
1208 |
index 899072e..b6bd4ef 100644 |
1222 |
--- lib/vlog.c |
1209 |
--- lib/vlog.c |