protocol

package

v0.0.7 Latest Latest Go to latest Published: Apr 12, 2023 License: Apache-2.0 Imports: 16 Imported by: 0

Details

View Source

const FileDirectionry = "file"

View Source

const FileProtocolBufSize = 2 * 1024 * 1024

View Source

const P2PReadReqRespTime = time.Duration(time.Second * 15)

View Source

const P2PResponseFailed uint32 = 400

View Source

const P2PResponseFinish uint32 = 210

View Source

const P2PResponseOK uint32 = 200

View Source

const P2PWriteReqRespTime = time.Duration(time.Second * 15)

View Source

const TmpDirectionry = "tmp"

This section is empty.

func CalcFileSHA256(f *os.File) (string, error)

CalcFileSHA256 is used to calculate the sha256 value of the file type.

func CalcPathSHA256(fpath string) (string, error)

CalcPathSHA256 is used to calculate the sha256 value of a file with a given path.

func CalcSHA256(data []byte) (string, error)

CalcSHA256 is used to calculate the sha256 value of the data.

type Protocol struct {
	*core.Node
	*WriteFileProtocol
	*ReadFileProtocol
}

func NewProtocol(node *core.Node) *Protocol

type ReadFileProtocol struct {
	// contains filtered or unexported fields
}

func NewReadFileProtocol(node *core.Node) *ReadFileProtocol

func (e *ReadFileProtocol) ReadFileAction(id peer.ID, roothash, datahash, path string, size int64) error

type WriteFileProtocol struct {
	// contains filtered or unexported fields
}

func NewWriteFileProtocol(node *core.Node) *WriteFileProtocol

func (e *WriteFileProtocol) WriteFileAction(id peer.ID, roothash, path string) error