/* * Copyright (c) 2011 Bryan Schumaker * * Uses debugfs to create fault injection points for client testing */ #include #include #include #include #include #include #include #include "state.h" #include "netns.h" struct nfsd_fault_inject_op { char *file; u64 (*get)(void); u64 (*set_val)(u64); u64 (*set_clnt)(struct sockaddr_storage *, size_t); }; static struct dentry *debug_dir; static ssize_t fault_inject_read(struct file *file, char __user *buf, size_t len, loff_t *ppos) { static u64 val; char read_buf[25]; size_t size; loff_t pos = *ppos; struct nfsd_fault_inject_op *op = file_inode(file)->i_private; if (!pos) val = op->get(); size = scnprintf(read_buf, sizeof(read_buf), "%llu\n", val); return simple_read_from_buffer(buf, len, ppos, read_buf, size); } static ssize_t fault_inject_write(struct file *file, const char __user *buf, size_t len, loff_t *ppos) { char write_buf[INET6_ADDRSTRLEN]; size_t size = min(sizeof(write_buf) - 1, len); struct net *net = current->nsproxy->net_ns; struct sockaddr_storage sa; struct nfsd_fault_inject_op *op = file_inode(file)->i_private; u64 val; char *nl; if (copy_from_user(write_buf, buf, size)) return -EFAULT; write_buf[size] = '\0'; /* Deal with any embedded newlines in the string */ nl = strchr(write_buf, '\n'); if (nl) { size = nl - write_buf; *nl = '\0'; } size = rpc_pton(net, write_buf, size, (struct sockaddr *)&sa, sizeof(sa)); if (size > 0) { val = op->set_clnt(&sa, size); if (val) pr_info("NFSD [%s]: Client %s had %llu state object(s)\n", op->file, write_buf, val); } else { val = simple_strtoll(write_buf, NULL, 0); if (val == 0) pr_info("NFSD Fault Injection: %s (all)", op->file); else pr_info("NFSD Fault Injection: %s (n = %llu)", op->file, val); val = op->set_val(val); pr_info("NFSD: %s: found %llu", op->file, val); } return len; /* on success, claim we got the whole input */ } static const struct file_operations fops_nfsd = { .owner = THIS_MODULE, .read = fault_inject_read, .write = fault_inject_write, }; void nfsd_fault_inject_cleanup(void) { debugfs_remove_recursive(debug_dir); } static struct nfsd_fault_inject_op inject_ops[] = { { .file = "forget_clients", .get = nfsd_inject_print_clients, .set_val = nfsd_inject_forget_clients, .set_clnt = nfsd_inject_forget_client, }, { .file = "forget_locks", .get = nfsd_inject_print_locks, .set_val = nfsd_inject_forget_locks, .set_clnt = nfsd_inject_forget_client_locks, }, { .file = "forget_openowners", .get = nfsd_inject_print_openowners, .set_val = nfsd_inject_forget_openowners, .set_clnt = nfsd_inject_forget_client_openowners, }, { .file = "forget_delegations", .get = nfsd_inject_print_delegations, .set_val = nfsd_inject_forget_delegations, .set_clnt = nfsd_inject_forget_client_delegations, }, { .file = "recall_delegations", .get = nfsd_inject_print_delegations, .set_val = nfsd_inject_recall_delegations, .set_clnt = nfsd_inject_recall_client_delegations, }, }; #define NUM_INJECT_OPS (sizeof(inject_ops)/sizeof(struct nfsd_fault_inject_op)) int nfsd_fault_inject_init(void) { unsigned int i; struct nfsd_fault_inject_op *op; umode_t mode = S_IFREG | S_IRUSR | S_IWUSR; debug_dir = debugfs_create_dir("nfsd", NULL); if (!debug_dir) goto fail; for (i = 0; i < NUM_INJECT_OPS; i++) { op = &inject_ops[i]; if (!debugfs_create_file(op->file, mode, debug_dir, op, &fops_nfsd)) goto fail; } return 0; fail: nfsd_fault_inject_cleanup(); return -ENOMEM; } ctrl'>space:mode:
authorMauro Carvalho Chehab <mchehab@s-opensource.com>2016-12-26 14:09:28 -0200
committerMauro Carvalho Chehab <mchehab@s-opensource.com>2016-12-26 14:09:28 -0200
commit0e0694ff1a7791274946b7f51bae692da0001a08 (patch)
tree53d28f58d793c151aa870f17d38ddec6ac01ec7a /include/rdma/ib_verbs.h
parent65390ea01ce678379da32b01f39fcfac4903f256 (diff)
parentc739c0a7c3c2472d7562b8f802cdce44d2597c8b (diff)
Merge branch 'patchwork' into v4l_for_linus
* patchwork: [media] s5k4ecgx: select CRC32 helper [media] dvb: avoid warning in dvb_net [media] v4l: tvp5150: Don't override output pinmuxing at stream on/off time [media] v4l: tvp5150: Fix comment regarding output pin muxing [media] v4l: tvp5150: Reset device at probe time, not in get/set format handlers [media] pctv452e: move buffer to heap, no mutex [media] media/cobalt: use pci_irq_allocate_vectors [media] cec: fix race between configuring and unconfiguring [media] cec: move cec_report_phys_addr into cec_config_thread_func [media] cec: replace cec_report_features by cec_fill_msg_report_features [media] cec: update log_addr[] before finishing configuration [media] cec: CEC_MSG_GIVE_FEATURES should abort for CEC version < 2 [media] cec: when canceling a message, don't overwrite old status info [media] cec: fix report_current_latency [media] smiapp: Make suspend and resume functions __maybe_unused [media] smiapp: Implement power-on and power-off sequences without runtime PM
Diffstat (limited to 'include/rdma/ib_verbs.h')