summaryrefslogtreecommitdiff
path: root/eth-multiplexer/device_impl.c
diff options
context:
space:
mode:
Diffstat (limited to 'eth-multiplexer/device_impl.c')
-rw-r--r--eth-multiplexer/device_impl.c213
1 files changed, 213 insertions, 0 deletions
diff --git a/eth-multiplexer/device_impl.c b/eth-multiplexer/device_impl.c
new file mode 100644
index 00000000..d96fc0f0
--- /dev/null
+++ b/eth-multiplexer/device_impl.c
@@ -0,0 +1,213 @@
+/*
+ Copyright (C) 2008 Free Software Foundation, Inc.
+ Written by Zheng Da.
+
+ This file is part of the GNU Hurd.
+
+ The GNU Hurd is free software; you can redistribute it and/or modify
+ it under the terms of the GNU General Public License as published by
+ the Free Software Foundation; either version 2, or (at your option)
+ any later version.
+
+ The GNU Hurd is distributed in the hope that it will be useful,
+ but WITHOUT ANY WARRANTY; without even the implied warranty of
+ MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+ GNU General Public License for more details.
+
+ You should have received a copy of the GNU General Public License
+ along with the GNU Hurd; see the file COPYING. If not, write to
+ the Free Software Foundation, 675 Mass Ave, Cambridge, MA 02139, USA. */
+
+#include <fcntl.h>
+#include <mach.h>
+#include <hurd.h>
+#include <hurd/ports.h>
+#include <hurd/netfs.h>
+#include <device/device.h>
+
+#include "ethernet.h"
+#include "vdev.h"
+#include "device_S.h"
+#include "notify_S.h"
+#include "bpf_impl.h"
+#include "netfs_impl.h"
+#include "util.h"
+
+extern struct port_bucket *port_bucket;
+extern struct port_class *vdev_portclass;
+extern struct port_class *other_portclass;
+extern struct port_info *notify_pi;
+
+/* Implementation of device interface */
+
+/*
+ * This function is currently running in the multithread environment,
+ * it should be protected by locks.
+ */
+kern_return_t
+ds_device_open (mach_port_t master_port, mach_port_t reply_port,
+ mach_msg_type_name_t reply_portPoly,
+ dev_mode_t mode, dev_name_t name, mach_port_t *device,
+ mach_msg_type_name_t *devicetype)
+{
+ struct vether_device *dev;
+ struct protid *pi = ports_lookup_port (netfs_port_bucket, master_port, 0);
+ if (pi == NULL)
+ return D_NO_SUCH_DEVICE;
+
+ /* If the virtual device hasn't been created yet,
+ * create it now. */
+ if (pi->po->np->nn->ln == NULL)
+ {
+ extern struct port_bucket *port_bucket;
+ extern struct port_class *vdev_portclass;
+ extern struct stat underlying_node_stat;
+ static int ino_count = 0;
+ /* Create a new light node (virtual device). */
+ struct lnode *ln = (struct lnode *) add_vdev (pi->po->np->nn->name,
+ sizeof (*ln),
+ vdev_portclass,
+ port_bucket);
+ if (ln == NULL)
+ {
+ ports_port_deref (pi);
+ return D_NO_MEMORY;
+ }
+ memset (&ln->st, 0, sizeof (ln->st));
+ ln->st.st_ino = ++ino_count;
+ ln->st.st_mode = S_IFCHR | (underlying_node_stat.st_mode & ~S_IFMT);
+ ln->st.st_ctime = ln->st.st_mtime = ln->st.st_atime = time (NULL);
+ fshelp_touch (&ln->st, TOUCH_ATIME|TOUCH_MTIME|TOUCH_CTIME,
+ multiplexer_maptime);
+ pi->po->np->nn->ln = ln;
+ }
+
+ dev = (struct vether_device *) pi->po->np->nn->ln;
+ if (dev)
+ {
+ *device = dev->dev_port;
+ *devicetype = MACH_MSG_TYPE_MAKE_SEND;
+ return 0;
+ }
+ return D_NO_SUCH_DEVICE;
+}
+
+kern_return_t
+ds_device_close (struct vether_device *device)
+{
+ return 0;
+}
+
+kern_return_t
+ds_device_write (struct vether_device *vdev, mach_port_t reply_port,
+ mach_msg_type_name_t reply_type, dev_mode_t mode,
+ recnum_t recnum, io_buf_ptr_t data, size_t datalen,
+ int *bytes_written)
+{
+ kern_return_t ret = 0;
+ if (vdev == NULL)
+ {
+ vm_deallocate (mach_task_self (), (vm_address_t) data, datalen);
+ return D_NO_SUCH_DEVICE;
+ }
+ /* The packet is forwarded to all virtual interfaces and
+ * the interface which the multiplexer connects to. */
+ broadcast_pack (data, datalen, vdev);
+ *bytes_written = datalen;
+ if(ether_port != MACH_PORT_NULL)
+ ret = device_write (ether_port, mode , recnum ,
+ data, datalen, bytes_written);
+ /* The data in device_write() is transmifered out of line,
+ * so the server-side function has to deallocate it. */
+ vm_deallocate (mach_task_self (), (vm_address_t) data, datalen);
+ return ret;
+}
+
+kern_return_t
+ds_device_write_inband (struct vether_device *vdev, mach_port_t reply_port,
+ mach_msg_type_name_t reply_type, dev_mode_t mode,
+ recnum_t recnum, io_buf_ptr_inband_t data,
+ size_t datalen, int *bytes_written)
+{
+ if (vdev == NULL)
+ return D_NO_SUCH_DEVICE;
+ return D_INVALID_OPERATION;
+}
+
+kern_return_t
+ds_device_read (struct vether_device *vdev, mach_port_t reply_port,
+ mach_msg_type_name_t reply_type, dev_mode_t mode,
+ recnum_t recnum, int bytes_wanted,
+ io_buf_ptr_t *data, size_t *datalen)
+{
+ if (vdev == NULL)
+ return D_NO_SUCH_DEVICE;
+ return D_INVALID_OPERATION;
+}
+
+kern_return_t
+ds_device_read_inband (struct vether_device *vdev, mach_port_t reply_port,
+ mach_msg_type_name_t reply_type, dev_mode_t mode,
+ recnum_t recnum, int bytes_wanted,
+ io_buf_ptr_inband_t data, size_t *datalen)
+{
+ if (vdev == NULL)
+ return D_NO_SUCH_DEVICE;
+ return D_INVALID_OPERATION;
+}
+
+kern_return_t
+ds_device_map (struct vether_device *vdev, vm_prot_t prot, vm_offset_t offset,
+ vm_size_t size, memory_object_t *pager, int unmap)
+{
+ if (vdev == NULL)
+ return D_NO_SUCH_DEVICE;
+ return D_INVALID_OPERATION;
+}
+
+kern_return_t
+ds_device_set_status (struct vether_device *vdev, dev_flavor_t flavor,
+ dev_status_t status, size_t statuslen)
+{
+ if (vdev == NULL)
+ return D_NO_SUCH_DEVICE;
+ return D_INVALID_OPERATION;
+}
+
+kern_return_t
+ds_device_get_status (struct vether_device *vdev, dev_flavor_t flavor,
+ dev_status_t status, size_t *statuslen)
+{
+ extern io_return_t dev_getstat (struct vether_device *, dev_flavor_t,
+ dev_status_t, natural_t *);
+ kern_return_t ret = 0;
+ if (vdev == NULL)
+ return D_NO_SUCH_DEVICE;
+ if(ether_port != MACH_PORT_NULL)
+ ret = device_get_status (ether_port, flavor, status, statuslen);
+ else
+ ret = dev_getstat (vdev, flavor, status, statuslen);
+ return ret;
+}
+
+kern_return_t
+ds_device_set_filter (struct vether_device *vdev, mach_port_t receive_port,
+ int priority, filter_array_t filter, size_t filterlen)
+{
+ mach_port_t tmp;
+ kern_return_t err;
+ if (vdev == NULL)
+ return D_NO_SUCH_DEVICE;
+ err = mach_port_request_notification (mach_task_self (), receive_port,
+ MACH_NOTIFY_DEAD_NAME, 0,
+ ports_get_right (notify_pi),
+ MACH_MSG_TYPE_MAKE_SEND_ONCE, &tmp);
+ if (err != KERN_SUCCESS)
+ goto out;
+ if (tmp != MACH_PORT_NULL)
+ mach_port_deallocate (mach_task_self (), tmp);
+ err = net_set_filter (&vdev->port_list, receive_port,
+ priority, filter, filterlen);
+out:
+ return err;
+}
generated by cgit v1.2.3 (git 2.39.1) at 2024-11-15 23:17:15 +0000