Function SocketKey

examples/socketkey/socketkey.go:36–123

NOTE: Some lines are commented out for the sake of tests. * SocketKey is a streaming multi-threaded client->server transfer of secure data over a socket. */

(size int)

SocketKey is a streaming multi-threaded client->server transfer of secure data over a socket.
*/
func SocketKey(size int) {
	// Create a server to listen on.
	listener, err := net.Listen("tcp", "127.0.0.1:4128")
	if err != nil {
		memguard.SafePanic(err)
	}
	defer listener.Close()

	// Catch signals and close the listener before terminating safely.
	memguard.CatchSignal(func(s os.Signal) {
		fmt.Println("Received signal:", s.String())
		listener.Close()
	}, os.Interrupt, os.Kill)

	// Purge the session before returning.
	defer memguard.Purge()

	// Create a client to connect to our server.
	go func() {
		// Connect to our server
		addr, err := net.ResolveTCPAddr("tcp", "127.0.0.1:4128")
		if err != nil {
			memguard.SafePanic(err)
		}
		conn, err := net.DialTCP("tcp", nil, addr)
		if err != nil {
			memguard.SafePanic(err)
		}
		defer conn.Close()

		// Create a buffer filled with random bytes
		buf := memguard.NewBufferRandom(size)
		defer buf.Destroy()

		// Save a copy of the key for comparison later.
		data = make([]byte, buf.Size())
		copy(data, buf.Bytes())

		// fmt.Printf("Sending key: %#v\n", buf.Bytes())

		// Send the data to the server
		var total, written int
		for total = 0; total < size; total += written {
			written, err = conn.Write(buf.Bytes()[total:])
			if err != nil {
				memguard.SafePanic(err)
			}
		}
	}()

	// Accept connections from clients
	conn, err := listener.Accept()
	if err != nil {
		memguard.SafePanic(err)
	}

	// Read the data directly into a guarded memory region
	buf, err := memguard.NewBufferFromReader(conn, size)