logging
This commit is contained in:
@@ -136,4 +136,5 @@ func (p *LocalPartition) Shutdown() {
|
|||||||
p.closeSubscribers()
|
p.closeSubscribers()
|
||||||
p.LogBuffer.ShutdownLogBuffer()
|
p.LogBuffer.ShutdownLogBuffer()
|
||||||
atomic.StoreInt32(&p.FollowerId, 0)
|
atomic.StoreInt32(&p.FollowerId, 0)
|
||||||
|
glog.V(0).Infof("local partition %v shutting down", p.Partition)
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user