19f46080cSMatt Helsley /* 29f46080cSMatt Helsley * cn_proc.c - process events connector 39f46080cSMatt Helsley * 49f46080cSMatt Helsley * Copyright (C) Matt Helsley, IBM Corp. 2005 59f46080cSMatt Helsley * Based on cn_fork.c by Guillaume Thouvenin <guillaume.thouvenin@bull.net> 69f46080cSMatt Helsley * Original copyright notice follows: 79f46080cSMatt Helsley * Copyright (C) 2005 BULL SA. 89f46080cSMatt Helsley * 99f46080cSMatt Helsley * 109f46080cSMatt Helsley * This program is free software; you can redistribute it and/or modify 119f46080cSMatt Helsley * it under the terms of the GNU General Public License as published by 129f46080cSMatt Helsley * the Free Software Foundation; either version 2 of the License, or 139f46080cSMatt Helsley * (at your option) any later version. 149f46080cSMatt Helsley * 159f46080cSMatt Helsley * This program is distributed in the hope that it will be useful, 169f46080cSMatt Helsley * but WITHOUT ANY WARRANTY; without even the implied warranty of 179f46080cSMatt Helsley * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the 189f46080cSMatt Helsley * GNU General Public License for more details. 199f46080cSMatt Helsley * 209f46080cSMatt Helsley * You should have received a copy of the GNU General Public License 219f46080cSMatt Helsley * along with this program; if not, write to the Free Software 229f46080cSMatt Helsley * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA 239f46080cSMatt Helsley */ 249f46080cSMatt Helsley 259f46080cSMatt Helsley #include <linux/module.h> 269f46080cSMatt Helsley #include <linux/kernel.h> 27caf3c9dcSMatt Helsley #include <linux/ktime.h> 289f46080cSMatt Helsley #include <linux/init.h> 299f46080cSMatt Helsley #include <asm/atomic.h> 309f46080cSMatt Helsley 319f46080cSMatt Helsley #include <linux/cn_proc.h> 329f46080cSMatt Helsley 339f46080cSMatt Helsley #define CN_PROC_MSG_SIZE (sizeof(struct cn_msg) + sizeof(struct proc_event)) 349f46080cSMatt Helsley 359f46080cSMatt Helsley static atomic_t proc_event_num_listeners = ATOMIC_INIT(0); 369f46080cSMatt Helsley static struct cb_id cn_proc_event_id = { CN_IDX_PROC, CN_VAL_PROC }; 379f46080cSMatt Helsley 38cc398c2eSDavid S. Miller /* proc_event_counts is used as the sequence number of the netlink message */ 399f46080cSMatt Helsley static DEFINE_PER_CPU(__u32, proc_event_counts) = { 0 }; 409f46080cSMatt Helsley 419f46080cSMatt Helsley static inline void get_seq(__u32 *ts, int *cpu) 429f46080cSMatt Helsley { 439f46080cSMatt Helsley *ts = get_cpu_var(proc_event_counts)++; 449f46080cSMatt Helsley *cpu = smp_processor_id(); 45cc398c2eSDavid S. Miller put_cpu_var(proc_event_counts); 469f46080cSMatt Helsley } 479f46080cSMatt Helsley 489f46080cSMatt Helsley void proc_fork_connector(struct task_struct *task) 499f46080cSMatt Helsley { 509f46080cSMatt Helsley struct cn_msg *msg; 519f46080cSMatt Helsley struct proc_event *ev; 529f46080cSMatt Helsley __u8 buffer[CN_PROC_MSG_SIZE]; 539f46080cSMatt Helsley 549f46080cSMatt Helsley if (atomic_read(&proc_event_num_listeners) < 1) 559f46080cSMatt Helsley return; 569f46080cSMatt Helsley 579f46080cSMatt Helsley msg = (struct cn_msg*)buffer; 589f46080cSMatt Helsley ev = (struct proc_event*)msg->data; 599f46080cSMatt Helsley get_seq(&msg->seq, &ev->cpu); 60caf3c9dcSMatt Helsley ktime_get_ts(&ev->timestamp); /* get high res monotonic timestamp */ 619f46080cSMatt Helsley ev->what = PROC_EVENT_FORK; 629f46080cSMatt Helsley ev->event_data.fork.parent_pid = task->real_parent->pid; 639f46080cSMatt Helsley ev->event_data.fork.parent_tgid = task->real_parent->tgid; 649f46080cSMatt Helsley ev->event_data.fork.child_pid = task->pid; 659f46080cSMatt Helsley ev->event_data.fork.child_tgid = task->tgid; 669f46080cSMatt Helsley 679f46080cSMatt Helsley memcpy(&msg->id, &cn_proc_event_id, sizeof(msg->id)); 689f46080cSMatt Helsley msg->ack = 0; /* not used */ 699f46080cSMatt Helsley msg->len = sizeof(*ev); 709f46080cSMatt Helsley /* If cn_netlink_send() failed, the data is not sent */ 719f46080cSMatt Helsley cn_netlink_send(msg, CN_IDX_PROC, GFP_KERNEL); 729f46080cSMatt Helsley } 739f46080cSMatt Helsley 749f46080cSMatt Helsley void proc_exec_connector(struct task_struct *task) 759f46080cSMatt Helsley { 769f46080cSMatt Helsley struct cn_msg *msg; 779f46080cSMatt Helsley struct proc_event *ev; 789f46080cSMatt Helsley __u8 buffer[CN_PROC_MSG_SIZE]; 799f46080cSMatt Helsley 809f46080cSMatt Helsley if (atomic_read(&proc_event_num_listeners) < 1) 819f46080cSMatt Helsley return; 829f46080cSMatt Helsley 839f46080cSMatt Helsley msg = (struct cn_msg*)buffer; 849f46080cSMatt Helsley ev = (struct proc_event*)msg->data; 859f46080cSMatt Helsley get_seq(&msg->seq, &ev->cpu); 86caf3c9dcSMatt Helsley ktime_get_ts(&ev->timestamp); 879f46080cSMatt Helsley ev->what = PROC_EVENT_EXEC; 889f46080cSMatt Helsley ev->event_data.exec.process_pid = task->pid; 899f46080cSMatt Helsley ev->event_data.exec.process_tgid = task->tgid; 909f46080cSMatt Helsley 919f46080cSMatt Helsley memcpy(&msg->id, &cn_proc_event_id, sizeof(msg->id)); 929f46080cSMatt Helsley msg->ack = 0; /* not used */ 939f46080cSMatt Helsley msg->len = sizeof(*ev); 949f46080cSMatt Helsley cn_netlink_send(msg, CN_IDX_PROC, GFP_KERNEL); 959f46080cSMatt Helsley } 969f46080cSMatt Helsley 979f46080cSMatt Helsley void proc_id_connector(struct task_struct *task, int which_id) 989f46080cSMatt Helsley { 999f46080cSMatt Helsley struct cn_msg *msg; 1009f46080cSMatt Helsley struct proc_event *ev; 1019f46080cSMatt Helsley __u8 buffer[CN_PROC_MSG_SIZE]; 1029f46080cSMatt Helsley 1039f46080cSMatt Helsley if (atomic_read(&proc_event_num_listeners) < 1) 1049f46080cSMatt Helsley return; 1059f46080cSMatt Helsley 1069f46080cSMatt Helsley msg = (struct cn_msg*)buffer; 1079f46080cSMatt Helsley ev = (struct proc_event*)msg->data; 1089f46080cSMatt Helsley ev->what = which_id; 1099f46080cSMatt Helsley ev->event_data.id.process_pid = task->pid; 1109f46080cSMatt Helsley ev->event_data.id.process_tgid = task->tgid; 1119f46080cSMatt Helsley if (which_id == PROC_EVENT_UID) { 1129f46080cSMatt Helsley ev->event_data.id.r.ruid = task->uid; 1139f46080cSMatt Helsley ev->event_data.id.e.euid = task->euid; 1149f46080cSMatt Helsley } else if (which_id == PROC_EVENT_GID) { 1159f46080cSMatt Helsley ev->event_data.id.r.rgid = task->gid; 1169f46080cSMatt Helsley ev->event_data.id.e.egid = task->egid; 1179f46080cSMatt Helsley } else 1189f46080cSMatt Helsley return; 1199f46080cSMatt Helsley get_seq(&msg->seq, &ev->cpu); 120caf3c9dcSMatt Helsley ktime_get_ts(&ev->timestamp); 1219f46080cSMatt Helsley 1229f46080cSMatt Helsley memcpy(&msg->id, &cn_proc_event_id, sizeof(msg->id)); 1239f46080cSMatt Helsley msg->ack = 0; /* not used */ 1249f46080cSMatt Helsley msg->len = sizeof(*ev); 1259f46080cSMatt Helsley cn_netlink_send(msg, CN_IDX_PROC, GFP_KERNEL); 1269f46080cSMatt Helsley } 1279f46080cSMatt Helsley 1289f46080cSMatt Helsley void proc_exit_connector(struct task_struct *task) 1299f46080cSMatt Helsley { 1309f46080cSMatt Helsley struct cn_msg *msg; 1319f46080cSMatt Helsley struct proc_event *ev; 1329f46080cSMatt Helsley __u8 buffer[CN_PROC_MSG_SIZE]; 1339f46080cSMatt Helsley 1349f46080cSMatt Helsley if (atomic_read(&proc_event_num_listeners) < 1) 1359f46080cSMatt Helsley return; 1369f46080cSMatt Helsley 1379f46080cSMatt Helsley msg = (struct cn_msg*)buffer; 1389f46080cSMatt Helsley ev = (struct proc_event*)msg->data; 1399f46080cSMatt Helsley get_seq(&msg->seq, &ev->cpu); 140caf3c9dcSMatt Helsley ktime_get_ts(&ev->timestamp); 1419f46080cSMatt Helsley ev->what = PROC_EVENT_EXIT; 1429f46080cSMatt Helsley ev->event_data.exit.process_pid = task->pid; 1439f46080cSMatt Helsley ev->event_data.exit.process_tgid = task->tgid; 1449f46080cSMatt Helsley ev->event_data.exit.exit_code = task->exit_code; 1459f46080cSMatt Helsley ev->event_data.exit.exit_signal = task->exit_signal; 1469f46080cSMatt Helsley 1479f46080cSMatt Helsley memcpy(&msg->id, &cn_proc_event_id, sizeof(msg->id)); 1489f46080cSMatt Helsley msg->ack = 0; /* not used */ 1499f46080cSMatt Helsley msg->len = sizeof(*ev); 1509f46080cSMatt Helsley cn_netlink_send(msg, CN_IDX_PROC, GFP_KERNEL); 1519f46080cSMatt Helsley } 1529f46080cSMatt Helsley 1539f46080cSMatt Helsley /* 1549f46080cSMatt Helsley * Send an acknowledgement message to userspace 1559f46080cSMatt Helsley * 1569f46080cSMatt Helsley * Use 0 for success, EFOO otherwise. 1579f46080cSMatt Helsley * Note: this is the negative of conventional kernel error 1589f46080cSMatt Helsley * values because it's not being returned via syscall return 1599f46080cSMatt Helsley * mechanisms. 1609f46080cSMatt Helsley */ 1619f46080cSMatt Helsley static void cn_proc_ack(int err, int rcvd_seq, int rcvd_ack) 1629f46080cSMatt Helsley { 1639f46080cSMatt Helsley struct cn_msg *msg; 1649f46080cSMatt Helsley struct proc_event *ev; 1659f46080cSMatt Helsley __u8 buffer[CN_PROC_MSG_SIZE]; 1669f46080cSMatt Helsley 1679f46080cSMatt Helsley if (atomic_read(&proc_event_num_listeners) < 1) 1689f46080cSMatt Helsley return; 1699f46080cSMatt Helsley 1709f46080cSMatt Helsley msg = (struct cn_msg*)buffer; 1719f46080cSMatt Helsley ev = (struct proc_event*)msg->data; 1729f46080cSMatt Helsley msg->seq = rcvd_seq; 173caf3c9dcSMatt Helsley ktime_get_ts(&ev->timestamp); 1749f46080cSMatt Helsley ev->cpu = -1; 1759f46080cSMatt Helsley ev->what = PROC_EVENT_NONE; 1769f46080cSMatt Helsley ev->event_data.ack.err = err; 1779f46080cSMatt Helsley memcpy(&msg->id, &cn_proc_event_id, sizeof(msg->id)); 1789f46080cSMatt Helsley msg->ack = rcvd_ack + 1; 1799f46080cSMatt Helsley msg->len = sizeof(*ev); 1809f46080cSMatt Helsley cn_netlink_send(msg, CN_IDX_PROC, GFP_KERNEL); 1819f46080cSMatt Helsley } 1829f46080cSMatt Helsley 1839f46080cSMatt Helsley /** 1849f46080cSMatt Helsley * cn_proc_mcast_ctl 1859f46080cSMatt Helsley * @data: message sent from userspace via the connector 1869f46080cSMatt Helsley */ 1879f46080cSMatt Helsley static void cn_proc_mcast_ctl(void *data) 1889f46080cSMatt Helsley { 1899f46080cSMatt Helsley struct cn_msg *msg = data; 1909f46080cSMatt Helsley enum proc_cn_mcast_op *mc_op = NULL; 1919f46080cSMatt Helsley int err = 0; 1929f46080cSMatt Helsley 1939f46080cSMatt Helsley if (msg->len != sizeof(*mc_op)) 1949f46080cSMatt Helsley return; 1959f46080cSMatt Helsley 1969f46080cSMatt Helsley mc_op = (enum proc_cn_mcast_op*)msg->data; 1979f46080cSMatt Helsley switch (*mc_op) { 1989f46080cSMatt Helsley case PROC_CN_MCAST_LISTEN: 1999f46080cSMatt Helsley atomic_inc(&proc_event_num_listeners); 2009f46080cSMatt Helsley break; 2019f46080cSMatt Helsley case PROC_CN_MCAST_IGNORE: 2029f46080cSMatt Helsley atomic_dec(&proc_event_num_listeners); 2039f46080cSMatt Helsley break; 2049f46080cSMatt Helsley default: 2059f46080cSMatt Helsley err = EINVAL; 2069f46080cSMatt Helsley break; 2079f46080cSMatt Helsley } 2089f46080cSMatt Helsley cn_proc_ack(err, msg->seq, msg->ack); 2099f46080cSMatt Helsley } 2109f46080cSMatt Helsley 2119f46080cSMatt Helsley /* 2129f46080cSMatt Helsley * cn_proc_init - initialization entry point 2139f46080cSMatt Helsley * 2149f46080cSMatt Helsley * Adds the connector callback to the connector driver. 2159f46080cSMatt Helsley */ 2169f46080cSMatt Helsley static int __init cn_proc_init(void) 2179f46080cSMatt Helsley { 2189f46080cSMatt Helsley int err; 2199f46080cSMatt Helsley 2209f46080cSMatt Helsley if ((err = cn_add_callback(&cn_proc_event_id, "cn_proc", 2219f46080cSMatt Helsley &cn_proc_mcast_ctl))) { 2229f46080cSMatt Helsley printk(KERN_WARNING "cn_proc failed to register\n"); 2239f46080cSMatt Helsley return err; 2249f46080cSMatt Helsley } 2259f46080cSMatt Helsley return 0; 2269f46080cSMatt Helsley } 2279f46080cSMatt Helsley 2289f46080cSMatt Helsley module_init(cn_proc_init); 229