11ffaa640SHendrik Brueckner /* 21ffaa640SHendrik Brueckner * Deliver z/VM CP special messages (SMSG) as uevents. 31ffaa640SHendrik Brueckner * 41ffaa640SHendrik Brueckner * The driver registers for z/VM CP special messages with the 51ffaa640SHendrik Brueckner * "APP" prefix. Incoming messages are delivered to user space 61ffaa640SHendrik Brueckner * as uevents. 71ffaa640SHendrik Brueckner * 81ffaa640SHendrik Brueckner * Copyright IBM Corp. 2010 91ffaa640SHendrik Brueckner * Author(s): Hendrik Brueckner <brueckner@linux.vnet.ibm.com> 101ffaa640SHendrik Brueckner * 111ffaa640SHendrik Brueckner */ 121ffaa640SHendrik Brueckner #define KMSG_COMPONENT "smsgiucv_app" 131ffaa640SHendrik Brueckner #define pr_fmt(fmt) KMSG_COMPONENT ": " fmt 141ffaa640SHendrik Brueckner 151ffaa640SHendrik Brueckner #include <linux/ctype.h> 161ffaa640SHendrik Brueckner #include <linux/err.h> 171ffaa640SHendrik Brueckner #include <linux/device.h> 181ffaa640SHendrik Brueckner #include <linux/list.h> 191ffaa640SHendrik Brueckner #include <linux/kobject.h> 201ffaa640SHendrik Brueckner #include <linux/module.h> 215a0e3ad6STejun Heo #include <linux/slab.h> 221ffaa640SHendrik Brueckner #include <linux/spinlock.h> 231ffaa640SHendrik Brueckner #include <linux/workqueue.h> 241ffaa640SHendrik Brueckner #include <net/iucv/iucv.h> 251ffaa640SHendrik Brueckner #include "smsgiucv.h" 261ffaa640SHendrik Brueckner 271ffaa640SHendrik Brueckner /* prefix used for SMSG registration */ 281ffaa640SHendrik Brueckner #define SMSG_PREFIX "APP" 291ffaa640SHendrik Brueckner 301ffaa640SHendrik Brueckner /* SMSG related uevent environment variables */ 311ffaa640SHendrik Brueckner #define ENV_SENDER_STR "SMSG_SENDER=" 321ffaa640SHendrik Brueckner #define ENV_SENDER_LEN (strlen(ENV_SENDER_STR) + 8 + 1) 331ffaa640SHendrik Brueckner #define ENV_PREFIX_STR "SMSG_ID=" 341ffaa640SHendrik Brueckner #define ENV_PREFIX_LEN (strlen(ENV_PREFIX_STR) + \ 351ffaa640SHendrik Brueckner strlen(SMSG_PREFIX) + 1) 361ffaa640SHendrik Brueckner #define ENV_TEXT_STR "SMSG_TEXT=" 371ffaa640SHendrik Brueckner #define ENV_TEXT_LEN(msg) (strlen(ENV_TEXT_STR) + strlen((msg)) + 1) 381ffaa640SHendrik Brueckner 391ffaa640SHendrik Brueckner /* z/VM user ID which is permitted to send SMSGs 401ffaa640SHendrik Brueckner * If the value is undefined or empty (""), special messages are 411ffaa640SHendrik Brueckner * accepted from any z/VM user ID. */ 421ffaa640SHendrik Brueckner static char *sender; 431ffaa640SHendrik Brueckner module_param(sender, charp, 0400); 441ffaa640SHendrik Brueckner MODULE_PARM_DESC(sender, "z/VM user ID from which CP SMSGs are accepted"); 451ffaa640SHendrik Brueckner 461ffaa640SHendrik Brueckner /* SMSG device representation */ 471ffaa640SHendrik Brueckner static struct device *smsg_app_dev; 481ffaa640SHendrik Brueckner 491ffaa640SHendrik Brueckner /* list element for queuing received messages for delivery */ 501ffaa640SHendrik Brueckner struct smsg_app_event { 511ffaa640SHendrik Brueckner struct list_head list; 521ffaa640SHendrik Brueckner char *buf; 531ffaa640SHendrik Brueckner char *envp[4]; 541ffaa640SHendrik Brueckner }; 551ffaa640SHendrik Brueckner 561ffaa640SHendrik Brueckner /* queue for outgoing uevents */ 571ffaa640SHendrik Brueckner static LIST_HEAD(smsg_event_queue); 581ffaa640SHendrik Brueckner static DEFINE_SPINLOCK(smsg_event_queue_lock); 591ffaa640SHendrik Brueckner 601ffaa640SHendrik Brueckner static void smsg_app_event_free(struct smsg_app_event *ev) 611ffaa640SHendrik Brueckner { 621ffaa640SHendrik Brueckner kfree(ev->buf); 631ffaa640SHendrik Brueckner kfree(ev); 641ffaa640SHendrik Brueckner } 651ffaa640SHendrik Brueckner 661ffaa640SHendrik Brueckner static struct smsg_app_event *smsg_app_event_alloc(const char *from, 671ffaa640SHendrik Brueckner const char *msg) 681ffaa640SHendrik Brueckner { 691ffaa640SHendrik Brueckner struct smsg_app_event *ev; 701ffaa640SHendrik Brueckner 711ffaa640SHendrik Brueckner ev = kzalloc(sizeof(*ev), GFP_ATOMIC); 721ffaa640SHendrik Brueckner if (!ev) 731ffaa640SHendrik Brueckner return NULL; 741ffaa640SHendrik Brueckner 751ffaa640SHendrik Brueckner ev->buf = kzalloc(ENV_SENDER_LEN + ENV_PREFIX_LEN + 761ffaa640SHendrik Brueckner ENV_TEXT_LEN(msg), GFP_ATOMIC); 771ffaa640SHendrik Brueckner if (!ev->buf) { 781ffaa640SHendrik Brueckner kfree(ev); 791ffaa640SHendrik Brueckner return NULL; 801ffaa640SHendrik Brueckner } 811ffaa640SHendrik Brueckner 821ffaa640SHendrik Brueckner /* setting up environment pointers into buf */ 831ffaa640SHendrik Brueckner ev->envp[0] = ev->buf; 841ffaa640SHendrik Brueckner ev->envp[1] = ev->envp[0] + ENV_SENDER_LEN; 851ffaa640SHendrik Brueckner ev->envp[2] = ev->envp[1] + ENV_PREFIX_LEN; 861ffaa640SHendrik Brueckner ev->envp[3] = NULL; 871ffaa640SHendrik Brueckner 881ffaa640SHendrik Brueckner /* setting up environment: sender, prefix name, and message text */ 891ffaa640SHendrik Brueckner snprintf(ev->envp[0], ENV_SENDER_LEN, ENV_SENDER_STR "%s", from); 901ffaa640SHendrik Brueckner snprintf(ev->envp[1], ENV_PREFIX_LEN, ENV_PREFIX_STR "%s", SMSG_PREFIX); 911ffaa640SHendrik Brueckner snprintf(ev->envp[2], ENV_TEXT_LEN(msg), ENV_TEXT_STR "%s", msg); 921ffaa640SHendrik Brueckner 931ffaa640SHendrik Brueckner return ev; 941ffaa640SHendrik Brueckner } 951ffaa640SHendrik Brueckner 961ffaa640SHendrik Brueckner static void smsg_event_work_fn(struct work_struct *work) 971ffaa640SHendrik Brueckner { 981ffaa640SHendrik Brueckner LIST_HEAD(event_queue); 991ffaa640SHendrik Brueckner struct smsg_app_event *p, *n; 1001ffaa640SHendrik Brueckner struct device *dev; 1011ffaa640SHendrik Brueckner 1021ffaa640SHendrik Brueckner dev = get_device(smsg_app_dev); 1031ffaa640SHendrik Brueckner if (!dev) 1041ffaa640SHendrik Brueckner return; 1051ffaa640SHendrik Brueckner 1061ffaa640SHendrik Brueckner spin_lock_bh(&smsg_event_queue_lock); 1071ffaa640SHendrik Brueckner list_splice_init(&smsg_event_queue, &event_queue); 1081ffaa640SHendrik Brueckner spin_unlock_bh(&smsg_event_queue_lock); 1091ffaa640SHendrik Brueckner 1101ffaa640SHendrik Brueckner list_for_each_entry_safe(p, n, &event_queue, list) { 1111ffaa640SHendrik Brueckner list_del(&p->list); 1121ffaa640SHendrik Brueckner kobject_uevent_env(&dev->kobj, KOBJ_CHANGE, p->envp); 1131ffaa640SHendrik Brueckner smsg_app_event_free(p); 1141ffaa640SHendrik Brueckner } 1151ffaa640SHendrik Brueckner 1161ffaa640SHendrik Brueckner put_device(dev); 1171ffaa640SHendrik Brueckner } 1181ffaa640SHendrik Brueckner static DECLARE_WORK(smsg_event_work, smsg_event_work_fn); 1191ffaa640SHendrik Brueckner 1201ffaa640SHendrik Brueckner static void smsg_app_callback(const char *from, char *msg) 1211ffaa640SHendrik Brueckner { 1221ffaa640SHendrik Brueckner struct smsg_app_event *se; 1231ffaa640SHendrik Brueckner 1241ffaa640SHendrik Brueckner /* check if the originating z/VM user ID matches 1251ffaa640SHendrik Brueckner * the configured sender. */ 1261ffaa640SHendrik Brueckner if (sender && strlen(sender) > 0 && strcmp(from, sender) != 0) 1271ffaa640SHendrik Brueckner return; 1281ffaa640SHendrik Brueckner 1291ffaa640SHendrik Brueckner /* get start of message text (skip prefix and leading blanks) */ 1301ffaa640SHendrik Brueckner msg += strlen(SMSG_PREFIX); 1311ffaa640SHendrik Brueckner while (*msg && isspace(*msg)) 1321ffaa640SHendrik Brueckner msg++; 1331ffaa640SHendrik Brueckner if (*msg == '\0') 1341ffaa640SHendrik Brueckner return; 1351ffaa640SHendrik Brueckner 1361ffaa640SHendrik Brueckner /* allocate event list element and its environment */ 1371ffaa640SHendrik Brueckner se = smsg_app_event_alloc(from, msg); 1381ffaa640SHendrik Brueckner if (!se) 1391ffaa640SHendrik Brueckner return; 1401ffaa640SHendrik Brueckner 1411ffaa640SHendrik Brueckner /* queue event and schedule work function */ 1421ffaa640SHendrik Brueckner spin_lock(&smsg_event_queue_lock); 1431ffaa640SHendrik Brueckner list_add_tail(&se->list, &smsg_event_queue); 1441ffaa640SHendrik Brueckner spin_unlock(&smsg_event_queue_lock); 1451ffaa640SHendrik Brueckner 1461ffaa640SHendrik Brueckner schedule_work(&smsg_event_work); 1471ffaa640SHendrik Brueckner return; 1481ffaa640SHendrik Brueckner } 1491ffaa640SHendrik Brueckner 1501ffaa640SHendrik Brueckner static int __init smsgiucv_app_init(void) 1511ffaa640SHendrik Brueckner { 1521ffaa640SHendrik Brueckner struct device_driver *smsgiucv_drv; 1531ffaa640SHendrik Brueckner int rc; 1541ffaa640SHendrik Brueckner 1551ffaa640SHendrik Brueckner if (!MACHINE_IS_VM) 1561ffaa640SHendrik Brueckner return -ENODEV; 1571ffaa640SHendrik Brueckner 1581ffaa640SHendrik Brueckner smsg_app_dev = kzalloc(sizeof(*smsg_app_dev), GFP_KERNEL); 1591ffaa640SHendrik Brueckner if (!smsg_app_dev) 1601ffaa640SHendrik Brueckner return -ENOMEM; 1611ffaa640SHendrik Brueckner 1621ffaa640SHendrik Brueckner smsgiucv_drv = driver_find(SMSGIUCV_DRV_NAME, &iucv_bus); 1631ffaa640SHendrik Brueckner if (!smsgiucv_drv) { 1641ffaa640SHendrik Brueckner kfree(smsg_app_dev); 1651ffaa640SHendrik Brueckner return -ENODEV; 1661ffaa640SHendrik Brueckner } 1671ffaa640SHendrik Brueckner 1681ffaa640SHendrik Brueckner rc = dev_set_name(smsg_app_dev, KMSG_COMPONENT); 1691ffaa640SHendrik Brueckner if (rc) { 1701ffaa640SHendrik Brueckner kfree(smsg_app_dev); 171*fde25a9bSAlan Stern goto fail; 1721ffaa640SHendrik Brueckner } 1731ffaa640SHendrik Brueckner smsg_app_dev->bus = &iucv_bus; 1741ffaa640SHendrik Brueckner smsg_app_dev->parent = iucv_root; 1751ffaa640SHendrik Brueckner smsg_app_dev->release = (void (*)(struct device *)) kfree; 1761ffaa640SHendrik Brueckner smsg_app_dev->driver = smsgiucv_drv; 1771ffaa640SHendrik Brueckner rc = device_register(smsg_app_dev); 1781ffaa640SHendrik Brueckner if (rc) { 1791ffaa640SHendrik Brueckner put_device(smsg_app_dev); 180*fde25a9bSAlan Stern goto fail; 1811ffaa640SHendrik Brueckner } 1821ffaa640SHendrik Brueckner 18341b42876SHendrik Brueckner /* convert sender to uppercase characters */ 18441b42876SHendrik Brueckner if (sender) { 18541b42876SHendrik Brueckner int len = strlen(sender); 18641b42876SHendrik Brueckner while (len--) 18741b42876SHendrik Brueckner sender[len] = toupper(sender[len]); 18841b42876SHendrik Brueckner } 18941b42876SHendrik Brueckner 1901ffaa640SHendrik Brueckner /* register with the smsgiucv device driver */ 1911ffaa640SHendrik Brueckner rc = smsg_register_callback(SMSG_PREFIX, smsg_app_callback); 1921ffaa640SHendrik Brueckner if (rc) { 1931ffaa640SHendrik Brueckner device_unregister(smsg_app_dev); 194*fde25a9bSAlan Stern goto fail; 1951ffaa640SHendrik Brueckner } 1961ffaa640SHendrik Brueckner 1971ffaa640SHendrik Brueckner rc = 0; 198*fde25a9bSAlan Stern fail: 1991ffaa640SHendrik Brueckner return rc; 2001ffaa640SHendrik Brueckner } 2011ffaa640SHendrik Brueckner module_init(smsgiucv_app_init); 2021ffaa640SHendrik Brueckner 2031ffaa640SHendrik Brueckner static void __exit smsgiucv_app_exit(void) 2041ffaa640SHendrik Brueckner { 2051ffaa640SHendrik Brueckner /* unregister callback */ 2061ffaa640SHendrik Brueckner smsg_unregister_callback(SMSG_PREFIX, smsg_app_callback); 2071ffaa640SHendrik Brueckner 2081ffaa640SHendrik Brueckner /* cancel pending work and flush any queued event work */ 2091ffaa640SHendrik Brueckner cancel_work_sync(&smsg_event_work); 2101ffaa640SHendrik Brueckner smsg_event_work_fn(&smsg_event_work); 2111ffaa640SHendrik Brueckner 2121ffaa640SHendrik Brueckner device_unregister(smsg_app_dev); 2131ffaa640SHendrik Brueckner } 2141ffaa640SHendrik Brueckner module_exit(smsgiucv_app_exit); 2151ffaa640SHendrik Brueckner 2161ffaa640SHendrik Brueckner MODULE_LICENSE("GPL v2"); 2171ffaa640SHendrik Brueckner MODULE_DESCRIPTION("Deliver z/VM CP SMSG as uevents"); 2181ffaa640SHendrik Brueckner MODULE_AUTHOR("Hendrik Brueckner <brueckner@linux.vnet.ibm.com>"); 219