p2pserver

package
v0.12.4 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 22, 2024 License: Apache-2.0 Imports: 25 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	PP_LOG_ALL      = false
	PP_LOG_READ     = true
	PP_LOG_WRITE    = true
	PP_LOG_INBOUND  = true
	PP_LOG_OUTBOUND = true

	MIN_RECONNECT_INTERVAL_THRESHOLD = 60  // seconds
	MAX_RECONNECT_INTERVAL_THRESHOLD = 600 // seconds
	RECONNECT_INTERVAL_MULTIPLIER    = 2
)

Variables

This section is empty.

Functions

func CreateNewContextPacketId 

func CreateNewContextPacketId(ctx context.Context) (int64, context.Context)

CreateNewContextPacketId used for downloading / uploading speed tracking

Types

type P2pServer 

type P2pServer struct {

	// SPMaintenanceMap stores records of SpUnderMaintenance, K - SpP2pAddress, V - lastReconnectRecord
	SPMaintenanceMap *utils.AutoCleanMap
	// contains filtered or unexported fields
}

func GetP2pServer 

func GetP2pServer(ctx context.Context) *P2pServer

func (*P2pServer) AddConnConntextKey 

func (p *P2pServer) AddConnConntextKey(key interface{})

func (*P2pServer) BuildBadVersionMsg added in v0.12.0 

func (p *P2pServer) BuildBadVersionMsg(version uint16, cmd uint8, minAppVer uint16) []byte

func (*P2pServer) CanConnectToSp added in v0.12.1 

func (p *P2pServer) CanConnectToSp(p2pAddress string) bool

func (*P2pServer) CleanUpConnMap 

func (p *P2pServer) CleanUpConnMap(fileHash string)

func (*P2pServer) ClearBufferedSpConns 

func (p *P2pServer) ClearBufferedSpConns()

func (*P2pServer) ConfirmOptSP 

func (p *P2pServer) ConfirmOptSP(ctx context.Context, spNetworkAddr string)

ConfirmOptSP connect if there is a detected optimal SP node.

func (*P2pServer) ConnectToSP 

func (p *P2pServer) ConnectToSP(ctx context.Context) (newConnection bool, err error)

ConnectToSP checks if there is a connection to an SP node. If there isn't, it attempts to create one with a random SP node.

func (*P2pServer) DeleteConnFromCache 

func (p *P2pServer) DeleteConnFromCache(key string)

DeleteConnFromCache access function for member cachedConnMap

func (*P2pServer) GetBufferedSpConns 

func (p *P2pServer) GetBufferedSpConns() []*cf.ClientConn

func (*P2pServer) GetClientConn 

func (p *P2pServer) GetClientConn(networkAddr string) (*cf.ClientConn, bool)

func (*P2pServer) GetConnectionName 

func (p *P2pServer) GetConnectionName(conn core.WriteCloser) string

func (*P2pServer) GetP2PAddress added in v0.10.0 

func (p *P2pServer) GetP2PAddress() fwtypes.P2PAddress

func (*P2pServer) GetP2PPublicKey added in v0.10.0 

func (p *P2pServer) GetP2PPublicKey() fwcryptotypes.PubKey

func (*P2pServer) GetP2pServer 

func (p *P2pServer) GetP2pServer() *core.Server

func (*P2pServer) GetPPInfo added in v0.10.0 

func (p *P2pServer) GetPPInfo() *protos.PPBaseInfo

func (*P2pServer) GetSpConn 

func (p *P2pServer) GetSpConn() *cf.ClientConn

func (*P2pServer) GetSpName 

func (p *P2pServer) GetSpName() string

func (*P2pServer) Init added in v0.10.0 

func (p *P2pServer) Init() error

func (*P2pServer) LoadConnFromCache 

func (p *P2pServer) LoadConnFromCache(key string) (*cf.ClientConn, bool)

LoadConnFromCache access function for member cachedConnMap

func (*P2pServer) LoadRequestInfo added in v0.10.0 

func (p *P2pServer) LoadRequestInfo(reqId int64, rspMsgType uint8) (uint8, bool)

func (*P2pServer) NewClientToAlternativeSp 

func (p *P2pServer) NewClientToAlternativeSp(ctx context.Context, server string) (*cf.ClientConn, error)

func (*P2pServer) NewClientToMainSp 

func (p *P2pServer) NewClientToMainSp(ctx context.Context, server string) error

func (*P2pServer) NewClientToPp 

func (p *P2pServer) NewClientToPp(ctx context.Context, server string, heartbeat bool) (*cf.ClientConn, error)

func (*P2pServer) RangeCachedConn 

func (p *P2pServer) RangeCachedConn(prefix string, rf func(k, v interface{}) bool)

func (*P2pServer) ReadOfflineChan 

func (p *P2pServer) ReadOfflineChan() chan *offline

func (*P2pServer) RecordSpMaintenance 

func (p *P2pServer) RecordSpMaintenance(spP2pAddress string, recordTime time.Time) bool

RecordSpMaintenance return boolean flag of switching to new SP

func (*P2pServer) SendMessage 

func (p *P2pServer) SendMessage(ctx context.Context, conn core.WriteCloser, pb proto.Message, cmd header.MsgType) error

func (*P2pServer) SendMessageByCachedConn 

func (p *P2pServer) SendMessageByCachedConn(ctx context.Context, key string, netAddr string, pb proto.Message, cmd header.MsgType, fn core.WriteHookFunc) error

func (*P2pServer) SendMessageToSPServer 

func (p *P2pServer) SendMessageToSPServer(ctx context.Context, pb proto.Message, cmd header.MsgType)

func (*P2pServer) SetOptionFunctions added in v0.12.0 

func (p *P2pServer) SetOptionFunctions(write func(context.Context, *msg.RelayMsgBuf), read func(*msg.RelayMsgBuf),
	handle func(context.Context, *msg.RelayMsgBuf))

func (*P2pServer) SetPPServer 

func (p *P2pServer) SetPPServer(pp *core.Server)

func (*P2pServer) SignP2pMessage added in v0.10.0 

func (p *P2pServer) SignP2pMessage(signMsg []byte) ([]byte, error)

func (*P2pServer) SpConnValid 

func (p *P2pServer) SpConnValid() bool

func (*P2pServer) Start 

func (p *P2pServer) Start(ctx context.Context)

func (*P2pServer) StartListenServer 

func (p *P2pServer) StartListenServer(ctx context.Context, port string)

func (*P2pServer) Stop 

func (p *P2pServer) Stop()

func (*P2pServer) StoreBufferedSpConn 

func (p *P2pServer) StoreBufferedSpConn(spConn *cf.ClientConn)

func (*P2pServer) StoreConnToCache 

func (p *P2pServer) StoreConnToCache(key string, conn *cf.ClientConn)

StoreConnToCache access function for member cachedConnMap

func (*P2pServer) StoreRequestInfo added in v0.10.0 

func (p *P2pServer) StoreRequestInfo(reqId int64, reqMsgType uint8)

func (*P2pServer) TransferSendMessageToPPServ 

func (p *P2pServer) TransferSendMessageToPPServ(ctx context.Context, addr string, msgBuf *msg.RelayMsgBuf) error

func (*P2pServer) TransferSendMessageToSPServer 

func (p *P2pServer) TransferSendMessageToSPServer(ctx context.Context, message *msg.RelayMsgBuf)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.