2 * user-mode-linux networking multicast transport
3 * Copyright (C) 2001 by Harald Welte <laforge@gnumonks.org>
5 * based on the existing uml-networking code, which is
6 * Copyright (C) 2001 Lennert Buytenhek (buytenh@gnu.org) and
7 * James Leu (jleu@mindspring.net).
8 * Copyright (C) 2001 by various other people who didn't put their name here.
10 * Licensed under the GPL.
16 #include <linux/inet.h>
17 #include <sys/socket.h>
20 #include <netinet/in.h>
23 #include "kern_util.h"
24 #include "user_util.h"
28 #define MAX_PACKET (ETH_MAX_PACKET + ETH_HEADER_OTHER)
30 static struct sockaddr_in *new_addr(char *addr, unsigned short port)
32 struct sockaddr_in *sin;
34 sin = um_kmalloc(sizeof(struct sockaddr_in));
36 printk("new_addr: allocation of sockaddr_in failed\n");
39 sin->sin_family = AF_INET;
40 sin->sin_addr.s_addr = in_aton(addr);
45 static void mcast_user_init(void *data, void *dev)
47 struct mcast_data *pri = data;
49 pri->mcast_addr = new_addr(pri->addr, pri->port);
53 static int mcast_open(void *data)
55 struct mcast_data *pri = data;
56 struct sockaddr_in *sin = pri->mcast_addr;
61 if ((sin->sin_addr.s_addr == 0) || (sin->sin_port == 0)) {
66 fd = socket(AF_INET, SOCK_DGRAM, 0);
68 printk("mcast_open : data socket failed, errno = %d\n",
74 if (setsockopt(fd, SOL_SOCKET, SO_REUSEADDR, &yes, sizeof(yes)) < 0) {
75 printk("mcast_open: SO_REUSEADDR failed, errno = %d\n",
82 /* set ttl according to config */
83 if (setsockopt(fd, SOL_IP, IP_MULTICAST_TTL, &pri->ttl,
84 sizeof(pri->ttl)) < 0) {
85 printk("mcast_open: IP_MULTICAST_TTL failed, error = %d\n",
92 /* set LOOP, so data does get fed back to local sockets */
93 if (setsockopt(fd, SOL_IP, IP_MULTICAST_LOOP, &yes, sizeof(yes)) < 0) {
94 printk("mcast_open: IP_MULTICAST_LOOP failed, error = %d\n",
101 /* bind socket to mcast address */
102 if (bind(fd, (struct sockaddr *) sin, sizeof(*sin)) < 0) {
103 printk("mcast_open : data bind failed, errno = %d\n", errno);
109 /* subscribe to the multicast group */
110 mreq.imr_multiaddr.s_addr = sin->sin_addr.s_addr;
111 mreq.imr_interface.s_addr = 0;
112 if (setsockopt(fd, SOL_IP, IP_ADD_MEMBERSHIP,
113 &mreq, sizeof(mreq)) < 0) {
114 printk("mcast_open: IP_ADD_MEMBERSHIP failed, error = %d\n",
116 printk("There appears not to be a multicast-capable network "
117 "interface on the host.\n");
118 printk("eth0 should be configured in order to use the "
119 "multicast transport.\n");
128 static void mcast_close(int fd, void *data)
131 struct mcast_data *pri = data;
132 struct sockaddr_in *sin = pri->mcast_addr;
134 mreq.imr_multiaddr.s_addr = sin->sin_addr.s_addr;
135 mreq.imr_interface.s_addr = 0;
136 if (setsockopt(fd, SOL_IP, IP_DROP_MEMBERSHIP,
137 &mreq, sizeof(mreq)) < 0) {
138 printk("mcast_open: IP_DROP_MEMBERSHIP failed, error = %d\n",
145 int mcast_user_write(int fd, void *buf, int len, struct mcast_data *pri)
147 struct sockaddr_in *data_addr = pri->mcast_addr;
149 return(net_sendto(fd, buf, len, data_addr, sizeof(*data_addr)));
152 static int mcast_set_mtu(int mtu, void *data)
157 struct net_user_info mcast_user_info = {
158 .init = mcast_user_init,
160 .close = mcast_close,
162 .set_mtu = mcast_set_mtu,
164 .delete_address = NULL,
165 .max_packet = MAX_PACKET - ETH_HEADER_OTHER
169 * Overrides for Emacs so that we follow Linus's tabbing style.
170 * Emacs will notice this stuff at the end of the file and automatically
171 * adjust the settings for this buffer only. This must remain at the end
173 * ---------------------------------------------------------------------------
175 * c-file-style: "linux"