Go: moving source files to the root of the project.

This patch includes packaging changes related to files move.

1 files changed, 0 insertions, 170 deletions

diff --git a/src/go/unit/port.go b/src/go/unit/port.go
deleted file mode 100644
index a68cae74..00000000
--- a/src/go/unit/port.go
+++ /dev/null
@@ -1,170 +0,0 @@
-/*
- * Copyright (C) Max Romanov
- * Copyright (C) NGINX, Inc.
- */
-
-package unit
-
-/*
-#include "nxt_cgo_lib.h"
-*/
-import "C"
-
-import (
-	"net"
-	"os"
-	"sync"
-	"unsafe"
-)
-
-type port_key struct {
-	pid int
-	id  int
-}
-
-type port struct {
-	key port_key
-	rcv *net.UnixConn
-	snd *net.UnixConn
-}
-
-type port_registry struct {
-	sync.RWMutex
-	m map[port_key]*port
-}
-
-var port_registry_ port_registry
-
-func find_port(key port_key) *port {
-	port_registry_.RLock()
-	res := port_registry_.m[key]
-	port_registry_.RUnlock()
-
-	return res
-}
-
-func add_port(p *port) {
-
-	port_registry_.Lock()
-	if port_registry_.m == nil {
-		port_registry_.m = make(map[port_key]*port)
-	}
-
-	port_registry_.m[p.key] = p
-
-	port_registry_.Unlock()
-}
-
-func (p *port) Close() {
-	if p.rcv != nil {
-		p.rcv.Close()
-	}
-
-	if p.snd != nil {
-		p.snd.Close()
-	}
-}
-
-func getUnixConn(fd int) *net.UnixConn {
-	if fd < 0 {
-		return nil
-	}
-
-	f := os.NewFile(uintptr(fd), "sock")
-	defer f.Close()
-
-	c, err := net.FileConn(f)
-	if err != nil {
-		nxt_go_warn("FileConn error %s", err)
-		return nil
-	}
-
-	uc, ok := c.(*net.UnixConn)
-	if !ok {
-		nxt_go_warn("Not a Unix-domain socket %d", fd)
-		return nil
-	}
-
-	return uc
-}
-
-//export nxt_go_add_port
-func nxt_go_add_port(pid C.int, id C.int, rcv C.int, snd C.int) {
-	p := &port{
-		key: port_key{
-			pid: int(pid),
-			id:  int(id),
-		},
-		rcv: getUnixConn(int(rcv)),
-		snd: getUnixConn(int(snd)),
-	}
-
-	add_port(p)
-}
-
-//export nxt_go_remove_port
-func nxt_go_remove_port(pid C.int, id C.int) {
-	key := port_key{
-		pid: int(pid),
-		id:  int(id),
-	}
-
-	port_registry_.Lock()
-	if port_registry_.m != nil {
-		delete(port_registry_.m, key)
-	}
-
-	port_registry_.Unlock()
-}
-
-//export nxt_go_port_send
-func nxt_go_port_send(pid C.int, id C.int, buf unsafe.Pointer, buf_size C.int,
-	oob unsafe.Pointer, oob_size C.int) C.ssize_t {
-
-	key := port_key{
-		pid: int(pid),
-		id:  int(id),
-	}
-
-	p := find_port(key)
-
-	if p == nil {
-		nxt_go_warn("port %d:%d not found", pid, id)
-		return 0
-	}
-
-	n, oobn, err := p.snd.WriteMsgUnix(GoBytes(buf, buf_size),
-		GoBytes(oob, oob_size), nil)
-
-	if err != nil {
-		nxt_go_warn("write result %d (%d), %s", n, oobn, err)
-	}
-
-	return C.ssize_t(n)
-}
-
-//export nxt_go_port_recv
-func nxt_go_port_recv(pid C.int, id C.int, buf unsafe.Pointer, buf_size C.int,
-	oob unsafe.Pointer, oob_size C.int) C.ssize_t {
-
-	key := port_key{
-		pid: int(pid),
-		id:  int(id),
-	}
-
-	p := find_port(key)
-
-	if p == nil {
-		nxt_go_warn("port %d:%d not found", pid, id)
-		return 0
-	}
-
-	n, oobn, _, _, err := p.rcv.ReadMsgUnix(GoBytes(buf, buf_size),
-		GoBytes(oob, oob_size))
-
-	if err != nil {
-		nxt_go_warn("read result %d (%d), %s", n, oobn, err)
-	}
-
-	return C.ssize_t(n)
-}