static int ovs_packet_family;
/* Generic Netlink socket. */
-static struct nl_sock *genl_sock;
static struct nln *nln = NULL;
static int dpif_linux_init(void);
buf = ofpbuf_new(1024);
dpif_linux_vport_to_ofpbuf(&request, buf);
- nl_dump_start(&state->dump, genl_sock, buf);
+ nl_dump_start(&state->dump, NETLINK_GENERIC, buf);
ofpbuf_delete(buf);
return 0;
buf = ofpbuf_new(1024);
dpif_linux_flow_to_ofpbuf(&request, buf);
- nl_dump_start(&state->dump, genl_sock, buf);
+ nl_dump_start(&state->dump, NETLINK_GENERIC, buf);
ofpbuf_delete(buf);
state->buf = NULL;
ofpbuf_use_stub(&request, request_stub, sizeof request_stub);
dpif_linux_encode_execute(dp_ifindex, execute, &request);
- error = nl_sock_transact(genl_sock, &request, NULL);
+ error = nl_transact(NETLINK_GENERIC, &request, NULL);
ofpbuf_uninit(&request);
return error;
for (i = 0; i < n_ops; i++) {
txnsp[i] = &auxes[i].txn;
}
- nl_sock_transact_multiple(genl_sock, txnsp, n_ops);
+ nl_transact_multiple(NETLINK_GENERIC, txnsp, n_ops);
for (i = 0; i < n_ops; i++) {
struct op_auxdata *aux = &auxes[i];
error = nl_lookup_genl_family(OVS_PACKET_FAMILY,
&ovs_packet_family);
}
- if (!error) {
- error = nl_sock_create(NETLINK_GENERIC, &genl_sock);
- }
if (!error) {
error = nl_lookup_genl_mcgroup(OVS_VPORT_FAMILY, OVS_VPORT_MCGROUP,
&ovs_vport_mcgroup,
request_buf = ofpbuf_new(1024);
dpif_linux_vport_to_ofpbuf(request, request_buf);
- error = nl_sock_transact(genl_sock, request_buf, bufp);
+ error = nl_transact(NETLINK_GENERIC, request_buf, bufp);
ofpbuf_delete(request_buf);
if (reply) {
buf = ofpbuf_new(1024);
dpif_linux_dp_to_ofpbuf(&request, buf);
- nl_dump_start(dump, genl_sock, buf);
+ nl_dump_start(dump, NETLINK_GENERIC, buf);
ofpbuf_delete(buf);
}
request_buf = ofpbuf_new(1024);
dpif_linux_dp_to_ofpbuf(request, request_buf);
- error = nl_sock_transact(genl_sock, request_buf, bufp);
+ error = nl_transact(NETLINK_GENERIC, request_buf, bufp);
ofpbuf_delete(request_buf);
if (reply) {
request_buf = ofpbuf_new(1024);
dpif_linux_flow_to_ofpbuf(request, request_buf);
- error = nl_sock_transact(genl_sock, request_buf, bufp);
+ error = nl_transact(NETLINK_GENERIC, request_buf, bufp);
ofpbuf_delete(request_buf);
if (reply) {