Skip to content

GitLab

Commit 63673133 authored by tavit ohanian's avatar tavit ohanian
Browse files
Options

reference basis

parents a2eccfb3 22bd2c38
Pipeline #517 failed with stages
      Hide whitespace changes
      Inline Side-by-side
      Showing with 434 additions and 1 deletion
      .github/workflows/automerge.yml 0 → 100644
      View file @ 63673133
      # File managed by web3-bot. DO NOT EDIT.
      # See https://github.com/protocol/.github/ for details.
      # Automatically merge pull requests opened by web3-bot, as soon as (and only if) all tests pass.
      # This reduces the friction associated with updating with our workflows.
      on: [ pull_request ]
      name: Automerge
      jobs:
      automerge-check:
      if: github.event.pull_request.user.login == 'web3-bot'
      runs-on: ubuntu-latest
      outputs:
      status: ${{ steps.should-automerge.outputs.status }}
      steps:
      - uses: actions/checkout@v2
      with:
      fetch-depth: 0
      - name: Check if we should automerge
      id: should-automerge
      run: |
      for commit in $(git rev-list --first-parent origin/${{ github.event.pull_request.base.ref }}..${{ github.event.pull_request.head.sha }}); do
      committer=$(git show --format=$'%ce' -s $commit)
      echo "Committer: $committer"
      if [[ "$committer" != "web3-bot@users.noreply.github.com" ]]; then
      echo "Commit $commit wasn't committed by web3-bot, but by $committer."
      echo "::set-output name=status::false"
      exit
      fi
      done
      echo "::set-output name=status::true"
      automerge:
      needs: automerge-check
      runs-on: ubuntu-latest
      if: ${{ needs.automerge-check.outputs.status == 'true' }}
      steps:
      - name: Wait on tests
      uses: lewagon/wait-on-check-action@bafe56a6863672c681c3cf671f5e10b20abf2eaa # v0.2
      with:
      ref: ${{ github.event.pull_request.head.sha }}
      repo-token: ${{ secrets.GITHUB_TOKEN }}
      wait-interval: 10
      running-workflow-name: 'automerge' # the name of this job
      - name: Merge PR
      uses: pascalgn/automerge-action@741c311a47881be9625932b0a0de1b0937aab1ae # v0.13.1
      env:
      GITHUB_TOKEN: "${{ secrets.GITHUB_TOKEN }}"
      MERGE_LABELS: ""
      MERGE_METHOD: "squash"
      MERGE_DELETE_BRANCH: true
      .github/workflows/go-check.yml 0 → 100644
      View file @ 63673133
      # File managed by web3-bot. DO NOT EDIT.
      # See https://github.com/protocol/.github/ for details.
      on: [push, pull_request]
      name: Go Checks
      jobs:
      unit:
      runs-on: ubuntu-latest
      name: All
      steps:
      - uses: actions/checkout@v2
      with:
      submodules: recursive
      - uses: actions/setup-go@v2
      with:
      go-version: "1.16.x"
      - name: Install staticcheck
      run: go install honnef.co/go/tools/cmd/staticcheck@434f5f3816b358fe468fa83dcba62d794e7fe04b # 2021.1 (v0.2.0)
      - name: Check that go.mod is tidy
      uses: protocol/multiple-go-modules@v1.0
      with:
      run: |
      go mod tidy
      if [[ -n $(git ls-files --other --exclude-standard --directory -- go.sum) ]]; then
      echo "go.sum was added by go mod tidy"
      exit 1
      fi
      git diff --exit-code -- go.sum go.mod
      - name: gofmt
      if: ${{ success() || failure() }} # run this step even if the previous one failed
      run: |
      out=$(gofmt -s -l .)
      if [[ -n "$out" ]]; then
      echo $out | awk '{print "::error file=" $0 ",line=0,col=0::File is not gofmt-ed."}'
      exit 1
      fi
      - name: go vet
      if: ${{ success() || failure() }} # run this step even if the previous one failed
      uses: protocol/multiple-go-modules@v1.0
      with:
      run: go vet ./...
      - name: staticcheck
      if: ${{ success() || failure() }} # run this step even if the previous one failed
      uses: protocol/multiple-go-modules@v1.0
      with:
      run: |
      set -o pipefail
      staticcheck ./... | sed -e 's@\(.*\)\.go@./\1.go@g'
      .github/workflows/go-test.yml 0 → 100644
      View file @ 63673133
      # File managed by web3-bot. DO NOT EDIT.
      # See https://github.com/protocol/.github/ for details.
      on: [push, pull_request]
      name: Go Test
      jobs:
      unit:
      strategy:
      fail-fast: false
      matrix:
      os: [ "ubuntu", "windows", "macos" ]
      go: [ "1.15.x", "1.16.x" ]
      runs-on: ${{ matrix.os }}-latest
      name: ${{ matrix.os}} (go ${{ matrix.go }})
      steps:
      - uses: actions/checkout@v2
      with:
      submodules: recursive
      - uses: actions/setup-go@v2
      with:
      go-version: ${{ matrix.go }}
      - name: Go information
      run: |
      go version
      go env
      - name: Run tests
      uses: protocol/multiple-go-modules@v1.0
      with:
      run: go test -v -coverprofile coverage.txt ./...
      - name: Run tests (32 bit)
      if: ${{ matrix.os != 'macos' }} # can't run 32 bit tests on OSX.
      uses: protocol/multiple-go-modules@v1.0
      env:
      GOARCH: 386
      with:
      run: go test -v ./...
      - name: Run tests with race detector
      if: ${{ matrix.os == 'ubuntu' }} # speed things up. Windows and OSX VMs are slow
      uses: protocol/multiple-go-modules@v1.0
      with:
      run: go test -v -race ./...
      - name: Upload coverage to Codecov
      uses: codecov/codecov-action@a1ed4b322b4b38cb846afb5a0ebfa17086917d27 # v1.5.0
      with:
      file: coverage.txt
      env_vars: OS=${{ matrix.os }}, GO=${{ matrix.go }}
      LICENSE 0 → 100644
      View file @ 63673133
      Copyright (c) 2013 Conformal Systems LLC.
      Permission to use, copy, modify, and distribute this software for any
      purpose with or without fee is hereby granted, provided that the above
      copyright notice and this permission notice appear in all copies.
      THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES
      WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF
      MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR
      ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
      WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN
      ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF
      OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
      \ No newline at end of file
      README.md
      View file @ 63673133
      # go-reuseport
      dms3 p2p go-reuseport
      \ No newline at end of file
      [![](https://img.shields.io/badge/made%20by-Protocol%20Labs-blue.svg?style=flat-square)](https://protocol.ai)
      [![](https://img.shields.io/badge/project-libp2p-yellow.svg?style=flat-square)](https://libp2p.io/)
      [![](https://img.shields.io/badge/freenode-%23libp2p-yellow.svg?style=flat-square)](https://webchat.freenode.net/?channels=%23libp2p)
      [![codecov](https://codecov.io/gh/libp2p/go-reuseport/branch/master/graph/badge.svg)](https://codecov.io/gh/libp2p/go-reuseport)
      [![Travis CI](https://travis-ci.org/libp2p/go-reuseport.svg?branch=master)](https://travis-ci.org/libp2p/go-reuseport)
      [![Discourse posts](https://img.shields.io/discourse/https/discuss.libp2p.io/posts.svg)](https://discuss.libp2p.io)
      **NOTE:** This package REQUIRES go >= 1.11.
      This package enables listening and dialing from _the same_ TCP or UDP port.
      This means that the following sockopts may be set:
      ```
      SO_REUSEADDR
      SO_REUSEPORT
      ```
      - godoc: https://godoc.org/github.com/libp2p/go-reuseport
      This is a simple package to help with address reuse. This is particularly
      important when attempting to do TCP NAT holepunching, which requires a process
      to both Listen and Dial on the same TCP port. This package provides some
      utilities around enabling this behaviour on various OS.
      ## Examples
      ```Go
      // listen on the same port. oh yeah.
      l1, _ := reuse.Listen("tcp", "127.0.0.1:1234")
      l2, _ := reuse.Listen("tcp", "127.0.0.1:1234")
      ```
      ```Go
      // dial from the same port. oh yeah.
      l1, _ := reuse.Listen("tcp", "127.0.0.1:1234")
      l2, _ := reuse.Listen("tcp", "127.0.0.1:1235")
      c, _ := reuse.Dial("tcp", "127.0.0.1:1234", "127.0.0.1:1235")
      ```
      **Note: cant dial self because tcp/ip stacks use 4-tuples to identify connections, and doing so would clash.**
      ## Tested
      Tested on `darwin`, `linux`, and `windows`.
      ---
      The last gx published version of this module was: 0.2.2: Qme8kdM7thoCqLqd7GYCRqipoZJS64rhJo5MBcTpyWfsL9
      addr.go 0 → 100644
      View file @ 63673133
      package reuseport
      import (
      "net"
      )
      func ResolveAddr(network, address string) (net.Addr, error) {
      switch network {
      default:
      return nil, net.UnknownNetworkError(network)
      case "ip", "ip4", "ip6":
      return net.ResolveIPAddr(network, address)
      case "tcp", "tcp4", "tcp6":
      return net.ResolveTCPAddr(network, address)
      case "udp", "udp4", "udp6":
      return net.ResolveUDPAddr(network, address)
      case "unix", "unixgram", "unixpacket":
      return net.ResolveUnixAddr(network, address)
      }
      }
      codecov.yml 0 → 100644
      View file @ 63673133
      coverage:
      range: "50...100"
      comment: off
      control_plan9.go 0 → 100644
      View file @ 63673133
      package reuseport
      import (
      "syscall"
      )
      func Control(network, address string, c syscall.RawConn) error {
      return nil
      }
      control_unix.go 0 → 100644
      View file @ 63673133
      // +build !plan9,!windows,!wasm
      package reuseport
      import (
      "syscall"
      "golang.org/x/sys/unix"
      )
      func Control(network, address string, c syscall.RawConn) error {
      var err error
      c.Control(func(fd uintptr) {
      err = unix.SetsockoptInt(int(fd), unix.SOL_SOCKET, unix.SO_REUSEADDR, 1)
      if err != nil {
      return
      }
      err = unix.SetsockoptInt(int(fd), unix.SOL_SOCKET, unix.SO_REUSEPORT, 1)
      if err != nil {
      return
      }
      })
      return err
      }
      control_wasm.go 0 → 100644
      View file @ 63673133
      // +build wasm
      package reuseport
      import (
      "syscall"
      )
      func Control(network, address string, c syscall.RawConn) error {
      return nil
      }
      control_windows.go 0 → 100644
      View file @ 63673133
      package reuseport
      import (
      "syscall"
      "golang.org/x/sys/windows"
      )
      func Control(network, address string, c syscall.RawConn) (err error) {
      return c.Control(func(fd uintptr) {
      err = windows.SetsockoptInt(windows.Handle(fd), windows.SOL_SOCKET, windows.SO_REUSEADDR, 1)
      })
      }
      go.mod 0 → 100644
      View file @ 63673133
      module github.com/libp2p/go-reuseport
      go 1.15
      require (
      github.com/pkg/errors v0.9.1
      github.com/stretchr/testify v1.5.1
      golang.org/x/sys v0.0.0-20190228124157-a34e9553db1e
      )
      interface.go 0 → 100644
      View file @ 63673133
      // Package reuseport provides Listen and Dial functions that set socket
      // options in order to be able to reuse ports. You should only use this
      // package if you know what SO_REUSEADDR and SO_REUSEPORT are.
      //
      // For example:
      //
      // // listen on the same port. oh yeah.
      // l1, _ := reuse.Listen("tcp", "127.0.0.1:1234")
      // l2, _ := reuse.Listen("tcp", "127.0.0.1:1234")
      //
      // // dial from the same port. oh yeah.
      // l1, _ := reuse.Listen("tcp", "127.0.0.1:1234")
      // l2, _ := reuse.Listen("tcp", "127.0.0.1:1235")
      // c, _ := reuse.Dial("tcp", "127.0.0.1:1234", "127.0.0.1:1235")
      //
      // Note: cant dial self because tcp/ip stacks use 4-tuples to identify connections,
      // and doing so would clash.
      package reuseport
      import (
      "context"
      "net"
      "github.com/pkg/errors"
      )
      // Available returns whether or not SO_REUSEPORT or equivalent behaviour is
      // available in the OS.
      func Available() bool {
      return true
      }
      var listenConfig = net.ListenConfig{
      Control: Control,
      }
      // Listen listens at the given network and address. see net.Listen
      // Returns a net.Listener created from a file discriptor for a socket
      // with SO_REUSEPORT and SO_REUSEADDR option set.
      func Listen(network, address string) (net.Listener, error) {
      return listenConfig.Listen(context.Background(), network, address)
      }
      // ListenPacket listens at the given network and address. see net.ListenPacket
      // Returns a net.Listener created from a file discriptor for a socket
      // with SO_REUSEPORT and SO_REUSEADDR option set.
      func ListenPacket(network, address string) (net.PacketConn, error) {
      return listenConfig.ListenPacket(context.Background(), network, address)
      }
      // Dial dials the given network and address. see net.Dialer.Dial
      // Returns a net.Conn created from a file descriptor for a socket
      // with SO_REUSEPORT and SO_REUSEADDR option set.
      func Dial(network, laddr, raddr string) (net.Conn, error) {
      nla, err := ResolveAddr(network, laddr)
      if err != nil {
      return nil, errors.Wrap(err, "resolving local addr")
      }
      d := net.Dialer{
      Control: Control,
      LocalAddr: nla,
      }
      return d.Dial(network, raddr)
      }
      reuse_test.go 0 → 100644
      View file @ 63673133
      package reuseport
      import (
      "context"
      "net"
      "strings"
      "testing"
      "github.com/pkg/errors"
      "github.com/stretchr/testify/assert"
      "github.com/stretchr/testify/require"
      )
      func testDialFromListeningPort(t *testing.T, network, host string) {
      lc := net.ListenConfig{
      Control: Control,
      }
      ctx := context.Background()
      ll, err := lc.Listen(ctx, network, host+":0")
      if err != nil && strings.Contains(err.Error(), "cannot assign requested address") {
      t.Skip(err)
      }
      require.NoError(t, err)
      rl, err := lc.Listen(ctx, network, host+":0")
      require.NoError(t, err)
      d := net.Dialer{
      LocalAddr: ll.Addr(),
      Control: Control,
      }
      c, err := d.Dial(network, rl.Addr().String())
      require.NoError(t, err)
      c.Close()
      }
      func TestDialFromListeningPort(t *testing.T) {
      testDialFromListeningPort(t, "tcp", "localhost")
      }
      func TestDialFromListeningPortTcp6(t *testing.T) {
      testDialFromListeningPort(t, "tcp6", "[::1]")
      }
      func TestListenPacketWildcardAddress(t *testing.T) {
      pc, err := ListenPacket("udp", ":0")
      require.NoError(t, err)
      pc.Close()
      }
      func TestErrorWhenDialUnresolvable(t *testing.T) {
      _, err := Dial("asd", "127.0.0.1:1234", "127.0.0.1:1234")
      assert.IsType(t, net.UnknownNetworkError(""), errors.Cause(err))
      _, err = Dial("tcp", "a.b.c.d:1234", "a.b.c.d:1235")
      assert.Error(t, err)
      }
      Markdown is supported
      0% or .
      You are about to add 0 people to the discussion. Proceed with caution.
      Finish editing this message first!
      Please register or to comment