Function Example

pkg/flipcall/flipcall_example_test.go:24–113

()

)

func Example() {
	const (
		reqPrefix     = "request "
		respPrefix    = "response "
		count         = 3
		maxMessageLen = len(respPrefix) + 1 // 1 digit
	)

	pwa, err := NewPacketWindowAllocator()
	if err != nil {
		panic(err)
	}
	defer pwa.Destroy()
	pwd, err := pwa.Allocate(PacketWindowLengthForDataCap(uint32(maxMessageLen)))
	if err != nil {
		panic(err)
	}
	var clientEP Endpoint
	if err := clientEP.Init(ClientSide, pwd); err != nil {
		panic(err)
	}
	defer clientEP.Destroy()
	var serverEP Endpoint
	if err := serverEP.Init(ServerSide, pwd); err != nil {
		panic(err)
	}
	defer serverEP.Destroy()

	var serverRun sync.WaitGroup
	serverRun.Add(1)
	go func() {
		defer serverRun.Done()
		i := 0
		var buf bytes.Buffer
		// wait for first request
		n, err := serverEP.RecvFirst()
		if err != nil {
			return
		}
		for {
			// read request
			buf.Reset()
			buf.Write(serverEP.Data()[:n])
			fmt.Println(buf.String())
			// write response
			buf.Reset()
			fmt.Fprintf(&buf, "%s%d", respPrefix, i)
			copy(serverEP.Data(), buf.Bytes())
			// send response and wait for next request
			n, err = serverEP.SendRecv(uint32(buf.Len()))
			if err != nil {
				return
			}
			i++
		}
	}()
	defer func() {
		serverEP.Shutdown()