protocol

package

v0.0.11 Latest Latest Go to latest Published: Apr 28, 2023 License: Apache-2.0 Imports: 19 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 CustomDataTagProtocol
- func NewCustomDataTagProtocol(node *core.Node) *CustomDataTagProtocol
- func (e *CustomDataTagProtocol) TagReq(peerId peer.ID, filename, customdata string, blocknum int64) (uint32, error)
type FileProtocol
- func NewFileProtocol(node *core.Node) *FileProtocol
- func (e *FileProtocol) FileReq(peerId peer.ID, fileId string, filetype int32, fpath string) error
type IdleDataTagProtocol
- func NewIdleDataTagProtocol(node *core.Node) *IdleDataTagProtocol
- func (e *IdleDataTagProtocol) IdleReq(peerId peer.ID, filesize, blocknum, peerindex uint64, sign []byte) (uint32, error)
type MusProtocol
- func NewMusProtocol(node *core.Node) *MusProtocol
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 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 CustomDataTag_Protocol = "/kldr/cdtg/1"

View Source

const FILE_PROTOCOL = "/kldr/sft/1"

View Source

const FileDirectionry = "file"

View Source

const FileProtocolBufSize = 2 * 1024 * 1024

View Source

const FileProtocolMsgBuf = 16 * 1024 * 1024

View Source

const IdleDataTag_Protocol = "/kldr/idtg/1"

View Source

const IdleDirectionry = "idle"

View Source

const IdleProtocolMsgBuf = 1024

View Source

const MUS_PROTOCOL = "/kldr/vdf/1"

View Source

const MaxCustomDataLength = 255

View Source

const MaxFileNameLength = 255

View Source

const MusDirectionry = "mu"

View Source

const MusProtocolMsgBuf = 32

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 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 CustomDataTagProtocol ¶ added in v0.0.10

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

func NewCustomDataTagProtocol ¶ added in v0.0.10

func NewCustomDataTagProtocol(node *core.Node) *CustomDataTagProtocol

func (*CustomDataTagProtocol) TagReq ¶ added in v0.0.10

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

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, fileId string, filetype int32, fpath string) error

type IdleDataTagProtocol ¶ added in v0.0.10

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

func NewIdleDataTagProtocol ¶ added in v0.0.10

func NewIdleDataTagProtocol(node *core.Node) *IdleDataTagProtocol

func (*IdleDataTagProtocol) IdleReq ¶ added in v0.0.10

func (e *IdleDataTagProtocol) IdleReq(peerId peer.ID, filesize, blocknum, peerindex uint64, sign []byte) (uint32, 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

type Protocol ¶

type Protocol struct {
	*core.Node
	*WriteFileProtocol
	*ReadFileProtocol
	*CustomDataTagProtocol
	*IdleDataTagProtocol
	*MusProtocol
	*FileProtocol
}

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 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