Skip to content
This repository has been archived by the owner on Jun 20, 2024. It is now read-only.

Remove proxy status.sock #2960

Merged
merged 4 commits into from
May 15, 2017
Merged
Show file tree
Hide file tree
Changes from 2 commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
6 changes: 4 additions & 2 deletions prog/weaver/main.go
Original file line number Diff line number Diff line change
Expand Up @@ -258,17 +258,18 @@ func main() {

var waitReady common.WaitGroup

var proxy *weaveproxy.Proxy
var err error
if proxyConfig.Enabled {
// Start Weave Proxy:
proxy, err := weaveproxy.NewProxy(*proxyConfig)
proxy, err = weaveproxy.NewProxy(*proxyConfig)
if err != nil {
Log.Fatalf("Could not start proxy: %s", err)
}
defer proxy.Stop()
listeners := proxy.Listen()
proxy.AttachExistingContainers()
go proxy.Serve(listeners, waitReady.Add())
go proxy.ListenAndServeStatus("/home/weave/status.sock")
}

if pktdebug {
Expand Down Expand Up @@ -441,6 +442,7 @@ func main() {
HandleHTTP(muxRouter, version, router, allocator, defaultSubnet, ns, dnsserver, &waitReady)
HandleHTTPPeer(muxRouter, allocator, discoveryEndpoint, token, name.String())
muxRouter.Methods("GET").Path("/metrics").Handler(metricsHandler(router, allocator, ns, dnsserver))
muxRouter.Methods("GET").Path("/proxyaddrs").HandlerFunc(proxy.StatusHTTP)

This comment was marked as abuse.

This comment was marked as abuse.

This comment was marked as abuse.

http.Handle("/", common.LoggingHTTPHandler(muxRouter))
Log.Println("Listening for HTTP control messages on", httpAddr)
go listenAndServeHTTP(httpAddr, nil)
Expand Down
11 changes: 0 additions & 11 deletions proxy/proxy.go
Original file line number Diff line number Diff line change
Expand Up @@ -310,17 +310,6 @@ func (proxy *Proxy) Serve(listeners []net.Listener, ready func()) {
}
}

func (proxy *Proxy) ListenAndServeStatus(socket string) {
listener, err := weavenet.ListenUnixSocket(socket)
if err != nil {
Log.Fatalf("ListenAndServeStatus failed: %s", err)
}
handler := http.HandlerFunc(proxy.StatusHTTP)
if err := (&http.Server{Handler: handler}).Serve(listener); err != nil {
Log.Fatalf("ListenAndServeStatus failed: %s", err)
}
}

func (proxy *Proxy) StatusHTTP(w http.ResponseWriter, r *http.Request) {
for _, addr := range proxy.normalisedAddrs {
fmt.Fprintln(w, addr)
Expand Down
18 changes: 2 additions & 16 deletions weave
Original file line number Diff line number Diff line change
Expand Up @@ -661,19 +661,6 @@ http_call() {
return $retval
}

http_call_unix() {
container="$1"
socket="$2"
http_verb="$3"
url="$4"
shift 4
# NB: requires curl >= 7.40
output=$(docker exec $container curl -s -S -X $http_verb --unix-socket $socket "$@" http:$url) || return 1
# in some docker versions, `docker exec` does not fail when the executed command fails
[ -n "$output" ] || return 1
echo $output
}

call_weave() {
TMPERR=/tmp/call_weave_err_$$
retval=0
Expand Down Expand Up @@ -1166,10 +1153,9 @@ proxy_args() {
}

proxy_addrs() {
if addr="$(http_call_unix $CONTAINER_NAME status.sock GET /status 2>/dev/null)" ; then
echo "$addr" | sed "s/0.0.0.0/$PROXY_HOST/g"
if addr="$(call_weave GET /proxyaddrs)" ; then
echo "$addr" | sed "s/0.0.0.0/$PROXY_HOST/g" | tr '\n' ' '
else
echo "$CONTAINER_NAME container is not present. Have you launched it?" >&2
return 1
fi
}
Expand Down