@@ -26,7 +26,6 @@ import (
26
26
"sort"
27
27
"strconv"
28
28
"strings"
29
- "sync"
30
29
"syscall"
31
30
"time"
32
31
@@ -36,6 +35,7 @@ import (
36
35
"github.com/algorand/go-algorand/data/transactions"
37
36
"github.com/algorand/go-algorand/network"
38
37
"github.com/algorand/go-algorand/protocol"
38
+ "github.com/algorand/go-deadlock"
39
39
kzstd "github.com/klauspost/compress/zstd"
40
40
"github.com/valyala/gozstd"
41
41
)
@@ -109,24 +109,24 @@ type tagStats struct {
109
109
compressedBytes uint64
110
110
messageCount uint64
111
111
contextBytes uint64
112
- mu sync .Mutex
112
+ mu deadlock .Mutex
113
113
}
114
114
115
115
// compressDumpHandler extends dumpHandler with compression functionality
116
116
type compressDumpHandler struct {
117
117
* dumpHandler // Embed the original dumpHandler
118
118
stats map [protocol.Tag ]* tagStats
119
- statsMutex sync .Mutex
119
+ statsMutex deadlock .Mutex
120
120
compressor * zstd.BulkProcessor
121
121
contexts map [string ]* CompressionContext
122
- contextMu sync .Mutex
122
+ contextMu deadlock .Mutex
123
123
dict []byte
124
124
cdict * gozstd.CDict // Reusable gozstd dictionary
125
125
126
126
// Tag-specific context configuration
127
127
tagContexts map [protocol.Tag ]int // Maps tag to window size
128
128
tagGroups map [protocol.Tag ]string // Maps tag to group name for shared contexts
129
- tagContextsMu sync .Mutex
129
+ tagContextsMu deadlock .Mutex
130
130
}
131
131
132
132
// setupCompressSignalHandler sets up a signal handler for the compressDumpHandler
0 commit comments