2 * Copyright (C) 2001 Lennert Buytenhek (buytenh@gnu.org) and
3 * James Leu (jleu@mindspring.net).
4 * Copyright (C) 2001 by various other people who didn't put their name here.
5 * Licensed under the GPL.
11 #include <sys/socket.h>
16 #include "kern_util.h"
19 #include "um_malloc.h"
21 #define MAX_PACKET (ETH_MAX_PACKET + ETH_HEADER_OTHER)
23 enum request_type
{ REQ_NEW_CONTROL
};
25 #define SWITCH_MAGIC 0xfeedface
30 enum request_type type
;
31 struct sockaddr_un sock
;
34 static struct sockaddr_un
*new_addr(void *name
, int len
)
36 struct sockaddr_un
*sun
;
38 sun
= um_kmalloc(sizeof(struct sockaddr_un
));
40 printk("new_addr: allocation of sockaddr_un failed\n");
43 sun
->sun_family
= AF_UNIX
;
44 memcpy(sun
->sun_path
, name
, len
);
48 static int connect_to_switch(struct daemon_data
*pri
)
50 struct sockaddr_un
*ctl_addr
= pri
->ctl_addr
;
51 struct sockaddr_un
*local_addr
= pri
->local_addr
;
52 struct sockaddr_un
*sun
;
53 struct request_v3 req
;
56 pri
->control
= socket(AF_UNIX
, SOCK_STREAM
, 0);
59 printk("daemon_open : control socket failed, errno = %d\n",
64 if(connect(pri
->control
, (struct sockaddr
*) ctl_addr
,
65 sizeof(*ctl_addr
)) < 0){
67 printk("daemon_open : control connect failed, errno = %d\n",
72 fd
= socket(AF_UNIX
, SOCK_DGRAM
, 0);
75 printk("daemon_open : data socket failed, errno = %d\n",
79 if(bind(fd
, (struct sockaddr
*) local_addr
, sizeof(*local_addr
)) < 0){
81 printk("daemon_open : data bind failed, errno = %d\n",
86 sun
= um_kmalloc(sizeof(struct sockaddr_un
));
88 printk("new_addr: allocation of sockaddr_un failed\n");
93 req
.magic
= SWITCH_MAGIC
;
94 req
.version
= SWITCH_VERSION
;
95 req
.type
= REQ_NEW_CONTROL
;
96 req
.sock
= *local_addr
;
97 n
= os_write_file(pri
->control
, &req
, sizeof(req
));
99 printk("daemon_open : control setup request failed, err = %d\n",
105 n
= os_read_file(pri
->control
, sun
, sizeof(*sun
));
106 if(n
!= sizeof(*sun
)){
107 printk("daemon_open : read of data socket failed, err = %d\n",
113 pri
->data_addr
= sun
;
121 os_close_file(pri
->control
);
125 static int daemon_user_init(void *data
, void *dev
)
127 struct daemon_data
*pri
= data
;
135 if(!strcmp(pri
->sock_type
, "unix"))
136 pri
->ctl_addr
= new_addr(pri
->ctl_sock
,
137 strlen(pri
->ctl_sock
) + 1);
139 name
.pid
= os_getpid();
140 gettimeofday(&tv
, NULL
);
141 name
.usecs
= tv
.tv_usec
;
142 pri
->local_addr
= new_addr(&name
, sizeof(name
));
144 pri
->fd
= connect_to_switch(pri
);
146 kfree(pri
->local_addr
);
147 pri
->local_addr
= NULL
;
154 static int daemon_open(void *data
)
156 struct daemon_data
*pri
= data
;
160 static void daemon_remove(void *data
)
162 struct daemon_data
*pri
= data
;
164 os_close_file(pri
->fd
);
166 os_close_file(pri
->control
);
169 kfree(pri
->data_addr
);
170 pri
->data_addr
= NULL
;
171 kfree(pri
->ctl_addr
);
172 pri
->ctl_addr
= NULL
;
173 kfree(pri
->local_addr
);
174 pri
->local_addr
= NULL
;
177 int daemon_user_write(int fd
, void *buf
, int len
, struct daemon_data
*pri
)
179 struct sockaddr_un
*data_addr
= pri
->data_addr
;
181 return net_sendto(fd
, buf
, len
, data_addr
, sizeof(*data_addr
));
184 static int daemon_set_mtu(int mtu
, void *data
)
189 const struct net_user_info daemon_user_info
= {
190 .init
= daemon_user_init
,
193 .remove
= daemon_remove
,
194 .set_mtu
= daemon_set_mtu
,
196 .delete_address
= NULL
,
197 .max_packet
= MAX_PACKET
- ETH_HEADER_OTHER