From 0df3357cac73a2191cf4e01d5ef8db48a0bcbc64 Mon Sep 17 00:00:00 2001
From: Boris Schrijver <boris@pcextreme.nl>
Date: Wed, 16 Sep 2015 22:17:27 +0200
Subject: [PATCH] Added findByDc(long dcId) to VolumeDao and VolumeDaoImpl.

---
 engine/schema/src/com/cloud/storage/dao/VolumeDao.java    | 2 ++
 .../schema/src/com/cloud/storage/dao/VolumeDaoImpl.java   | 8 ++++++++
 2 files changed, 10 insertions(+)

diff --git a/engine/schema/src/com/cloud/storage/dao/VolumeDao.java b/engine/schema/src/com/cloud/storage/dao/VolumeDao.java
index 05aa3cff4e1..4959ce4d63b 100644
--- a/engine/schema/src/com/cloud/storage/dao/VolumeDao.java
+++ b/engine/schema/src/com/cloud/storage/dao/VolumeDao.java
@@ -47,6 +47,8 @@ public interface VolumeDao extends GenericDao<VolumeVO, Long>, StateDao<Volume.S
 
     List<VolumeVO> findByPod(long podId);
 
+    List<VolumeVO> findByDc(long dcId);
+
     List<VolumeVO> findByAccountAndPod(long accountId, long podId);
 
     List<VolumeVO> findByTemplateAndZone(long templateId, long zoneId);
diff --git a/engine/schema/src/com/cloud/storage/dao/VolumeDaoImpl.java b/engine/schema/src/com/cloud/storage/dao/VolumeDaoImpl.java
index 56e92cff630..7d0c9c31242 100644
--- a/engine/schema/src/com/cloud/storage/dao/VolumeDaoImpl.java
+++ b/engine/schema/src/com/cloud/storage/dao/VolumeDaoImpl.java
@@ -197,6 +197,14 @@ public class VolumeDaoImpl extends GenericDaoBase<VolumeVO, Long> implements Vol
         return listBy(sc);
     }
 
+    @Override
+    public List<VolumeVO> findByDc(long dcId) {
+        SearchCriteria<VolumeVO> sc = AllFieldsSearch.create();
+        sc.setParameters("data_center_id", dcId);
+
+        return listBy(sc);
+    }
+
     @Override
     public List<VolumeVO> findByAccountAndPod(long accountId, long podId) {
         SearchCriteria<VolumeVO> sc = AllFieldsSearch.create();