From 332df78e2bb6caadfc6f4714450000ebb1f9d224 Mon Sep 17 00:00:00 2001
From: yukon <yukon@apache.org>
Date: Fri, 11 Aug 2017 22:17:32 +0800
Subject: [PATCH] [ROCKETMQ-261] Use write lock when destroy IndexService

---
 .../java/org/apache/rocketmq/store/index/IndexService.java    | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/store/src/main/java/org/apache/rocketmq/store/index/IndexService.java b/store/src/main/java/org/apache/rocketmq/store/index/IndexService.java
index e562c2ab..b565349e 100644
--- a/store/src/main/java/org/apache/rocketmq/store/index/IndexService.java
+++ b/store/src/main/java/org/apache/rocketmq/store/index/IndexService.java
@@ -142,7 +142,7 @@ public class IndexService {
 
     public void destroy() {
         try {
-            this.readWriteLock.readLock().lock();
+            this.readWriteLock.writeLock().lock();
             for (IndexFile f : this.indexFileList) {
                 f.destroy(1000 * 3);
             }
@@ -150,7 +150,7 @@ public class IndexService {
         } catch (Exception e) {
             log.error("destroy exception", e);
         } finally {
-            this.readWriteLock.readLock().unlock();
+            this.readWriteLock.writeLock().unlock();
         }
     }
 
-- 
GitLab