transfersMU sync.Mutex
transfers map[int]map[[4]byte]*FileTransfer
- Agreed bool
logger *zap.SugaredLogger
}
// notifyOthers sends transaction t to other clients connected to the server
func (cc *ClientConn) notifyOthers(t Transaction) (trans []Transaction) {
for _, c := range sortedClients(cc.Server.Clients) {
- if c.ID != cc.ID && c.Agreed {
+ if c.ID != cc.ID {
t.clientID = c.ID
trans = append(trans, t)
}
reply := Transaction{
Flags: 0x00,
IsReply: 0x01,
- Type: t.Type,
+ Type: []byte{0x00, 0x00},
ID: t.ID,
clientID: cc.ID,
ErrorCode: []byte{0, 0, 0, 0},