|
configuration.RegistryPacketsMutex.Lock() |
|
for _, packet := range configuration.RegistryPackets { |
|
if err := session.WritePacket(packet); err != nil { |
|
return err |
|
} |
|
session.registryIndexes[packet.RegistryId] = slices.Clone(packet.Indexes) |
|
} |
|
configuration.RegistryPacketsMutex.Unlock() |
Improper handling of the error may lead to a deadlock by forgetting to unlock the mutex.
Zeppelin/server/session/std/session.go
Lines 273 to 280 in a29bd9c
Improper handling of the error may lead to a deadlock by forgetting to unlock the mutex.