protocol

package

v0.0.9 Latest Latest Go to latest Published: Apr 25, 2023 License: Apache-2.0 Imports: 18 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/CESSProject/p2p-go

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
func CalcFileSHA256(f *os.File) (string, error)
func CalcPathSHA256(fpath string) (string, error)
func CalcSHA256(data []byte) (string, error)
type FileProtocol
- func NewFileProtocol(node *core.Node) *FileProtocol
- func (e *FileProtocol) FileReq(peerId peer.ID, filetype uint32, fpath string) error
type IdleProtocol
- func NewIdleProtocol(node *core.Node) *IdleProtocol
- func (e *IdleProtocol) IdleReq(peerId peer.ID, peerindex uint64, sign []byte) error
type MusProtocol
- func NewMusProtocol(node *core.Node) *MusProtocol
- func (e *MusProtocol) MusReq(peerId peer.ID, filename, customdata string, blocknum int64) (uint32, error)
type Protocol
- func NewProtocol(node *core.Node) *Protocol
type ReadFileProtocol
- func NewReadFileProtocol(node *core.Node) *ReadFileProtocol
- func (e *ReadFileProtocol) ReadFileAction(id peer.ID, roothash, datahash, path string, size int64) error
type TagProtocol
- func NewTagProtocol(node *core.Node) *TagProtocol
- func (e *TagProtocol) TagReq(peerId peer.ID, filename, customdata string, blocknum int64) (uint32, error)
type WriteFileProtocol
- func NewWriteFileProtocol(node *core.Node) *WriteFileProtocol
- func (e *WriteFileProtocol) WriteFileAction(id peer.ID, roothash, path string) error

Constants ¶

View Source

const (
	FileType_ServiceFile uint32 = iota
	FileType_IdleFile
	FileType_TagFile
	FileType_MusFile
	FileType_UsFile
	FileType_NamesFile
)

View Source

const FILE_PROTOCOL = "/file/req/1"

View Source

const FileDirectionry = "file"

View Source

const FileProtocolBufSize = 2 * 1024 * 1024

View Source

const FileProtocolMsgBuf = 2 * 1024 * 1024

View Source

const IDLE_PROTOCOL = "/idle/req/1"

View Source

const IdleDirectionry = "idle"

View Source

const IdleProtocolMsgBuf = 1024

View Source

const MUS_PROTOCOL = "/mus/req/1"

View Source

const MaxCustomDataLength = 255

View Source

const MaxFileNameLength = 255

View Source

const MusDirectionry = "mu"

View Source

const NamesDirectionry = "name"

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 TAG_PROTOCOL = "/tag/req/1"

View Source

const TagDirectionry = "tag"

View Source

const TagProtocolMsgBuf = 1024

View Source

const TmpDirectionry = "tmp"

View Source

const UsDirectionry = "us"

Variables ¶

View Source

var (
	FileNameLengthErr = fmt.Errorf("filename length exceeds %d", MaxFileNameLength)
	FileNameEmptyErr  = fmt.Errorf("filename is empty")

	CustomDataLengthErr = fmt.Errorf("custom data length exceeds %d", MaxCustomDataLength)
)

Functions ¶

func CalcFileSHA256 ¶

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

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

func CalcPathSHA256 ¶

func CalcPathSHA256(fpath string) (string, error)

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

func CalcSHA256 ¶

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

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

Types ¶

type FileProtocol ¶ added in v0.0.9

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

func NewFileProtocol ¶ added in v0.0.9

func NewFileProtocol(node *core.Node) *FileProtocol

func (*FileProtocol) FileReq ¶ added in v0.0.9

func (e *FileProtocol) FileReq(peerId peer.ID, filetype uint32, fpath string) error

type IdleProtocol ¶ added in v0.0.9

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

func NewIdleProtocol ¶ added in v0.0.9

func NewIdleProtocol(node *core.Node) *IdleProtocol

func (*IdleProtocol) IdleReq ¶ added in v0.0.9

func (e *IdleProtocol) IdleReq(peerId peer.ID, peerindex uint64, sign []byte) error

type MusProtocol ¶ added in v0.0.9

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

func NewMusProtocol ¶ added in v0.0.9

func NewMusProtocol(node *core.Node) *MusProtocol

func (*MusProtocol) MusReq ¶ added in v0.0.9

func (e *MusProtocol) MusReq(peerId peer.ID, filename, customdata string, blocknum int64) (uint32, error)

type Protocol ¶

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

func NewProtocol ¶

func NewProtocol(node *core.Node) *Protocol

type ReadFileProtocol ¶

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

func NewReadFileProtocol ¶

func NewReadFileProtocol(node *core.Node) *ReadFileProtocol

func (*ReadFileProtocol) ReadFileAction ¶

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

type TagProtocol ¶ added in v0.0.9

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

func NewTagProtocol ¶ added in v0.0.9

func NewTagProtocol(node *core.Node) *TagProtocol

func (*TagProtocol) TagReq ¶ added in v0.0.9

func (e *TagProtocol) TagReq(peerId peer.ID, filename, customdata string, blocknum int64) (uint32, error)

type WriteFileProtocol ¶

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

func NewWriteFileProtocol ¶

func NewWriteFileProtocol(node *core.Node) *WriteFileProtocol

func (*WriteFileProtocol) WriteFileAction ¶

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

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL