cregit-Linux how code gets into the kernel

Release 4.11 net/phonet/datagram.c

Directory: net/phonet
/*
 * File: datagram.c
 *
 * Datagram (ISI) Phonet sockets
 *
 * Copyright (C) 2008 Nokia Corporation.
 *
 * Authors: Sakari Ailus <sakari.ailus@nokia.com>
 *          Rémi Denis-Courmont
 *
 * This program is free software; you can redistribute it and/or
 * modify it under the terms of the GNU General Public License
 * version 2 as published by the Free Software Foundation.
 *
 * This program 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 this program; if not, write to the Free Software
 * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
 * 02110-1301 USA
 */

#include <linux/kernel.h>
#include <linux/slab.h>
#include <linux/socket.h>
#include <asm/ioctls.h>
#include <net/sock.h>

#include <linux/phonet.h>
#include <linux/export.h>
#include <net/phonet/phonet.h>

static int pn_backlog_rcv(struct sock *sk, struct sk_buff *skb);

/* associated socket ceases to exist */

static void pn_sock_close(struct sock *sk, long timeout) { sk_common_release(sk); }

Contributors

PersonTokensPropCommitsCommitProp
Rémi Denis-Courmont19100.00%1100.00%
Total19100.00%1100.00%


static int pn_ioctl(struct sock *sk, int cmd, unsigned long arg) { struct sk_buff *skb; int answ; switch (cmd) { case SIOCINQ: lock_sock(sk); skb = skb_peek(&sk->sk_receive_queue); answ = skb ? skb->len : 0; release_sock(sk); return put_user(answ, (int __user *)arg); case SIOCPNADDRESOURCE: case SIOCPNDELRESOURCE: { u32 res; if (get_user(res, (u32 __user *)arg)) return -EFAULT; if (res >= 256) return -EINVAL; if (cmd == SIOCPNADDRESOURCE) return pn_sock_bind_res(sk, res); else return pn_sock_unbind_res(sk, res); } } return -ENOIOCTLCMD; }

Contributors

PersonTokensPropCommitsCommitProp
Rémi Denis-Courmont144100.00%2100.00%
Total144100.00%2100.00%

/* Destroy socket. All references are gone. */
static void pn_destruct(struct sock *sk) { skb_queue_purge(&sk->sk_receive_queue); }

Contributors

PersonTokensPropCommitsCommitProp
Rémi Denis-Courmont19100.00%1100.00%
Total19100.00%1100.00%


static int pn_init(struct sock *sk) { sk->sk_destruct = pn_destruct; return 0; }

Contributors

PersonTokensPropCommitsCommitProp
Rémi Denis-Courmont20100.00%1100.00%
Total20100.00%1100.00%


static int pn_sendmsg(struct sock *sk, struct msghdr *msg, size_t len) { DECLARE_SOCKADDR(struct sockaddr_pn *, target, msg->msg_name); struct sk_buff *skb; int err; if (msg->msg_flags & ~(MSG_DONTWAIT|MSG_EOR|MSG_NOSIGNAL| MSG_CMSG_COMPAT)) return -EOPNOTSUPP; if (target == NULL) return -EDESTADDRREQ; if (msg->msg_namelen < sizeof(struct sockaddr_pn)) return -EINVAL; if (target->spn_family != AF_PHONET) return -EAFNOSUPPORT; skb = sock_alloc_send_skb(sk, MAX_PHONET_HEADER + len, msg->msg_flags & MSG_DONTWAIT, &err); if (skb == NULL) return err; skb_reserve(skb, MAX_PHONET_HEADER); err = memcpy_from_msg((void *)skb_put(skb, len), msg, len); if (err < 0) { kfree_skb(skb); return err; } /* * Fill in the Phonet header and * finally pass the packet forwards. */ err = pn_skb_send(sk, skb, target); /* If ok, return len. */ return (err >= 0) ? len : err; }

