diff options
| author | Max Romanov <max.romanov@nginx.com> | 2017-07-12 20:32:18 +0300 |
|---|---|---|
| committer | Max Romanov <max.romanov@nginx.com> | 2017-07-12 20:32:18 +0300 |
| commit | a97a5e8a0b7a921905994bae101d4f74f5a8aaa4 (patch) | |
| tree | 922a2e6fed3630439b56d99b57c7452ee259f617 /src/nginext/nginext.go | |
| parent | 51bbdd33382eee7da34ff0ed7d0df51ab2345786 (diff) | |
| download | unit-a97a5e8a0b7a921905994bae101d4f74f5a8aaa4.tar.gz unit-a97a5e8a0b7a921905994bae101d4f74f5a8aaa4.tar.bz2 | |
Go: worker initialization. READY message to master.
Diffstat (limited to 'src/nginext/nginext.go')
| -rw-r--r-- | src/nginext/nginext.go | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/nginext/nginext.go b/src/nginext/nginext.go index 2bde80a6..de0218e8 100644 --- a/src/nginext/nginext.go +++ b/src/nginext/nginext.go @@ -84,7 +84,6 @@ func ListenAndServe() { var read_port *port go_ports_env := os.Getenv("NXT_GO_PORTS") - fmt.Printf("NXT_GO_PORTS = %s\n", go_ports_env) ports := strings.Split(go_ports_env, ";") pid := os.Getpid() @@ -95,7 +94,6 @@ func ListenAndServe() { } attrs := strings.Split(port_str, ",") - fmt.Printf("Port = %q\n", attrs) var attrsN [5]int var err error @@ -119,6 +117,8 @@ func ListenAndServe() { } if read_port != nil { + C.nxt_go_ready() + for !nxt_go_quit { read_port.read() } |