X-Git-Url: http://git.onelab.eu/?a=blobdiff_plain;f=lib%2Fnetlink-socket.h;h=78dd7b23a1375a22c796f7779eb0b1a4043ad3b3;hb=a39c3ff9f586d3416976d3c3bd095fa81d73efa0;hp=ff2485837f6046da56be75fbdf5330c47105aac2;hpb=50802adb0e00bbf381c31b9e32a7a6a3e920e7ac;p=sliver-openvswitch.git diff --git a/lib/netlink-socket.h b/lib/netlink-socket.h index ff2485837..78dd7b23a 100644 --- a/lib/netlink-socket.h +++ b/lib/netlink-socket.h @@ -1,5 +1,5 @@ /* - * Copyright (c) 2008, 2009, 2010, 2011 Nicira Networks. + * Copyright (c) 2008, 2009, 2010, 2011, 2012 Nicira, Inc. * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. @@ -35,8 +35,8 @@ #include #include #include +#include "ofpbuf.h" -struct ofpbuf; struct nl_sock; #ifndef HAVE_NETLINK @@ -52,21 +52,43 @@ int nl_sock_join_mcgroup(struct nl_sock *, unsigned int multicast_group); int nl_sock_leave_mcgroup(struct nl_sock *, unsigned int multicast_group); int nl_sock_send(struct nl_sock *, const struct ofpbuf *, bool wait); -int nl_sock_recv(struct nl_sock *, struct ofpbuf **, bool wait); +int nl_sock_send_seq(struct nl_sock *, const struct ofpbuf *, + uint32_t nlmsg_seq, bool wait); +int nl_sock_recv(struct nl_sock *, struct ofpbuf *, bool wait); int nl_sock_transact(struct nl_sock *, const struct ofpbuf *request, - struct ofpbuf **reply); + struct ofpbuf **replyp); int nl_sock_drain(struct nl_sock *); void nl_sock_wait(const struct nl_sock *, short int events); +int nl_sock_fd(const struct nl_sock *); uint32_t nl_sock_pid(const struct nl_sock *); +/* Batching transactions. */ +struct nl_transaction { + /* Filled in by client. */ + struct ofpbuf *request; /* Request to send. */ + + /* The client must initialize 'reply' to one of: + * + * - NULL, if it does not care to examine the reply. + * + * - Otherwise, to an ofpbuf with a memory allocation of at least + * NLMSG_HDRLEN bytes. + */ + struct ofpbuf *reply; /* Reply (empty if reply was an error code). */ + int error; /* Positive errno value, 0 if no error. */ +}; + +void nl_sock_transact_multiple(struct nl_sock *, + struct nl_transaction **, size_t n); + /* Table dumping. */ struct nl_dump { struct nl_sock *sock; /* Socket being dumped. */ uint32_t seq; /* Expected nlmsg_seq for replies. */ - struct ofpbuf *buffer; /* Receive buffer currently being iterated. */ + struct ofpbuf buffer; /* Receive buffer currently being iterated. */ int status; /* 0=OK, EOF=done, or positive errno value. */ };