diff --git a/lib/backend.py b/lib/backend.py
index 47a941f97a9a3f4dbc2732f9e65b1431298ca6e9..027f38617b383be00804d341909b71f7ecb13e2e 100644
--- a/lib/backend.py
+++ b/lib/backend.py
@@ -610,6 +610,23 @@ def GetNodeInfo(vg_names, hv_names, excl_stor):
   return (bootid, vg_info, hv_info)
 
 
+def _CheckExclusivePvs(pvi_list):
+  """Check that PVs are not shared among LVs
+
+  @type pvi_list: list of L{objects.LvmPvInfo} objects
+  @param pvi_list: information about the PVs
+
+  @rtype: list of tuples (string, list of strings)
+  @return: offending volumes, as tuples: (pv_name, [lv1_name, lv2_name...])
+
+  """
+  res = []
+  for pvi in pvi_list:
+    if len(pvi.lv_list) > 1:
+      res.append((pvi.name, pvi.lv_list))
+  return res
+
+
 def VerifyNode(what, cluster_name):
   """Verify the status of the local node.
 
@@ -764,8 +781,15 @@ def VerifyNode(what, cluster_name):
     result[constants.NV_VGLIST] = utils.ListVolumeGroups()
 
   if constants.NV_PVLIST in what and vm_capable:
+    check_exclusive_pvs = constants.NV_EXCLUSIVEPVS in what
     val = bdev.LogicalVolume.GetPVInfo(what[constants.NV_PVLIST],
-                                       filter_allocatable=False)
+                                       filter_allocatable=False,
+                                       include_lvs=check_exclusive_pvs)
+    if check_exclusive_pvs:
+      result[constants.NV_EXCLUSIVEPVS] = _CheckExclusivePvs(val)
+      for pvi in val:
+        # Avoid sending useless data on the wire
+        pvi.lv_list = []
     result[constants.NV_PVLIST] = map(objects.LvmPvInfo.ToDict, val)
 
   if constants.NV_VERSION in what:
diff --git a/lib/cmdlib.py b/lib/cmdlib.py
index 2ac1798038b6cc50e3893b594a9b3c20e04bd0bd..77226800d76f9c3874ba81427c490579489ab5ae 100644
--- a/lib/cmdlib.py
+++ b/lib/cmdlib.py
@@ -1141,6 +1141,12 @@ def _CheckNodePVs(nresult, exclusive_storage):
   if exclusive_storage:
     (errmsgs, es_pvinfo) = utils.LvmExclusiveCheckNodePvs(pvlist)
     errlist.extend(errmsgs)
+    shared_pvs = nresult.get(constants.NV_EXCLUSIVEPVS, None)
+    if shared_pvs:
+      for (pvname, lvlist) in shared_pvs:
+        # TODO: Check that LVs are really unrelated (snapshots, DRBD meta...)
+        errlist.append("PV %s is shared among unrelated LVs (%s)" %
+                       (pvname, utils.CommaJoin(lvlist)))
   return (errlist, es_pvinfo)
 
 
@@ -3486,6 +3492,7 @@ class LUClusterVerifyGroup(LogicalUnit, _VerifyErrors):
     # it's True for at least a node, we act as if it were set for all the nodes
     self._exclusive_storage = compat.any(es_flags.values())
     if self._exclusive_storage:
+      node_verify_param[constants.NV_EXCLUSIVEPVS] = True
       es_unset_nodes = [n for (n, es) in es_flags.items()
                         if not es]
 
diff --git a/lib/constants.py b/lib/constants.py
index 3232e46bf78dcb178cb251dc862747f4d4d15912..2fc7ce9af8d05b51bd367ab12403af6b884cf255 100644
--- a/lib/constants.py
+++ b/lib/constants.py
@@ -1560,6 +1560,7 @@ CV_ALL_ECODES_STRINGS = \
 NV_BRIDGES = "bridges"
 NV_DRBDHELPER = "drbd-helper"
 NV_DRBDLIST = "drbd-list"
+NV_EXCLUSIVEPVS = "exclusive-pvs"
 NV_FILELIST = "filelist"
 NV_FILE_STORAGE_PATHS = "file-storage-paths"
 NV_HVINFO = "hvinfo"