Move Autoconf's macro definitions into config.h.
[sliver-openvswitch.git] / lib / vconn-netlink.c
1 /* Copyright (c) 2008 The Board of Trustees of The Leland Stanford
2  * Junior University
3  * 
4  * We are making the OpenFlow specification and associated documentation
5  * (Software) available for public use and benefit with the expectation
6  * that others will use, modify and enhance the Software and contribute
7  * those enhancements back to the community. However, since we would
8  * like to make the Software available for broadest use, with as few
9  * restrictions as possible permission is hereby granted, free of
10  * charge, to any person obtaining a copy of this Software to deal in
11  * the Software under the copyrights without restriction, including
12  * without limitation the rights to use, copy, modify, merge, publish,
13  * distribute, sublicense, and/or sell copies of the Software, and to
14  * permit persons to whom the Software is furnished to do so, subject to
15  * the following conditions:
16  * 
17  * The above copyright notice and this permission notice shall be
18  * included in all copies or substantial portions of the Software.
19  * 
20  * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
21  * EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
22  * MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
23  * NONINFRINGEMENT.  IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS
24  * BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN
25  * ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN
26  * CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
27  * SOFTWARE.
28  * 
29  * The name and trademarks of copyright holder(s) may NOT be used in
30  * advertising or publicity pertaining to the Software or any
31  * derivatives without specific, written prior permission.
32  */
33
34 #include <config.h>
35 #include "vconn.h"
36 #include <arpa/inet.h>
37 #include <assert.h>
38 #include <errno.h>
39 #include <netdb.h>
40 #include <poll.h>
41 #include <netinet/in.h>
42 #include <netinet/tcp.h>
43 #include <stdlib.h>
44 #include <string.h>
45 #include <unistd.h>
46 #include "openflow-netlink.h"
47 #include "buffer.h"
48 #include "dpif.h"
49 #include "netlink.h"
50 #include "poll-loop.h"
51 #include "socket-util.h"
52 #include "util.h"
53 #include "openflow.h"
54
55 #include "vlog.h"
56 #define THIS_MODULE VLM_VCONN_NETLINK
57
58 struct netlink_vconn
59 {
60     struct vconn vconn;
61     struct dpif dp;
62 };
63
64 static struct netlink_vconn *
65 netlink_vconn_cast(struct vconn *vconn) 
66 {
67     assert(vconn->class == &netlink_vconn_class);
68     return CONTAINER_OF(vconn, struct netlink_vconn, vconn); 
69 }
70
71 static int
72 netlink_open(const char *name, char *suffix, struct vconn **vconnp)
73 {
74     struct netlink_vconn *netlink;
75     int dp_idx;
76     int subscribe;
77     int retval;
78
79     subscribe = 1;
80     if (sscanf(suffix, "%d:%d", &dp_idx, &subscribe) < 1) {
81         error(0, "%s: syntax error", name);
82         return EAFNOSUPPORT;
83     }
84
85     netlink = xmalloc(sizeof *netlink);
86     netlink->vconn.class = &netlink_vconn_class;
87     netlink->vconn.connect_status = 0;
88     netlink->vconn.ip = 0;
89     retval = dpif_open(dp_idx, subscribe, &netlink->dp);
90     if (retval) {
91         free(netlink);
92         *vconnp = NULL;
93         return retval;
94     }
95     *vconnp = &netlink->vconn;
96     return 0;
97 }
98
99 static void
100 netlink_close(struct vconn *vconn) 
101 {
102     struct netlink_vconn *netlink = netlink_vconn_cast(vconn);
103     dpif_close(&netlink->dp);
104     free(netlink);
105 }
106
107 static int
108 netlink_recv(struct vconn *vconn, struct buffer **bufferp)
109 {
110     struct netlink_vconn *netlink = netlink_vconn_cast(vconn);
111     return dpif_recv_openflow(&netlink->dp, bufferp, false);
112 }
113
114 static int
115 netlink_send(struct vconn *vconn, struct buffer *buffer) 
116 {
117     struct netlink_vconn *netlink = netlink_vconn_cast(vconn);
118     int retval = dpif_send_openflow(&netlink->dp, buffer, false);
119     if (!retval) {
120         buffer_delete(buffer);
121     }
122     return retval;
123 }
124
125 static void
126 netlink_wait(struct vconn *vconn, enum vconn_wait_type wait) 
127 {
128     struct netlink_vconn *netlink = netlink_vconn_cast(vconn);
129     short int events = 0;
130     switch (wait) {
131     case WAIT_RECV:
132         events = POLLIN;
133         break;
134
135     case WAIT_SEND:
136         events = 0;
137         break;
138
139     default:
140         NOT_REACHED();
141     }
142     poll_fd_wait(nl_sock_fd(netlink->dp.sock), events);
143 }
144
145 struct vconn_class netlink_vconn_class = {
146     .name = "nl",
147     .open = netlink_open,
148     .close = netlink_close,
149     .recv = netlink_recv,
150     .send = netlink_send,
151     .wait = netlink_wait,
152 };