networking

package

v0.1.0 Latest Latest Go to latest Published: Jul 27, 2025 License: Apache-2.0 Imports: 9 Imported by: 0

Details

This section is empty.

This section is empty.

func DialTCP(comm *P2PComm, dst int, address string)

func EstablishConnections(wg *sync.WaitGroup, comm *P2PComm, partyID int, totalParties int)

func ListenTCP(comm *P2PComm, port string, src int)

type Communicator interface {
	Send(dst int, msg []byte) (int, error)
	Recv(src int) ([]byte, int, error)
	Close() error
}

type P2PComm struct {
	Socks map[int]*net.Conn
	Rank  int
	// contains filtered or unexported fields
}

func (comm *P2PComm) Close() error

func (comm *P2PComm) GetSock(key int) *net.Conn

func (comm *P2PComm) Recv(reader *bufio.Reader, src int) ([]byte, int, error)

func (comm *P2PComm) RecvBytesMap(reader *bufio.Reader, src int) map[int][]byte

func (comm *P2PComm) RecvBytesSlice(reader *bufio.Reader, src int) [][]byte

func (comm *P2PComm) RecvBytesSliceMap(reader *bufio.Reader, src int) map[int][][]byte

func (comm *P2PComm) RecvMatrix(reader *bufio.Reader, src int, length int) structs.Matrix[ring.Poly]

func (comm *P2PComm) RecvVector(reader *bufio.Reader, src int, length int) structs.Vector[ring.Poly]

func (comm *P2PComm) SendBytes(writer *bufio.Writer, dst int, msg []byte) (int, error)

func (comm *P2PComm) SendBytesMap(writer *bufio.Writer, dst int, data map[int][]byte)

func (comm *P2PComm) SendBytesSlice(writer *bufio.Writer, dst int, data [][]byte)

func (comm *P2PComm) SendBytesSliceMap(writer *bufio.Writer, dst int, data map[int][][]byte)

func (comm *P2PComm) SendMatrix(writer *bufio.Writer, dst int, msg structs.Matrix[ring.Poly])

func (comm *P2PComm) SendVector(writer *bufio.Writer, dst int, msg structs.Vector[ring.Poly])

func (comm *P2PComm) SetSock(key int, conn *net.Conn)