Skip to content
Snippets Groups Projects
Commit db6e6d1f authored by lunfardo314's avatar lunfardo314
Browse files

cleanup

parent c665b163
No related branches found
No related tags found
No related merge requests found
......@@ -7,7 +7,7 @@ import (
"sync"
"time"
waspconn2 "github.com/iotaledger/goshimmer/dapps/waspconn/packages/waspconn"
"github.com/iotaledger/goshimmer/dapps/waspconn/packages/waspconn"
"github.com/iotaledger/goshimmer/packages/binary/messagelayer/payload"
)
......@@ -155,25 +155,25 @@ func IncomingChunk(data []byte, maxChunkSize uint16) ([]byte, error) {
func (c *msgChunk) encode() []byte {
var buf bytes.Buffer
_ = waspconn2.WriteUint32(&buf, c.msgId)
_ = waspconn2.WriteByte(&buf, c.numChunks)
_ = waspconn2.WriteByte(&buf, c.chunkSeqNum)
_ = waspconn2.WriteBytes16(&buf, c.data)
_ = waspconn.WriteUint32(&buf, c.msgId)
_ = waspconn.WriteByte(&buf, c.numChunks)
_ = waspconn.WriteByte(&buf, c.chunkSeqNum)
_ = waspconn.WriteBytes16(&buf, c.data)
return buf.Bytes()
}
func (c *msgChunk) decode(data []byte, maxChunkSizeWithoutHeader uint16) error {
rdr := bytes.NewReader(data)
if err := waspconn2.ReadUint32(rdr, &c.msgId); err != nil {
if err := waspconn.ReadUint32(rdr, &c.msgId); err != nil {
return err
}
if err := waspconn2.ReadByte(rdr, &c.numChunks); err != nil {
if err := waspconn.ReadByte(rdr, &c.numChunks); err != nil {
return err
}
if err := waspconn2.ReadByte(rdr, &c.chunkSeqNum); err != nil {
if err := waspconn.ReadByte(rdr, &c.chunkSeqNum); err != nil {
return err
}
if data, err := waspconn2.ReadBytes16(rdr); err != nil {
if data, err := waspconn.ReadBytes16(rdr); err != nil {
return err
} else {
c.data = data
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment