Lines Matching refs:nbd
43 #include <linux/nbd.h>
44 #include <linux/nbd-netlink.h>
48 #include <trace/events/nbd.h>
66 struct nbd_device *nbd;
121 pid_t pid; /* pid of nbd-client, if attached */
133 struct nbd_device *nbd;
147 #define nbd_name(nbd) ((nbd)->disk->disk_name)
157 static int nbd_dev_dbg_init(struct nbd_device *nbd);
158 static void nbd_dev_dbg_close(struct nbd_device *nbd);
159 static void nbd_config_put(struct nbd_device *nbd);
163 static void nbd_disconnect_and_put(struct nbd_device *nbd);
165 static inline struct device *nbd_to_dev(struct nbd_device *nbd)
167 return disk_to_dev(nbd->disk);
215 struct nbd_device *nbd = (struct nbd_device *)disk->private_data;
217 return sprintf(buf, "%d\n", nbd->pid);
225 static void nbd_dev_remove(struct nbd_device *nbd)
227 struct gendisk *disk = nbd->disk;
234 blk_mq_free_tag_set(&nbd->tag_set);
240 * Place this in the last just before the nbd is freed to
245 if (test_bit(NBD_DESTROY_ON_DISCONNECT, &nbd->flags) && nbd->destroy_complete)
246 complete(nbd->destroy_complete);
248 kfree(nbd);
251 static void nbd_put(struct nbd_device *nbd)
253 if (refcount_dec_and_mutex_lock(&nbd->refs,
255 idr_remove(&nbd_index_idr, nbd->index);
256 nbd_dev_remove(nbd);
267 static void nbd_mark_nsock_dead(struct nbd_device *nbd, struct nbd_sock *nsock,
270 if (!nsock->dead && notify && !nbd_disconnected(nbd->config)) {
275 args->index = nbd->index;
281 if (atomic_dec_return(&nbd->config->live_connections) == 0) {
283 &nbd->config->runtime_flags)) {
285 &nbd->config->runtime_flags);
286 dev_info(nbd_to_dev(nbd),
296 static void nbd_size_clear(struct nbd_device *nbd)
298 if (nbd->config->bytesize) {
299 set_capacity(nbd->disk, 0);
300 kobject_uevent(&nbd_to_dev(nbd)->kobj, KOBJ_CHANGE);
304 static void nbd_size_update(struct nbd_device *nbd, bool start)
306 struct nbd_config *config = nbd->config;
307 struct block_device *bdev = bdget_disk(nbd->disk, 0);
311 nbd->disk->queue->limits.discard_granularity = config->blksize;
312 nbd->disk->queue->limits.discard_alignment = config->blksize;
313 blk_queue_max_discard_sectors(nbd->disk->queue, UINT_MAX);
315 blk_queue_logical_block_size(nbd->disk->queue, config->blksize);
316 blk_queue_physical_block_size(nbd->disk->queue, config->blksize);
317 set_capacity(nbd->disk, nr_sectors);
324 set_bit(GD_NEED_PART_SCAN, &nbd->disk->state);
327 kobject_uevent(&nbd_to_dev(nbd)->kobj, KOBJ_CHANGE);
330 static void nbd_size_set(struct nbd_device *nbd, loff_t blocksize,
333 struct nbd_config *config = nbd->config;
336 if (nbd->pid)
337 nbd_size_update(nbd, false);
344 dev_dbg(nbd_to_dev(cmd->nbd), "request %p: %s\n", req,
353 static void sock_shutdown(struct nbd_device *nbd)
355 struct nbd_config *config = nbd->config;
366 nbd_mark_nsock_dead(nbd, nsock, 0);
369 dev_warn(disk_to_dev(nbd->disk), "shutting down sockets\n");
392 struct nbd_device *nbd = cmd->nbd;
403 if (!refcount_inc_not_zero(&nbd->config_refs)) {
408 config = nbd->config;
411 (config->num_connections == 1 && nbd->tag_set.timeout)) {
412 dev_err_ratelimited(nbd_to_dev(nbd),
434 nbd_mark_nsock_dead(nbd, nsock, 1);
439 nbd_config_put(nbd);
444 if (!nbd->tag_set.timeout) {
451 dev_info(nbd_to_dev(nbd), "Possible stuck request %p: control (%s@%llu,%uB). Runtime %u seconds\n",
461 nbd_config_put(nbd);
466 nbd_config_put(nbd);
470 dev_err_ratelimited(nbd_to_dev(nbd), "Connection timed out\n");
474 sock_shutdown(nbd);
475 nbd_config_put(nbd);
485 static int sock_xmit(struct nbd_device *nbd, int index, int send,
488 struct nbd_config *config = nbd->config;
495 dev_err_ratelimited(disk_to_dev(nbd->disk),
541 static int nbd_send_cmd(struct nbd_device *nbd, struct nbd_cmd *cmd, int index)
544 struct nbd_config *config = nbd->config;
565 dev_err_ratelimited(disk_to_dev(nbd->disk),
601 trace_nbd_send_request(&request, nbd->index, blk_mq_rq_from_pdu(cmd));
603 dev_dbg(nbd_to_dev(nbd), "request %p: sending control (%s@%llu,%uB)\n",
606 result = sock_xmit(nbd, index, 1, &from,
623 dev_err_ratelimited(disk_to_dev(nbd->disk),
641 dev_dbg(nbd_to_dev(nbd), "request %p: sending %d bytes data\n",
652 result = sock_xmit(nbd, index, 1, &from, flags, &sent);
664 dev_err(disk_to_dev(nbd->disk),
687 static int nbd_read_reply(struct nbd_device *nbd, int index,
696 result = sock_xmit(nbd, index, 0, &to, MSG_WAITALL, NULL);
698 if (!nbd_disconnected(nbd->config))
699 dev_err(disk_to_dev(nbd->disk),
705 dev_err(disk_to_dev(nbd->disk), "Wrong magic (0x%lx)\n",
714 static struct nbd_cmd *nbd_handle_reply(struct nbd_device *nbd, int index,
728 if (hwq < nbd->tag_set.nr_hw_queues)
729 req = blk_mq_tag_to_rq(nbd->tag_set.tags[hwq],
732 dev_err(disk_to_dev(nbd->disk), "Unexpected reply (%d) %p\n",
741 dev_err(disk_to_dev(nbd->disk), "Suspicious reply %d (status %u flags %lu)",
747 dev_err(disk_to_dev(nbd->disk), "Unexpected reply %d from different sock %d (expected %d)",
751 dev_err(disk_to_dev(nbd->disk), "Double reply on req %p, cmd_cookie %u, handle cookie %u\n",
757 dev_err(disk_to_dev(nbd->disk), "Command already handled %p\n",
763 dev_err(disk_to_dev(nbd->disk), "Raced with timeout on req %p\n",
769 dev_err(disk_to_dev(nbd->disk), "Other side returned error (%d)\n",
775 dev_dbg(nbd_to_dev(nbd), "request %p: got reply\n", req);
783 result = sock_xmit(nbd, index, 0, &to, MSG_WAITALL, NULL);
785 dev_err(disk_to_dev(nbd->disk), "Receive data failed (result %d)\n",
793 if (nbd_disconnected(nbd->config)) {
800 dev_dbg(nbd_to_dev(nbd), "request %p: got %d bytes data\n",
815 struct nbd_device *nbd = args->nbd;
816 struct nbd_config *config = nbd->config;
817 struct request_queue *q = nbd->disk->queue;
825 if (nbd_read_reply(nbd, args->index, &reply))
835 dev_err(disk_to_dev(nbd->disk), "%s: no io inflight\n",
840 cmd = nbd_handle_reply(nbd, args->index, &reply);
854 nbd_mark_nsock_dead(nbd, nsock, 1);
857 nbd_config_put(nbd);
883 static void nbd_clear_que(struct nbd_device *nbd)
885 blk_mq_quiesce_queue(nbd->disk->queue);
886 blk_mq_tagset_busy_iter(&nbd->tag_set, nbd_clear_req, NULL);
887 blk_mq_unquiesce_queue(nbd->disk->queue);
888 dev_dbg(disk_to_dev(nbd->disk), "queue cleared\n");
891 static int find_fallback(struct nbd_device *nbd, int index)
893 struct nbd_config *config = nbd->config;
902 dev_err_ratelimited(disk_to_dev(nbd->disk),
925 dev_err_ratelimited(disk_to_dev(nbd->disk),
934 static int wait_for_reconnect(struct nbd_device *nbd)
936 struct nbd_config *config = nbd->config;
953 struct nbd_device *nbd = cmd->nbd;
958 if (!refcount_inc_not_zero(&nbd->config_refs)) {
959 dev_err_ratelimited(disk_to_dev(nbd->disk),
963 config = nbd->config;
966 dev_err_ratelimited(disk_to_dev(nbd->disk),
968 nbd_config_put(nbd);
977 index = find_fallback(nbd, index);
980 if (wait_for_reconnect(nbd)) {
990 sock_shutdown(nbd);
991 nbd_config_put(nbd);
1012 ret = nbd_send_cmd(nbd, cmd, index);
1020 dev_err_ratelimited(disk_to_dev(nbd->disk),
1022 nbd_mark_nsock_dead(nbd, nsock, 1);
1028 nbd_config_put(nbd);
1065 static struct socket *nbd_get_socket(struct nbd_device *nbd, unsigned long fd,
1076 dev_err(disk_to_dev(nbd->disk), "Unsupported socket: shutdown callout must be supported.\n");
1085 static int nbd_add_socket(struct nbd_device *nbd, unsigned long arg,
1088 struct nbd_config *config = nbd->config;
1094 sock = nbd_get_socket(nbd, arg, &err);
1102 blk_mq_freeze_queue(nbd->disk->queue);
1104 if (!netlink && !nbd->task_setup &&
1106 nbd->task_setup = current;
1109 (nbd->task_setup != current ||
1111 dev_err(disk_to_dev(nbd->disk),
1142 blk_mq_unfreeze_queue(nbd->disk->queue);
1147 blk_mq_unfreeze_queue(nbd->disk->queue);
1152 static int nbd_reconnect_socket(struct nbd_device *nbd, unsigned long arg)
1154 struct nbd_config *config = nbd->config;
1160 sock = nbd_get_socket(nbd, arg, &err);
1182 if (nbd->tag_set.timeout)
1183 sock->sk->sk_sndtimeo = nbd->tag_set.timeout;
1185 refcount_inc(&nbd->config_refs);
1192 args->nbd = nbd;
1202 queue_work(nbd->recv_workq, &args->work);
1220 static void nbd_parse_flags(struct nbd_device *nbd)
1222 struct nbd_config *config = nbd->config;
1224 set_disk_ro(nbd->disk, true);
1226 set_disk_ro(nbd->disk, false);
1228 blk_queue_flag_set(QUEUE_FLAG_DISCARD, nbd->disk->queue);
1231 blk_queue_write_cache(nbd->disk->queue, true, true);
1233 blk_queue_write_cache(nbd->disk->queue, true, false);
1236 blk_queue_write_cache(nbd->disk->queue, false, false);
1239 static void send_disconnects(struct nbd_device *nbd)
1241 struct nbd_config *config = nbd->config;
1255 ret = sock_xmit(nbd, i, 1, &from, 0, NULL);
1257 dev_err(disk_to_dev(nbd->disk),
1263 static int nbd_disconnect(struct nbd_device *nbd)
1265 struct nbd_config *config = nbd->config;
1267 dev_info(disk_to_dev(nbd->disk), "NBD_DISCONNECT\n");
1269 set_bit(NBD_DISCONNECT_REQUESTED, &nbd->flags);
1270 send_disconnects(nbd);
1274 static void nbd_clear_sock(struct nbd_device *nbd)
1276 sock_shutdown(nbd);
1277 nbd_clear_que(nbd);
1278 nbd->task_setup = NULL;
1281 static void nbd_config_put(struct nbd_device *nbd)
1283 if (refcount_dec_and_mutex_lock(&nbd->config_refs,
1284 &nbd->config_lock)) {
1285 struct nbd_config *config = nbd->config;
1286 nbd_dev_dbg_close(nbd);
1287 nbd_size_clear(nbd);
1290 device_remove_file(disk_to_dev(nbd->disk), &pid_attr);
1291 nbd->pid = 0;
1292 nbd_clear_sock(nbd);
1301 kfree(nbd->config);
1302 nbd->config = NULL;
1304 if (nbd->recv_workq)
1305 destroy_workqueue(nbd->recv_workq);
1306 nbd->recv_workq = NULL;
1308 nbd->tag_set.timeout = 0;
1309 nbd->disk->queue->limits.discard_granularity = 0;
1310 nbd->disk->queue->limits.discard_alignment = 0;
1311 blk_queue_max_discard_sectors(nbd->disk->queue, UINT_MAX);
1312 blk_queue_flag_clear(QUEUE_FLAG_DISCARD, nbd->disk->queue);
1314 mutex_unlock(&nbd->config_lock);
1315 nbd_put(nbd);
1320 static int nbd_start_device(struct nbd_device *nbd)
1322 struct nbd_config *config = nbd->config;
1326 if (nbd->pid)
1332 dev_err(disk_to_dev(nbd->disk), "server does not support multiple connections per device.\n");
1336 nbd->recv_workq = alloc_workqueue("knbd%d-recv",
1338 WQ_UNBOUND, 0, nbd->index);
1339 if (!nbd->recv_workq) {
1340 dev_err(disk_to_dev(nbd->disk), "Could not allocate knbd recv work queue.\n");
1344 blk_mq_update_nr_hw_queues(&nbd->tag_set, config->num_connections);
1345 nbd->pid = task_pid_nr(current);
1347 nbd_parse_flags(nbd);
1349 error = device_create_file(disk_to_dev(nbd->disk), &pid_attr);
1351 dev_err(disk_to_dev(nbd->disk), "device_create_file failed!\n");
1356 nbd_dev_dbg_init(nbd);
1362 sock_shutdown(nbd);
1372 flush_workqueue(nbd->recv_workq);
1376 if (nbd->tag_set.timeout)
1378 nbd->tag_set.timeout;
1380 refcount_inc(&nbd->config_refs);
1382 args->nbd = nbd;
1384 queue_work(nbd->recv_workq, &args->work);
1386 nbd_size_update(nbd, true);
1390 static int nbd_start_device_ioctl(struct nbd_device *nbd, struct block_device *bdev)
1392 struct nbd_config *config = nbd->config;
1395 ret = nbd_start_device(nbd);
1400 set_bit(GD_NEED_PART_SCAN, &nbd->disk->state);
1401 mutex_unlock(&nbd->config_lock);
1405 sock_shutdown(nbd);
1406 nbd_clear_que(nbd);
1409 flush_workqueue(nbd->recv_workq);
1410 mutex_lock(&nbd->config_lock);
1420 static void nbd_clear_sock_ioctl(struct nbd_device *nbd,
1423 nbd_clear_sock(nbd);
1427 &nbd->config->runtime_flags))
1428 nbd_config_put(nbd);
1439 static void nbd_set_cmd_timeout(struct nbd_device *nbd, u64 timeout)
1441 nbd->tag_set.timeout = timeout * HZ;
1443 blk_queue_rq_timeout(nbd->disk->queue, timeout * HZ);
1445 blk_queue_rq_timeout(nbd->disk->queue, 30 * HZ);
1449 static int __nbd_ioctl(struct block_device *bdev, struct nbd_device *nbd,
1452 struct nbd_config *config = nbd->config;
1457 return nbd_disconnect(nbd);
1459 nbd_clear_sock_ioctl(nbd, bdev);
1462 return nbd_add_socket(nbd, arg, false);
1468 nbd_size_set(nbd, arg,
1472 nbd_size_set(nbd, config->blksize,
1478 nbd_size_set(nbd, config->blksize, arg);
1481 nbd_set_cmd_timeout(nbd, arg);
1488 return nbd_start_device_ioctl(nbd, bdev);
1508 struct nbd_device *nbd = bdev->bd_disk->private_data;
1509 struct nbd_config *config = nbd->config;
1515 /* The block layer will pass back some non-nbd ioctls in case we have
1521 mutex_lock(&nbd->config_lock);
1523 /* Don't allow ioctl operations on a nbd device that was created with
1528 error = __nbd_ioctl(bdev, nbd, cmd, arg);
1530 dev_err(nbd_to_dev(nbd), "Cannot use ioctl interface on a netlink controlled device.\n");
1531 mutex_unlock(&nbd->config_lock);
1558 struct nbd_device *nbd;
1562 nbd = bdev->bd_disk->private_data;
1563 if (!nbd) {
1567 if (!refcount_inc_not_zero(&nbd->refs)) {
1571 if (!refcount_inc_not_zero(&nbd->config_refs)) {
1574 mutex_lock(&nbd->config_lock);
1575 if (refcount_inc_not_zero(&nbd->config_refs)) {
1576 mutex_unlock(&nbd->config_lock);
1582 mutex_unlock(&nbd->config_lock);
1585 nbd->config = config;
1586 refcount_set(&nbd->config_refs, 1);
1587 refcount_inc(&nbd->refs);
1588 mutex_unlock(&nbd->config_lock);
1590 } else if (nbd_disconnected(nbd->config)) {
1600 struct nbd_device *nbd = disk->private_data;
1603 if (test_bit(NBD_RT_DISCONNECT_ON_CLOSE, &nbd->config->runtime_flags) &&
1605 nbd_disconnect_and_put(nbd);
1608 nbd_config_put(nbd);
1609 nbd_put(nbd);
1625 struct nbd_device *nbd = s->private;
1627 if (nbd->pid)
1628 seq_printf(s, "recv: %d\n", nbd->pid);
1647 struct nbd_device *nbd = s->private;
1648 u32 flags = nbd->config->flags;
1680 static int nbd_dev_dbg_init(struct nbd_device *nbd)
1683 struct nbd_config *config = nbd->config;
1688 dir = debugfs_create_dir(nbd_name(nbd), nbd_dbg_dir);
1690 dev_err(nbd_to_dev(nbd), "Failed to create debugfs dir for '%s'\n",
1691 nbd_name(nbd));
1696 debugfs_create_file("tasks", 0444, dir, nbd, &nbd_dbg_tasks_ops);
1698 debugfs_create_u32("timeout", 0444, dir, &nbd->tag_set.timeout);
1700 debugfs_create_file("flags", 0444, dir, nbd, &nbd_dbg_flags_ops);
1705 static void nbd_dev_dbg_close(struct nbd_device *nbd)
1707 debugfs_remove_recursive(nbd->config->dbg_dir);
1714 dbg_dir = debugfs_create_dir("nbd", NULL);
1730 static int nbd_dev_dbg_init(struct nbd_device *nbd)
1735 static void nbd_dev_dbg_close(struct nbd_device *nbd)
1754 cmd->nbd = set->driver_data;
1769 struct nbd_device *nbd;
1774 nbd = kzalloc(sizeof(struct nbd_device), GFP_KERNEL);
1775 if (!nbd)
1783 err = idr_alloc(&nbd_index_idr, nbd, index, index + 1,
1788 err = idr_alloc(&nbd_index_idr, nbd, 0,
1796 nbd->index = index;
1797 nbd->disk = disk;
1798 nbd->tag_set.ops = &nbd_mq_ops;
1799 nbd->tag_set.nr_hw_queues = 1;
1800 nbd->tag_set.queue_depth = 128;
1801 nbd->tag_set.numa_node = NUMA_NO_NODE;
1802 nbd->tag_set.cmd_size = sizeof(struct nbd_cmd);
1803 nbd->tag_set.flags = BLK_MQ_F_SHOULD_MERGE |
1805 nbd->tag_set.driver_data = nbd;
1806 nbd->destroy_complete = NULL;
1808 err = blk_mq_alloc_tag_set(&nbd->tag_set);
1812 q = blk_mq_init_queue(&nbd->tag_set);
1832 mutex_init(&nbd->config_lock);
1833 refcount_set(&nbd->config_refs, 0);
1834 refcount_set(&nbd->refs, 1);
1835 INIT_LIST_HEAD(&nbd->list);
1839 disk->private_data = nbd;
1840 sprintf(disk->disk_name, "nbd%d", index);
1846 blk_mq_free_tag_set(&nbd->tag_set);
1852 kfree(nbd);
1859 struct nbd_device *nbd = ptr;
1862 if (!refcount_read(&nbd->config_refs)) {
1863 *found = nbd;
1895 static int nbd_genl_size_set(struct genl_info *info, struct nbd_device *nbd)
1897 struct nbd_config *config = nbd->config;
1915 nbd_size_set(nbd, bsize, div64_u64(bytes, bsize));
1922 struct nbd_device *nbd = NULL;
1940 printk(KERN_ERR "nbd: illegal input index %d\n", index);
1945 printk(KERN_ERR "nbd: must specify at least one socket\n");
1949 printk(KERN_ERR "nbd: must specify a size in bytes for the device\n");
1955 ret = idr_for_each(&nbd_index_idr, &find_free_cb, &nbd);
1961 printk(KERN_ERR "nbd: failed to add new device\n");
1964 nbd = idr_find(&nbd_index_idr, new_index);
1967 nbd = idr_find(&nbd_index_idr, index);
1968 if (!nbd) {
1972 printk(KERN_ERR "nbd: failed to add new device\n");
1975 nbd = idr_find(&nbd_index_idr, index);
1978 if (!nbd) {
1979 printk(KERN_ERR "nbd: couldn't find device at index %d\n",
1985 if (test_bit(NBD_DESTROY_ON_DISCONNECT, &nbd->flags) &&
1986 test_bit(NBD_DISCONNECT_REQUESTED, &nbd->flags)) {
1987 nbd->destroy_complete = &destroy_complete;
1990 /* Wait untill the the nbd stuff is totally destroyed */
1995 if (!refcount_inc_not_zero(&nbd->refs)) {
1999 printk(KERN_ERR "nbd: device at index %d is going down\n",
2005 mutex_lock(&nbd->config_lock);
2006 if (refcount_read(&nbd->config_refs)) {
2007 mutex_unlock(&nbd->config_lock);
2008 nbd_put(nbd);
2011 printk(KERN_ERR "nbd: nbd%d already in use\n", index);
2014 if (WARN_ON(nbd->config)) {
2015 mutex_unlock(&nbd->config_lock);
2016 nbd_put(nbd);
2021 mutex_unlock(&nbd->config_lock);
2022 nbd_put(nbd);
2023 printk(KERN_ERR "nbd: couldn't allocate config\n");
2026 nbd->config = config;
2027 refcount_set(&nbd->config_refs, 1);
2030 ret = nbd_genl_size_set(info, nbd);
2035 nbd_set_cmd_timeout(nbd,
2057 &nbd->flags))
2061 &nbd->flags))
2062 refcount_inc(&nbd->refs);
2079 printk(KERN_ERR "nbd: socks must be embedded in a SOCK_ITEM attr\n");
2088 printk(KERN_ERR "nbd: error processing sock list\n");
2095 ret = nbd_add_socket(nbd, fd, true);
2100 ret = nbd_start_device(nbd);
2102 mutex_unlock(&nbd->config_lock);
2105 refcount_inc(&nbd->config_refs);
2106 nbd_connect_reply(info, nbd->index);
2108 nbd_config_put(nbd);
2110 nbd_put(nbd);
2114 static void nbd_disconnect_and_put(struct nbd_device *nbd)
2116 mutex_lock(&nbd->config_lock);
2117 nbd_disconnect(nbd);
2118 sock_shutdown(nbd);
2119 wake_up(&nbd->config->conn_wait);
2126 if (nbd->recv_workq)
2127 flush_workqueue(nbd->recv_workq);
2128 nbd_clear_que(nbd);
2129 nbd->task_setup = NULL;
2130 mutex_unlock(&nbd->config_lock);
2133 &nbd->config->runtime_flags))
2134 nbd_config_put(nbd);
2139 struct nbd_device *nbd;
2146 printk(KERN_ERR "nbd: must specify an index to disconnect\n");
2151 nbd = idr_find(&nbd_index_idr, index);
2152 if (!nbd) {
2154 printk(KERN_ERR "nbd: couldn't find device at index %d\n",
2158 if (!refcount_inc_not_zero(&nbd->refs)) {
2160 printk(KERN_ERR "nbd: device at index %d is going down\n",
2165 if (!refcount_inc_not_zero(&nbd->config_refs)) {
2166 nbd_put(nbd);
2169 nbd_disconnect_and_put(nbd);
2170 nbd_config_put(nbd);
2171 nbd_put(nbd);
2177 struct nbd_device *nbd = NULL;
2187 printk(KERN_ERR "nbd: must specify a device to reconfigure\n");
2192 nbd = idr_find(&nbd_index_idr, index);
2193 if (!nbd) {
2195 printk(KERN_ERR "nbd: couldn't find a device at index %d\n",
2199 if (!refcount_inc_not_zero(&nbd->refs)) {
2201 printk(KERN_ERR "nbd: device at index %d is going down\n",
2207 if (!refcount_inc_not_zero(&nbd->config_refs)) {
2208 dev_err(nbd_to_dev(nbd),
2210 nbd_put(nbd);
2214 mutex_lock(&nbd->config_lock);
2215 config = nbd->config;
2217 !nbd->pid) {
2218 dev_err(nbd_to_dev(nbd),
2224 ret = nbd_genl_size_set(info, nbd);
2229 nbd_set_cmd_timeout(nbd,
2240 &nbd->flags))
2244 &nbd->flags))
2245 refcount_inc(&nbd->refs);
2266 printk(KERN_ERR "nbd: socks must be embedded in a SOCK_ITEM attr\n");
2275 printk(KERN_ERR "nbd: error processing sock list\n");
2282 ret = nbd_reconnect_socket(nbd, fd);
2288 dev_info(nbd_to_dev(nbd), "reconnected socket\n");
2292 mutex_unlock(&nbd->config_lock);
2293 nbd_config_put(nbd);
2294 nbd_put(nbd);
2296 nbd_put(nbd);
2340 static int populate_nbd_status(struct nbd_device *nbd, struct sk_buff *reply)
2353 if (refcount_read(&nbd->config_refs))
2358 ret = nla_put_u32(reply, NBD_DEVICE_INDEX, nbd->index);
2371 struct nbd_device *nbd = ptr;
2372 return populate_nbd_status(nbd, (struct sk_buff *)data);
2417 struct nbd_device *nbd;
2418 nbd = idr_find(&nbd_index_idr, index);
2419 if (nbd) {
2420 ret = populate_nbd_status(nbd, reply);
2498 printk(KERN_ERR "nbd: max_part must be >= 0\n");
2523 if (register_blkdev(NBD_MAJOR, "nbd"))
2527 unregister_blkdev(NBD_MAJOR, "nbd");
2542 struct nbd_device *nbd = ptr;
2544 list_add_tail(&nbd->list, list);
2550 struct nbd_device *nbd;
2566 nbd = list_first_entry(&del_list, struct nbd_device, list);
2567 list_del_init(&nbd->list);
2568 if (refcount_read(&nbd->config_refs))
2569 printk(KERN_ERR "nbd: possibly leaking nbd_config (ref %d)\n",
2570 refcount_read(&nbd->config_refs));
2571 if (refcount_read(&nbd->refs) != 1)
2572 printk(KERN_ERR "nbd: possibly leaking a device\n");
2573 nbd_put(nbd);
2577 unregister_blkdev(NBD_MAJOR, "nbd");