(c net.Conn)
| 349 | } |
| 350 | |
| 351 | func (p *BlockCachePacket) WriteToConn(c net.Conn) (err error) { |
| 352 | header, err := Buffers.Get(PacketHeaderSize) |
| 353 | if err != nil { |
| 354 | header = make([]byte, PacketHeaderSize) |
| 355 | } |
| 356 | defer Buffers.Put(header) |
| 357 | c.SetWriteDeadline(time.Now().Add(proto.WriteDeadlineTime * time.Second)) |
| 358 | p.MarshalHeader(header) |
| 359 | if _, err = c.Write(header); err == nil { |
| 360 | if p.Data != nil { |
| 361 | _, err = c.Write(p.Data[:p.Size]) |
| 362 | } |
| 363 | } |
| 364 | return |
| 365 | } |
| 366 | |
| 367 | func (p *BlockCachePacket) ReadFromConn(c net.Conn, timeoutSec int) (err error) { |
| 368 | if timeoutSec != proto.NoReadDeadlineTime { |
no test coverage detected