(data []byte, q *QueryEvent)
| 435 | } |
| 436 | |
| 437 | func (p *QueryEventParser) parseUpdatedDbNames(data []byte, q *QueryEvent) ( |
| 438 | []byte, |
| 439 | error) { |
| 440 | |
| 441 | if len(data) == 0 { |
| 442 | return data, errors.New("Not enough data") |
| 443 | } |
| 444 | |
| 445 | q.numUpdatedDbs = new(uint8) |
| 446 | data, err := readLittleEndian(data, q.numUpdatedDbs) |
| 447 | if err != nil { |
| 448 | return data, err |
| 449 | } |
| 450 | |
| 451 | if *q.numUpdatedDbs < MaxDbsInEventMts { |
| 452 | q.updatedDbNames = make([][]byte, *q.numUpdatedDbs, *q.numUpdatedDbs) |
| 453 | for i := uint8(0); i < *q.numUpdatedDbs; i++ { |
| 454 | idx := bytes.IndexByte(data, byte(0)) |
| 455 | if idx > -1 { |
| 456 | q.updatedDbNames[i] = data[:idx] |
| 457 | data = data[idx+1:] |
| 458 | } else { |
| 459 | return data, errors.New("Not enough data") |
| 460 | } |
| 461 | } |
| 462 | } |
| 463 | return data, nil |
| 464 | } |
| 465 | |
| 466 | func (p *QueryEventParser) parseMircoseconds(data []byte, q *QueryEvent) ( |
| 467 | []byte, |
no test coverage detected