-
Notifications
You must be signed in to change notification settings - Fork 0
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
rxrpc: Separate local endpoint event handling out into its own file
Separate local endpoint event handling out into its own file preparatory to overhauling the object management aspect (which remains in the original file). Signed-off-by: David Howells <dhowells@redhat.com>
- Loading branch information
David Howells
committed
Jun 15, 2016
1 parent
f66d749
commit 8756361
Showing
4 changed files
with
129 additions
and
102 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
|
|
@@ -12,6 +12,7 @@ af-rxrpc-y := \ | |
| input.o \ | ||
| insecure.o \ | ||
| key.o \ | ||
| local_event.o \ | ||
| local_object.o \ | ||
| misc.o \ | ||
| output.o \ | ||
|
|
||
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,120 @@ | ||
| /* AF_RXRPC local endpoint management | ||
| * | ||
| * Copyright (C) 2007 Red Hat, Inc. All Rights Reserved. | ||
| * Written by David Howells (dhowells@redhat.com) | ||
| * | ||
| * This program 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 of the License, or (at your option) any later version. | ||
| */ | ||
|
|
||
| #define pr_fmt(fmt) KBUILD_MODNAME ": " fmt | ||
|
|
||
| #include <linux/module.h> | ||
| #include <linux/net.h> | ||
| #include <linux/skbuff.h> | ||
| #include <linux/slab.h> | ||
| #include <linux/udp.h> | ||
| #include <linux/ip.h> | ||
| #include <net/sock.h> | ||
| #include <net/af_rxrpc.h> | ||
| #include <generated/utsrelease.h> | ||
| #include "ar-internal.h" | ||
|
|
||
| static const char rxrpc_version_string[65] = "linux-" UTS_RELEASE " AF_RXRPC"; | ||
|
|
||
| /* | ||
| * Reply to a version request | ||
| */ | ||
| static void rxrpc_send_version_request(struct rxrpc_local *local, | ||
| struct rxrpc_host_header *hdr, | ||
| struct sk_buff *skb) | ||
| { | ||
| struct rxrpc_wire_header whdr; | ||
| struct rxrpc_skb_priv *sp = rxrpc_skb(skb); | ||
| struct sockaddr_in sin; | ||
| struct msghdr msg; | ||
| struct kvec iov[2]; | ||
| size_t len; | ||
| int ret; | ||
|
|
||
| _enter(""); | ||
|
|
||
| sin.sin_family = AF_INET; | ||
| sin.sin_port = udp_hdr(skb)->source; | ||
| sin.sin_addr.s_addr = ip_hdr(skb)->saddr; | ||
|
|
||
| msg.msg_name = &sin; | ||
| msg.msg_namelen = sizeof(sin); | ||
| msg.msg_control = NULL; | ||
| msg.msg_controllen = 0; | ||
| msg.msg_flags = 0; | ||
|
|
||
| whdr.epoch = htonl(sp->hdr.epoch); | ||
| whdr.cid = htonl(sp->hdr.cid); | ||
| whdr.callNumber = htonl(sp->hdr.callNumber); | ||
| whdr.seq = 0; | ||
| whdr.serial = 0; | ||
| whdr.type = RXRPC_PACKET_TYPE_VERSION; | ||
| whdr.flags = RXRPC_LAST_PACKET | (~hdr->flags & RXRPC_CLIENT_INITIATED); | ||
| whdr.userStatus = 0; | ||
| whdr.securityIndex = 0; | ||
| whdr._rsvd = 0; | ||
| whdr.serviceId = htons(sp->hdr.serviceId); | ||
|
|
||
| iov[0].iov_base = &whdr; | ||
| iov[0].iov_len = sizeof(whdr); | ||
| iov[1].iov_base = (char *)rxrpc_version_string; | ||
| iov[1].iov_len = sizeof(rxrpc_version_string); | ||
|
|
||
| len = iov[0].iov_len + iov[1].iov_len; | ||
|
|
||
| _proto("Tx VERSION (reply)"); | ||
|
|
||
| ret = kernel_sendmsg(local->socket, &msg, iov, 2, len); | ||
| if (ret < 0) | ||
| _debug("sendmsg failed: %d", ret); | ||
|
|
||
| _leave(""); | ||
| } | ||
|
|
||
| /* | ||
| * Process event packets targetted at a local endpoint. | ||
| */ | ||
| void rxrpc_process_local_events(struct work_struct *work) | ||
| { | ||
| struct rxrpc_local *local = container_of(work, struct rxrpc_local, event_processor); | ||
| struct sk_buff *skb; | ||
| char v; | ||
|
|
||
| _enter(""); | ||
|
|
||
| atomic_inc(&local->usage); | ||
|
|
||
| while ((skb = skb_dequeue(&local->event_queue))) { | ||
| struct rxrpc_skb_priv *sp = rxrpc_skb(skb); | ||
|
|
||
| _debug("{%d},{%u}", local->debug_id, sp->hdr.type); | ||
|
|
||
| switch (sp->hdr.type) { | ||
| case RXRPC_PACKET_TYPE_VERSION: | ||
| if (skb_copy_bits(skb, 0, &v, 1) < 0) | ||
| return; | ||
| _proto("Rx VERSION { %02x }", v); | ||
| if (v == 0) | ||
| rxrpc_send_version_request(local, &sp->hdr, skb); | ||
| break; | ||
|
|
||
| default: | ||
| /* Just ignore anything we don't understand */ | ||
| break; | ||
| } | ||
|
|
||
| rxrpc_put_local(local); | ||
| rxrpc_free_skb(skb); | ||
| } | ||
|
|
||
| rxrpc_put_local(local); | ||
| _leave(""); | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters