diff options
| author | chrislu <chris.lu@gmail.com> | 2024-01-15 21:22:41 -0800 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2024-01-15 21:22:41 -0800 |
| commit | ba73199174ba00e04fb87c8f1abcff155a809fd4 (patch) | |
| tree | 11a6ebb3d51c7dce6aa8ba267cf0a3025581704a /weed/mq/topic/local_partition.go | |
| parent | 33d5343ea1c93e43a7e4e1e55e982319e7f733d3 (diff) | |
| download | seaweedfs-ba73199174ba00e04fb87c8f1abcff155a809fd4.tar.xz seaweedfs-ba73199174ba00e04fb87c8f1abcff155a809fd4.zip | |
reuse local partition
Diffstat (limited to 'weed/mq/topic/local_partition.go')
| -rw-r--r-- | weed/mq/topic/local_partition.go | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/weed/mq/topic/local_partition.go b/weed/mq/topic/local_partition.go index 84602add7..f4a080f38 100644 --- a/weed/mq/topic/local_partition.go +++ b/weed/mq/topic/local_partition.go @@ -84,13 +84,13 @@ func (p *LocalPartition) GetEarliestInMemoryMessagePosition() log_buffer.Message return p.logBuffer.GetEarliestPosition() } -func FromPbBrokerPartitionAssignment(self pb.ServerAddress, assignment *mq_pb.BrokerPartitionAssignment, logFlushFn log_buffer.LogFlushFuncType, readFromDiskFn log_buffer.LogReadFromDiskFuncType) *LocalPartition { +func FromPbBrokerPartitionAssignment(self pb.ServerAddress, partition Partition, assignment *mq_pb.BrokerPartitionAssignment, logFlushFn log_buffer.LogFlushFuncType, readFromDiskFn log_buffer.LogReadFromDiskFuncType) *LocalPartition { isLeader := assignment.LeaderBroker == string(self) followers := make([]pb.ServerAddress, len(assignment.FollowerBrokers)) for i, followerBroker := range assignment.FollowerBrokers { followers[i] = pb.ServerAddress(followerBroker) } - return NewLocalPartition(FromPbPartition(assignment.Partition), isLeader, followers, logFlushFn, readFromDiskFn) + return NewLocalPartition(partition, isLeader, followers, logFlushFn, readFromDiskFn) } func (p *LocalPartition) closePublishers() { |