rawconn_test.go 1.1 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465
  1. // Copyright 2018 The Go Authors. All rights reserved.
  2. // Use of this source code is governed by a BSD-style
  3. // license that can be found in the LICENSE file.
  4. // Test use of raw connections.
  5. //go:build !plan9 && !js
  6. package os_test
  7. import (
  8. "os"
  9. "syscall"
  10. "testing"
  11. )
  12. func TestRawConnReadWrite(t *testing.T) {
  13. t.Parallel()
  14. r, w, err := os.Pipe()
  15. if err != nil {
  16. t.Fatal(err)
  17. }
  18. defer r.Close()
  19. defer w.Close()
  20. rconn, err := r.SyscallConn()
  21. if err != nil {
  22. t.Fatal(err)
  23. }
  24. wconn, err := w.SyscallConn()
  25. if err != nil {
  26. t.Fatal(err)
  27. }
  28. var operr error
  29. err = wconn.Write(func(s uintptr) bool {
  30. _, operr = syscall.Write(syscallDescriptor(s), []byte{'b'})
  31. return operr != syscall.EAGAIN
  32. })
  33. if err != nil {
  34. t.Fatal(err)
  35. }
  36. if operr != nil {
  37. t.Fatal(err)
  38. }
  39. var n int
  40. buf := make([]byte, 1)
  41. err = rconn.Read(func(s uintptr) bool {
  42. n, operr = syscall.Read(syscallDescriptor(s), buf)
  43. return operr != syscall.EAGAIN
  44. })
  45. if err != nil {
  46. t.Fatal(err)
  47. }
  48. if operr != nil {
  49. t.Fatal(operr)
  50. }
  51. if n != 1 {
  52. t.Errorf("read %d bytes, expected 1", n)
  53. }
  54. if buf[0] != 'b' {
  55. t.Errorf("read %q, expected %q", buf, "b")
  56. }
  57. }