()
| 443 | } |
| 444 | |
| 445 | func (self *diff) send_data() error { |
| 446 | if self.data.sz > 0 { |
| 447 | if err := self.send_pending(); err != nil { |
| 448 | return err |
| 449 | } |
| 450 | self.written = true |
| 451 | data := self.buffer[self.data.pos : self.data.pos+self.data.sz] |
| 452 | var buf [5]byte |
| 453 | bin.PutUint32(buf[1:], uint32(len(data))) |
| 454 | buf[0] = byte(OpData) |
| 455 | if _, err := self.output.Write(buf[:]); err != nil { |
| 456 | return err |
| 457 | } |
| 458 | if _, err := self.output.Write(data); err != nil { |
| 459 | return err |
| 460 | } |
| 461 | self.data.pos += self.data.sz |
| 462 | self.data.sz = 0 |
| 463 | } |
| 464 | return nil |
| 465 | } |
| 466 | |
| 467 | func (self *diff) pump_till_op_written() error { |
| 468 | self.written = false |
no test coverage detected