X-Git-Url: https://git.josue.xyz/?a=blobdiff_plain;f=.config%2Fcoc%2Fextensions%2Fcoc-go-data%2Ftools%2Fpkg%2Fmod%2Fgolang.org%2Fx%2Ftools%40v0.0.0-20201028153306-37f0764111ff%2Finternal%2Ffakenet%2Fconn.go;fp=.config%2Fcoc%2Fextensions%2Fcoc-go-data%2Ftools%2Fpkg%2Fmod%2Fgolang.org%2Fx%2Ftools%40v0.0.0-20201028153306-37f0764111ff%2Finternal%2Ffakenet%2Fconn.go;h=0000000000000000000000000000000000000000;hb=3ddadb3c98564791f0ac36cb39771d844a63dc91;hp=c9cdaf27a7b9f4215f1c615253e54fca160f226e;hpb=5f797af6612ed10887189b47a1efc2f915586e59;p=dotfiles%2F.git

diff --git a/.config/coc/extensions/coc-go-data/tools/pkg/mod/golang.org/x/tools@v0.0.0-20201028153306-37f0764111ff/internal/fakenet/conn.go b/.config/coc/extensions/coc-go-data/tools/pkg/mod/golang.org/x/tools@v0.0.0-20201028153306-37f0764111ff/internal/fakenet/conn.go
deleted file mode 100644
index c9cdaf27..00000000
--- a/.config/coc/extensions/coc-go-data/tools/pkg/mod/golang.org/x/tools@v0.0.0-20201028153306-37f0764111ff/internal/fakenet/conn.go
+++ /dev/null
@@ -1,129 +0,0 @@
-// Copyright 2018 The Go Authors. All rights reserved.
-// Use of this source code is governed by a BSD-style
-// license that can be found in the LICENSE file.
-
-package fakenet
-
-import (
-	"io"
-	"net"
-	"sync"
-	"time"
-)
-
-// NewConn returns a net.Conn built on top of the supplied reader and writer.
-// It decouples the read and write on the conn from the underlying stream
-// to enable Close to abort ones that are in progress.
-// It's primary use is to fake a network connection from stdin and stdout.
-func NewConn(name string, in io.ReadCloser, out io.WriteCloser) net.Conn {
-	c := &fakeConn{
-		name:   name,
-		reader: newFeeder(in.Read),
-		writer: newFeeder(out.Write),
-		in:     in,
-		out:    out,
-	}
-	go c.reader.run()
-	go c.writer.run()
-	return c
-}
-
-type fakeConn struct {
-	name   string
-	reader *connFeeder
-	writer *connFeeder
-	in     io.ReadCloser
-	out    io.WriteCloser
-}
-
-type fakeAddr string
-
-// connFeeder serializes calls to the source function (io.Reader.Read or
-// io.Writer.Write) by delegating them to a channel. This also allows calls to
-// be intercepted when the connection is closed, and cancelled early if the
-// connection is closed while the calls are still outstanding.
-type connFeeder struct {
-	source func([]byte) (int, error)
-	input  chan []byte
-	result chan feedResult
-	mu     sync.Mutex
-	closed bool
-	done   chan struct{}
-}
-
-type feedResult struct {
-	n   int
-	err error
-}
-
-func (c *fakeConn) Close() error {
-	c.reader.close()
-	c.writer.close()
-	c.in.Close()
-	c.out.Close()
-	return nil
-}
-
-func (c *fakeConn) Read(b []byte) (n int, err error)   { return c.reader.do(b) }
-func (c *fakeConn) Write(b []byte) (n int, err error)  { return c.writer.do(b) }
-func (c *fakeConn) LocalAddr() net.Addr                { return fakeAddr(c.name) }
-func (c *fakeConn) RemoteAddr() net.Addr               { return fakeAddr(c.name) }
-func (c *fakeConn) SetDeadline(t time.Time) error      { return nil }
-func (c *fakeConn) SetReadDeadline(t time.Time) error  { return nil }
-func (c *fakeConn) SetWriteDeadline(t time.Time) error { return nil }
-func (a fakeAddr) Network() string                     { return "fake" }
-func (a fakeAddr) String() string                      { return string(a) }
-
-func newFeeder(source func([]byte) (int, error)) *connFeeder {
-	return &connFeeder{
-		source: source,
-		input:  make(chan []byte),
-		result: make(chan feedResult),
-		done:   make(chan struct{}),
-	}
-}
-
-func (f *connFeeder) close() {
-	f.mu.Lock()
-	if !f.closed {
-		f.closed = true
-		close(f.done)
-	}
-	f.mu.Unlock()
-}
-
-func (f *connFeeder) do(b []byte) (n int, err error) {
-	// send the request to the worker
-	select {
-	case f.input <- b:
-	case <-f.done:
-		return 0, io.EOF
-	}
-	// get the result from the worker
-	select {
-	case r := <-f.result:
-		return r.n, r.err
-	case <-f.done:
-		return 0, io.EOF
-	}
-}
-
-func (f *connFeeder) run() {
-	var b []byte
-	for {
-		// wait for an input request
-		select {
-		case b = <-f.input:
-		case <-f.done:
-			return
-		}
-		// invoke the underlying method
-		n, err := f.source(b)
-		// send the result back to the requester
-		select {
-		case f.result <- feedResult{n: n, err: err}:
-		case <-f.done:
-			return
-		}
-	}
-}