}
func (cc *ClientConn) handleTransaction(transaction Transaction) error {
- requestNum := binary.BigEndian.Uint16(transaction.Type)
+ requestNum := binary.BigEndian.Uint16(transaction.Type[:])
if handler, ok := TransactionHandlers[requestNum]; ok {
for _, reqField := range handler.RequiredFields {
field := transaction.GetField(reqField.ID)
func (cc *ClientConn) NewReply(t *Transaction, fields ...Field) Transaction {
return Transaction{
IsReply: 0x01,
- Type: []byte{0x00, 0x00},
+ Type: [2]byte{0x00, 0x00},
ID: t.ID,
clientID: cc.ID,
- ErrorCode: []byte{0, 0, 0, 0},
+ ErrorCode: [4]byte{0, 0, 0, 0},
Fields: fields,
}
}
return Transaction{
clientID: cc.ID,
IsReply: 0x01,
- Type: []byte{0, 0},
+ Type: [2]byte{0, 0},
ID: t.ID,
- ErrorCode: []byte{0, 0, 0, 1},
+ ErrorCode: [4]byte{0, 0, 0, 1},
Fields: []Field{
NewField(FieldError, []byte(errMsg)),
},