sashakoshka/hopp
sashakoshka/hopp
1
0
Fork 0
Code Issues 2 Pull Requests Actions Packages Projects Releases Wiki Activity

Fix METADAPT-A deadlock when closing transaction

Browse Source
This commit is contained in:
Sasha Koshka 2025-01-28 16:11:23 -05:00
parent 4647f91abe
commit 4daccca66a
1 changed files with 7 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
metadapta.go
View File

@ -104,7 +104,7 @@ func (this *a) receive() {
this.transLock.Lock() this.transLock.Lock()
defer this.transLock.Unlock() defer this.transLock.Unlock()
for _, trans := range this.transMap { for _, trans := range this.transMap {
trans.Close() trans.closeDontUnlist()
} }
clear(this.transMap) clear(this.transMap)
}() }()
@ -163,9 +163,13 @@ type transA struct {
} }
func (this *transA) Close() error { func (this *transA) Close() error {
this.incoming.Close() err := this.closeDontUnlist()
this.parent.unlistTransactionSafe(this.ID()) this.parent.unlistTransactionSafe(this.ID())
return nil return err
}
func (this *transA) closeDontUnlist() error {
return this.incoming.Close()
} }
func (this *transA) ID() int64 { func (this *transA) ID() int64 {