bugfix:mmap pageQuery nil poniter

Please enter the commit message for your changes. Lines starting modified: store/mmap/kite_mmap_store.go
songshubing · Mar 25, 2015 · d463d69 · d463d69
1 parent 0f5b57a
commit d463d69
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/store/mmap/kite_mmap_store.go b/store/mmap/kite_mmap_store.go
@@ -102,6 +102,8 @@ func (self *KiteMMapStore) Delete(messageId string) bool {
 //根据kiteServer名称查询需要重投的消息 返回值为 是否还有更多、和本次返回的数据结果
 func (self *KiteMMapStore) PageQueryEntity(hashKey string, kiteServer string, nextDeliveryTime int64, startIdx, limit int) (bool, []*MessageEntity) {
 	pe := make([]*MessageEntity, 0, limit+1)
+	self.lock.RLock()
+	defer self.lock.RUnlock()
 	for e := self.datalink.Back(); nil != e; e = e.Prev() {
 		entity := e.Value.(*MessageEntity)
 		if entity.NextDeliverTime <= nextDeliveryTime &&