utils

Documentation

Index

• Variables
• func BoolToInt64(b bool) int64
• func DialHTTPWithTLS(network, address string, client_idx int, acceptCerts []tls.Certificate) (*rpc.Client, error)
• func GetUtime() uint64
• func ListenAndServe(server *rpc.Server, address string)
• func ListenAndServeTLS(server *rpc.Server, address string, keyIdx int, acceptCerts []tls.Certificate, ...)
• func NextPowerOfTwo(val int) int
• func PrintTime(tag string)
• func RandInt(mod *big.Int) *big.Int
• func RandPerm(input []int) []int
• func RunForever(f func(), d time.Duration)
• func StartBlockProfiling(filename string)
• func StartMemProfiling(filename string)
• func StartProfiling(filename string)
• func StopProfiling()
• type BufPRGReader
  • func NewBufPRG(prg *PRGReader) *BufPRGReader
  • func (b *BufPRGReader) RandInt(mod *big.Int) *big.Int
• type DebugConn
  • func NewDebugConn(c net.Conn, tag string) *DebugConn
  • func (d *DebugConn) Close() error
  • func (d *DebugConn) Debug()
  • func (d *DebugConn) Read(p []byte) (int, error)
  • func (d *DebugConn) Write(p []byte) (int, error)
• type PRGKey
  • func RandomPRGKey() *PRGKey
• type PRGReader
  • func NewPRG(key *PRGKey) *PRGReader
  • func RandomPRG() *PRGReader
  • func (s *PRGReader) Read(p []byte) (int, error)

Variables

var LeaderCertificate tls.Certificate

var One *big.Int

var ServerBoxPrivateKeys []*[32]byte

var ServerBoxPublicKeys []*[32]byte

var ServerCertificates []tls.Certificate

var Zero *big.Int

Functions

func BoolToInt64

func BoolToInt64(b bool) int64

func DialHTTPWithTLS

func DialHTTPWithTLS(network, address string,
	client_idx int, acceptCerts []tls.Certificate) (*rpc.Client, error)

func GetUtime

func GetUtime() uint64

func ListenAndServe

func ListenAndServe(server *rpc.Server, address string)

For running RPC over TCP.

func ListenAndServeTLS

func ListenAndServeTLS(server *rpc.Server, address string,
	keyIdx int, acceptCerts []tls.Certificate, debugNet bool)

For running RPC over TLS.

func NextPowerOfTwo

func NextPowerOfTwo(val int) int

func PrintTime

func PrintTime(tag string)

func RandInt

func RandInt(mod *big.Int) *big.Int

Produce a random integer in Z_p where mod is the value p.

func RandPerm

func RandPerm(input []int) []int

Generate a random permutation of the ints specified in input.

func RunForever

func RunForever(f func(), d time.Duration)

func StartBlockProfiling

func StartBlockProfiling(filename string)

func StartMemProfiling

func StartMemProfiling(filename string)

func StartProfiling

func StartProfiling(filename string)

func StopProfiling

func StopProfiling()

Types

type BufPRGReader

type BufPRGReader struct {
	Key PRGKey
	// contains filtered or unexported fields
}

func NewBufPRG

func NewBufPRG(prg *PRGReader) *BufPRGReader

func (*BufPRGReader) RandInt

func (b *BufPRGReader) RandInt(mod *big.Int) *big.Int

type DebugConn

type DebugConn struct {
	io.ReadWriteCloser
	// contains filtered or unexported fields
}

func NewDebugConn

func NewDebugConn(c net.Conn, tag string) *DebugConn

func (*DebugConn) Close

func (d *DebugConn) Close() error

func (*DebugConn) Debug

func (d *DebugConn) Debug()

func (*DebugConn) Read

func (d *DebugConn) Read(p []byte) (int, error)

func (*DebugConn) Write

func (d *DebugConn) Write(p []byte) (int, error)

type PRGKey

type PRGKey [aes.BlockSize]byte

func RandomPRGKey

func RandomPRGKey() *PRGKey

type PRGReader

type PRGReader struct {
	Key PRGKey
	// contains filtered or unexported fields
}

We use the AES-CTR to generate pseudo-random numbers using a stream cipher. Go's native rand.Reader is extremely slow because it makes tons of system calls to generate a small number of pseudo-random bytes.

We pay the overhead of using a sync.Mutex to synchronize calls to AES-CTR, but this is relatively cheap.

func NewPRG

func NewPRG(key *PRGKey) *PRGReader

func RandomPRG

func RandomPRG() *PRGReader

func (*PRGReader) Read

func (s *PRGReader) Read(p []byte) (int, error)