[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]
[hurd] 05/25: eth-multiplexer: fix receiver lookups
From: |
Samuel Thibault |
Subject: |
[hurd] 05/25: eth-multiplexer: fix receiver lookups |
Date: |
Tue, 27 May 2014 08:32:02 +0000 |
This is an automated email from the git hooks/post-receive script.
sthibault pushed a commit to branch dde
in repository hurd.
commit dc2f85bef2999c94bafc9f21abcc60436f7ad129
Author: Justus Winter <address@hidden>
Date: Tue Apr 8 17:53:55 2014 +0200
eth-multiplexer: fix receiver lookups
Previously, the device definitions were filtered using sed to replace
the device_t type with mach_port_send_t to make the device argument of
device_open polymorphic. Rather than doing that, which makes it
impossible to use translation functions, the definition of device_open
has been amended.
* eth-multiplexer/Makefile: Remove ourdevice hack that changes
device_t to mach_port_send_t.
* eth-multiplexer/multiplexer.c: Likewise.
* eth-multiplexer/device_impl.c: Fix all device_t receiver lookups.
* eth-multiplexer/mig-decls.h: New file.
* eth-multiplexer/mig-mutate.h: Add mutators.
---
eth-multiplexer/Makefile | 6 +--
eth-multiplexer/device_impl.c | 59 ++++++---------------------
eth-multiplexer/{mig-mutate.h => mig-decls.h} | 32 ++++++++++++---
eth-multiplexer/mig-mutate.h | 7 ++++
eth-multiplexer/multiplexer.c | 2 +-
5 files changed, 48 insertions(+), 58 deletions(-)
diff --git a/eth-multiplexer/Makefile b/eth-multiplexer/Makefile
index fcd40f2..fbee1ca 100644
--- a/eth-multiplexer/Makefile
+++ b/eth-multiplexer/Makefile
@@ -21,7 +21,7 @@ target = eth-multiplexer
#CFLAGS += -DDEBUG
SRCS = ethernet.c vdev.c multiplexer.c dev_stat.c netfs_impl.c notify_impl.c
device_impl.c demuxer.c
-MIGSTUBS = ourdeviceServer.o notifyServer.o
+MIGSTUBS = deviceServer.o notifyServer.o
MIGSFLAGS = -imacros $(srcdir)/mig-mutate.h
OBJS = $(SRCS:.c=.o) $(MIGSTUBS)
LCLHDRS = ethernet.h util.h vdev.h netfs_impl.h
@@ -31,7 +31,3 @@ OTHERLIBS = -lpthread
CFLAGS += -I$(top_srcdir)/libbpf
include ../Makeconf
-
-ourdevice.defs: device.defs
- $(CPP) $(CPPFLAGS) -x c $< | sed -e '/out[ ]*device[ ]*:[
]*device_t/s/device_t/mach_port_send_t/' > $@
-
diff --git a/eth-multiplexer/device_impl.c b/eth-multiplexer/device_impl.c
index 459d9c4..35a4da4 100644
--- a/eth-multiplexer/device_impl.c
+++ b/eth-multiplexer/device_impl.c
@@ -27,7 +27,7 @@
#include "ethernet.h"
#include "vdev.h"
-#include "ourdevice_S.h"
+#include "device_S.h"
#include "notify_S.h"
#include "bpf_impl.h"
#include "netfs_impl.h"
@@ -40,38 +40,29 @@ extern struct port_info *notify_pi;
/* Implementation of device interface */
kern_return_t
-ds_xxx_device_set_status (device_t device, dev_flavor_t flavor,
+ds_xxx_device_set_status (struct vether_device *vdev, dev_flavor_t flavor,
dev_status_t status, size_t statu_cnt)
{
- struct vether_device *vdev = ports_lookup_port (port_bucket, device,
- vdev_portclass);
if (vdev == NULL)
return D_NO_SUCH_DEVICE;
- ports_port_deref (vdev);
return D_INVALID_OPERATION;
}
kern_return_t
-ds_xxx_device_get_status (device_t device, dev_flavor_t flavor,
+ds_xxx_device_get_status (struct vether_device *vdev, dev_flavor_t flavor,
dev_status_t status, size_t *statuscnt)
{
- struct vether_device *vdev = ports_lookup_port (port_bucket, device,
- vdev_portclass);
if (vdev == NULL)
return D_NO_SUCH_DEVICE;
- ports_port_deref (vdev);
return D_INVALID_OPERATION;
}
kern_return_t
-ds_xxx_device_set_filter (device_t device, mach_port_t rec,
+ds_xxx_device_set_filter (struct vether_device *vdev, mach_port_t rec,
int pri, filter_array_t filt, size_t len)
{
- struct vether_device *vdev = ports_lookup_port (port_bucket, device,
- vdev_portclass);
if (vdev == NULL)
return D_NO_SUCH_DEVICE;
- ports_port_deref (vdev);
return D_INVALID_OPERATION;
}
@@ -140,20 +131,18 @@ ds_device_open (mach_port_t master_port, mach_port_t
reply_port,
}
kern_return_t
-ds_device_close (device_t device)
+ds_device_close (struct vether_device *device)
{
return 0;
}
kern_return_t
-ds_device_write (device_t device, mach_port_t reply_port,
+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;
- struct vether_device *vdev = ports_lookup_port (port_bucket, device,
- vdev_portclass);
if (vdev == NULL)
{
vm_deallocate (mach_task_self (), (vm_address_t) data, datalen);
@@ -169,103 +158,82 @@ ds_device_write (device_t device, mach_port_t reply_port,
/* 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);
- ports_port_deref (vdev);
return ret;
}
kern_return_t
-ds_device_write_inband (device_t device, mach_port_t reply_port,
+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)
{
- struct vether_device *vdev = ports_lookup_port (port_bucket, device,
- vdev_portclass);
if (vdev == NULL)
return D_NO_SUCH_DEVICE;
- ports_port_deref (vdev);
return D_INVALID_OPERATION;
}
kern_return_t
-ds_device_read (device_t device, mach_port_t reply_port,
+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)
{
- struct vether_device *vdev = ports_lookup_port (port_bucket, device,
- vdev_portclass);
if (vdev == NULL)
return D_NO_SUCH_DEVICE;
- ports_port_deref (vdev);
return D_INVALID_OPERATION;
}
kern_return_t
-ds_device_read_inband (device_t device, mach_port_t reply_port,
+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)
{
- struct vether_device *vdev = ports_lookup_port (port_bucket, device,
- vdev_portclass);
if (vdev == NULL)
return D_NO_SUCH_DEVICE;
- ports_port_deref (vdev);
return D_INVALID_OPERATION;
}
kern_return_t
-ds_device_map (device_t device, vm_prot_t prot, vm_offset_t offset,
+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)
{
- struct vether_device *vdev = ports_lookup_port (port_bucket, device,
- vdev_portclass);
if (vdev == NULL)
return D_NO_SUCH_DEVICE;
- ports_port_deref (vdev);
return D_INVALID_OPERATION;
}
kern_return_t
-ds_device_set_status (device_t device, dev_flavor_t flavor,
+ds_device_set_status (struct vether_device *vdev, dev_flavor_t flavor,
dev_status_t status, size_t statuslen)
{
- struct vether_device *vdev = ports_lookup_port (port_bucket, device,
- vdev_portclass);
if (vdev == NULL)
return D_NO_SUCH_DEVICE;
- ports_port_deref (vdev);
return D_INVALID_OPERATION;
}
kern_return_t
-ds_device_get_status (device_t device, dev_flavor_t flavor,
+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;
- struct vether_device *vdev = ports_lookup_port (port_bucket, device,
- vdev_portclass);
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);
- ports_port_deref (vdev);
return ret;
}
kern_return_t
-ds_device_set_filter (device_t device, mach_port_t receive_port,
+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;
- struct vether_device *vdev = ports_lookup_port (port_bucket, device,
- vdev_portclass);
if (vdev == NULL)
return D_NO_SUCH_DEVICE;
err = mach_port_request_notification (mach_task_self (), receive_port,
@@ -279,6 +247,5 @@ ds_device_set_filter (device_t device, mach_port_t
receive_port,
err = net_set_filter (&vdev->port_list, receive_port,
priority, filter, filterlen);
out:
- ports_port_deref (vdev);
return err;
}
diff --git a/eth-multiplexer/mig-mutate.h b/eth-multiplexer/mig-decls.h
similarity index 54%
copy from eth-multiplexer/mig-mutate.h
copy to eth-multiplexer/mig-decls.h
index f692236..a68e2ec 100644
--- a/eth-multiplexer/mig-mutate.h
+++ b/eth-multiplexer/mig-decls.h
@@ -17,9 +17,29 @@
You should have received a copy of the GNU General Public License
along with the GNU Hurd. If not, see <http://www.gnu.org/licenses/>. */
-#define NOTIFY_INTRAN \
- port_info_t begin_using_port_info_port (mach_port_t)
-#define NOTIFY_DESTRUCTOR \
- end_using_port_info (port_info_t)
-#define NOTIFY_IMPORTS \
- import "libports/mig-decls.h";
+#ifndef __ETH_MULTIPLEXER_MIG_DECLS_H__
+#define __ETH_MULTIPLEXER_MIG_DECLS_H__
+
+#include <hurd/ports.h>
+
+typedef struct vether_device *vether_device_t;
+
+extern struct port_bucket *port_bucket;
+extern struct port_class *vdev_portclass;
+
+/* Called by server stub functions. */
+
+static inline struct vether_device * __attribute__ ((unused))
+begin_using_device_port (mach_port_t port)
+{
+ return ports_lookup_port (port_bucket, port, vdev_portclass);
+}
+
+static inline void __attribute__ ((unused))
+end_using_device (struct vether_device *p)
+{
+ if (p)
+ ports_port_deref (p);
+}
+
+#endif /* __ETH_MULTIPLEXER_MIG_DECLS_H__ */
diff --git a/eth-multiplexer/mig-mutate.h b/eth-multiplexer/mig-mutate.h
index f692236..2403c29 100644
--- a/eth-multiplexer/mig-mutate.h
+++ b/eth-multiplexer/mig-mutate.h
@@ -23,3 +23,10 @@
end_using_port_info (port_info_t)
#define NOTIFY_IMPORTS \
import "libports/mig-decls.h";
+
+#define DEVICE_INTRAN \
+ vether_device_t begin_using_device_port (mach_port_t)
+#define DEVICE_DESTRUCTOR \
+ end_using_device (vether_device_t)
+#define DEVICE_IMPORTS \
+ import "eth-multiplexer/mig-decls.h";
diff --git a/eth-multiplexer/multiplexer.c b/eth-multiplexer/multiplexer.c
index 87578ec..c36ab78 100644
--- a/eth-multiplexer/multiplexer.c
+++ b/eth-multiplexer/multiplexer.c
@@ -42,7 +42,7 @@
#include "ethernet.h"
#include "vdev.h"
-#include "ourdevice_S.h"
+#include "device_S.h"
#include "notify_S.h"
#include "bpf_impl.h"
#include "netfs_impl.h"
--
Alioth's /usr/local/bin/git-commit-notice on
/srv/git.debian.org/git/pkg-hurd/hurd.git
- [hurd] 19/25: libmachdev: remove mach_device_deallocate, (continued)
- [hurd] 19/25: libmachdev: remove mach_device_deallocate, Samuel Thibault, 2014/05/27
- [hurd] 20/25: libmachdev: make the two port buckets clearly distinct, Samuel Thibault, 2014/05/27
- [hurd] 21/25: libmachdev: drop unused declarations, Samuel Thibault, 2014/05/27
- [hurd] 14/25: devnode: improve the demuxer function, Samuel Thibault, 2014/05/27
- [hurd] 24/25: Merge remote-tracking branch 'incubator/dde' into dde-upstream, Samuel Thibault, 2014/05/27
- [hurd] 03/25: Drop DIST_FILES from Makefile, Samuel Thibault, 2014/05/27
- [hurd] 22/25: libmachdev: add missing includes, Samuel Thibault, 2014/05/27
- [hurd] 25/25: Merge branch 'dde-upstream' into dde, Samuel Thibault, 2014/05/27
- [hurd] 23/25: libmachdev: add, fix and use declaration for create_device_port, Samuel Thibault, 2014/05/27
- [hurd] 08/25: libmachdev: fix receiver lookups, Samuel Thibault, 2014/05/27
- [hurd] 05/25: eth-multiplexer: fix receiver lookups,
Samuel Thibault <=
- [hurd] 13/25: eth-multiplexer: fix argp_program_version, remove argp_program_bug_address, Samuel Thibault, 2014/05/27
- [hurd] 15/25: libmachdev: improve the demuxer functions, Samuel Thibault, 2014/05/27
- [hurd] 16/25: eth-filter: improve the demuxer function, Samuel Thibault, 2014/05/27
- [hurd] 10/25: devnode: remove the ourdevice hack, Samuel Thibault, 2014/05/27
- [hurd] 04/25: eth-filter: fix receiver lookups, Samuel Thibault, 2014/05/27
- [hurd] 01/25: libports: fix notify_port_t receiver lookups, Samuel Thibault, 2014/05/27