|
@@ -292,7 +292,11 @@ int ceph_msgr_init(void)
|
|
if (ceph_msgr_slab_init())
|
|
if (ceph_msgr_slab_init())
|
|
return -ENOMEM;
|
|
return -ENOMEM;
|
|
|
|
|
|
- ceph_msgr_wq = alloc_workqueue("ceph-msgr", 0, 0);
|
|
|
|
|
|
+ /*
|
|
|
|
+ * The number of active work items is limited by the number of
|
|
|
|
+ * connections, so leave @max_active at default.
|
|
|
|
+ */
|
|
|
|
+ ceph_msgr_wq = alloc_workqueue("ceph-msgr", WQ_MEM_RECLAIM, 0);
|
|
if (ceph_msgr_wq)
|
|
if (ceph_msgr_wq)
|
|
return 0;
|
|
return 0;
|
|
|
|
|