diff options
| author | Justus Winter <4winter@informatik.uni-hamburg.de> | 2014-04-13 14:03:48 +0200 |
|---|---|---|
| committer | Justus Winter <4winter@informatik.uni-hamburg.de> | 2014-12-07 15:38:18 +0100 |
| commit | 2514b693920124eb47eb48f50f07b179bc5090e9 (patch) | |
| tree | 259c65747e4531290f6fa1b126de030c566382d3 /pfinet | |
| parent | df8605b39f109362e86b0ebf6b8cf79fd1b2f3fd (diff) | |
pfinet: make the demuxers payload-aware
* pfinet/ethernet.c (ethernet_demuxer): Make the demuxer payload-aware.
* pfinet/main.c (pfinet_demuxer): Likewise.
Diffstat (limited to 'pfinet')
| -rw-r--r-- | pfinet/ethernet.c | 20 | ||||
| -rw-r--r-- | pfinet/main.c | 12 |
2 files changed, 29 insertions, 3 deletions
diff --git a/pfinet/ethernet.c b/pfinet/ethernet.c index 053fd1be..16782435 100644 --- a/pfinet/ethernet.c +++ b/pfinet/ethernet.c @@ -116,12 +116,30 @@ ethernet_demuxer (mach_msg_header_t *inp, int datalen; struct ether_device *edev; struct device *dev = 0; + mach_port_t local_port; if (inp->msgh_id != NET_RCV_MSG_ID) return 0; + if (MACH_MSGH_BITS_LOCAL (inp->msgh_bits) == + MACH_MSG_TYPE_PROTECTED_PAYLOAD) + { + struct port_info *pi = ports_lookup_payload (NULL, + inp->msgh_protected_payload, + NULL); + if (pi) + { + local_port = pi->port_right; + ports_port_deref (pi); + } + else + local_port = MACH_PORT_NULL; + } + else + local_port = inp->msgh_local_port; + for (edev = ether_dev; edev; edev = edev->next) - if (inp->msgh_local_port == edev->readptname) + if (local_port == edev->readptname) dev = &edev->dev; if (! dev) diff --git a/pfinet/main.c b/pfinet/main.c index 0f1fbfc7..8716fdbb 100644 --- a/pfinet/main.c +++ b/pfinet/main.c @@ -86,8 +86,16 @@ pfinet_demuxer (mach_msg_header_t *inp, /* We have several classes in one bucket, which need to be demuxed differently. */ - pi = ports_lookup_port(pfinet_bucket, inp->msgh_local_port, socketport_class); - + if (MACH_MSGH_BITS_LOCAL (inp->msgh_bits) == + MACH_MSG_TYPE_PROTECTED_PAYLOAD) + pi = ports_lookup_payload (pfinet_bucket, + inp->msgh_protected_payload, + socketport_class); + else + pi = ports_lookup_port (pfinet_bucket, + inp->msgh_local_port, + socketport_class); + if (pi) { ports_port_deref (pi); |