11642: Don't reuse completed jobs where output or log is null or not readable by...

[arvados.git] / services / ws / main.go

diff --git a/services/ws/main.go b/services/ws/main.go
index 9eee8130af9d9b4b8fe831aa48865f5abd64808f..b2b86705cc1b40cef16edd0060fc13977e41e17d 100644 (file)
--- a/services/ws/main.go
+++ b/services/ws/main.go
@@ -3,12 +3,9 @@ package main
 import (
        "flag"
        "fmt"
-       "net/http"
-       "time"
 
        "git.curoverse.com/arvados.git/sdk/go/config"
        "git.curoverse.com/arvados.git/sdk/go/ctxlog"
-       "github.com/coreos/go-systemd/daemon"
 )
 
 var logger = ctxlog.FromContext
@@ -39,31 +36,6 @@ func main() {
        }
 
        log.Info("started")
-       eventSource := &pgEventSource{
-               DataSource: cfg.Postgres.ConnectionString(),
-               QueueSize:  cfg.ServerEventQueue,
-       }
-       srv := &http.Server{
-               Addr:           cfg.Listen,
-               ReadTimeout:    time.Minute,
-               WriteTimeout:   time.Minute,
-               MaxHeaderBytes: 1 << 20,
-               Handler: &router{
-                       Config:         &cfg,
-                       eventSource:    eventSource,
-                       newPermChecker: func() permChecker { return newPermChecker(cfg.Client) },
-               },
-       }
-
-       go func() {
-               eventSource.Run()
-               log.Fatal("event source stopped")
-       }()
-
-       if _, err := daemon.SdNotify(false, "READY=1"); err != nil {
-               log.WithError(err).Warn("error notifying init daemon")
-       }
-
-       log.WithField("Listen", srv.Addr).Info("listening")
-       log.Fatal(srv.ListenAndServe())
+       srv := &server{wsConfig: &cfg}
+       log.Fatal(srv.Run())
 }