Contributors

PersonTokensPropCommitsCommitProp
Rémi Denis-Courmont18293.33%250.00%
Steffen Hurrle126.15%125.00%
Al Viro10.51%125.00%
Total195100.00%4100.00%


static int pn_recvmsg(struct sock *sk, struct msghdr *msg, size_t len, int noblock, int flags, int *addr_len) { struct sk_buff *skb = NULL; struct sockaddr_pn sa; int rval = -EOPNOTSUPP; int copylen; if (flags & ~(MSG_PEEK|MSG_TRUNC|MSG_DONTWAIT|MSG_NOSIGNAL| MSG_CMSG_COMPAT)) goto out_nofree; skb = skb_recv_datagram(sk, flags, noblock, &rval); if (skb == NULL) goto out_nofree; pn_skb_get_src_sockaddr(skb, &sa); copylen = skb->len; if (len < copylen) { msg->msg_flags |= MSG_TRUNC; copylen = len; } rval = skb_copy_datagram_msg(skb, 0, msg, copylen); if (rval) { rval = -EFAULT; goto out; } rval = (flags & MSG_TRUNC) ? skb->len : copylen; if (msg->msg_name != NULL) { __sockaddr_check_size(sizeof(sa)); memcpy(msg->msg_name, &sa, sizeof(sa)); *addr_len = sizeof(sa); } out: skb_free_datagram(sk, skb); out_nofree: return rval; }

Contributors

PersonTokensPropCommitsCommitProp
Rémi Denis-Courmont20090.91%240.00%
Hannes Frederic Sowa115.00%120.00%
Steffen Hurrle83.64%120.00%
David S. Miller10.45%120.00%
Total220100.00%5100.00%

/* Queue an skb for a sock. */
static int pn_backlog_rcv(struct sock *sk, struct sk_buff *skb) { int err = sock_queue_rcv_skb(sk, skb); if (err < 0) kfree_skb(skb); return err ? NET_RX_DROP : NET_RX_SUCCESS; }

Contributors

PersonTokensPropCommitsCommitProp
Rémi Denis-Courmont44100.00%1100.00%
Total44100.00%1100.00%

/* Module registration */ static struct proto pn_proto = { .close = pn_sock_close, .ioctl = pn_ioctl, .init = pn_init, .sendmsg = pn_sendmsg, .recvmsg = pn_recvmsg, .backlog_rcv = pn_backlog_rcv, .hash = pn_sock_hash, .unhash = pn_sock_unhash, .get_port = pn_sock_get_port, .obj_size = sizeof(struct pn_sock), .owner = THIS_MODULE, .name = "PHONET", }; static struct phonet_protocol pn_dgram_proto = { .ops = &phonet_dgram_ops, .prot = &pn_proto, .sock_type = SOCK_DGRAM, };
int __init isi_register(void) { return phonet_proto_register(PN_PROTO_PHONET, &pn_dgram_proto); }

Contributors

PersonTokensPropCommitsCommitProp
Rémi Denis-Courmont17100.00%1100.00%
Total17100.00%1100.00%


void __exit isi_unregister(void) { phonet_proto_unregister(PN_PROTO_PHONET, &pn_dgram_proto); }

Contributors

PersonTokensPropCommitsCommitProp
Rémi Denis-Courmont16100.00%1100.00%
Total16100.00%1100.00%


Overall Contributors

PersonTokensPropCommitsCommitProp
Rémi Denis-Courmont79495.32%440.00%
Steffen Hurrle202.40%110.00%
Hannes Frederic Sowa111.32%110.00%
Tejun Heo30.36%110.00%
Paul Gortmaker30.36%110.00%
David S. Miller10.12%110.00%
Al Viro10.12%110.00%
Total833100.00%10100.00%
Directory: net/phonet
Information contained on this website is for historical information purposes only and does not indicate or represent copyright ownership.
Created with cregit.