dospin/servermanager.go
2017-01-27 18:06:27 -06:00

165 lines
3.8 KiB
Go

/*
Copyright 2016-2017 gtalent2@gmail.com
This Source Code Form is subject to the terms of the Mozilla Public
License, v. 2.0. If a copy of the MPL was not distributed with this
file, You can obtain one at http://mozilla.org/MPL/2.0/.
*/
package main
import (
"log"
"net"
"strconv"
"time"
)
const (
SERVERMANAGER_SPINUP = iota
SERVERMANAGER_SPINDOWN
SERVERMANAGER_STOP
)
type serverManagerEvent struct {
eventType int
tcpConn *net.TCPConn
}
type ServerHandler interface {
// Takes snapshot name, and returns the IP to connect to.
Spinup(name string) (string, error)
Spindown(name string) error
}
type ServerManager struct {
name string
ports []int
in chan serverManagerEvent
done chan interface{}
connStatus chan ConnStatus
lastKeepAliveTime time.Time
server ServerHandler
}
func NewServerManager(name string, server ServerHandler, settings Settings) *ServerManager {
sm := new(ServerManager)
sm.name = name
sm.ports = settings.Servers[name].Ports
sm.in = make(chan serverManagerEvent)
sm.done = make(chan interface{})
sm.server = server
sm.lastKeepAliveTime = time.Now()
return sm
}
/*
Serves channel requests.
*/
func (me *ServerManager) Serve() {
// TODO: see if server is currently up, and setup port forwarding if so
activityTimeout := time.Duration(5 * time.Minute)
ticker := time.NewTicker(activityTimeout)
// event loop
for running := true; running; {
select {
case status := <-me.connStatus:
if status.Status == CONN_ACTIVE {
me.lastKeepAliveTime = time.Now()
}
case action := <-me.in:
running = me.serveAction(action)
case <-ticker.C:
if time.Since(me.lastKeepAliveTime) > activityTimeout {
log.Println("ServerManager: Activity timeout for", me.name, " - killing server")
running = me.serveAction(serverManagerEvent{eventType: SERVERMANAGER_SPINDOWN})
}
}
}
ticker.Stop()
// notify done
me.done <- 42
}
/*
Sends the serve loop a spinup message.
*/
func (me *ServerManager) Spinup(c *net.TCPConn) {
me.in <- serverManagerEvent{eventType: SERVERMANAGER_SPINUP, tcpConn: c}
}
/*
Sends the serve loop a spindown message.
*/
func (me *ServerManager) Spindown() {
me.in <- serverManagerEvent{eventType: SERVERMANAGER_SPINDOWN}
}
/*
Sends the serve loop a quit message.
*/
func (me *ServerManager) Stop() {
me.in <- serverManagerEvent{eventType: SERVERMANAGER_STOP}
}
func (me *ServerManager) Done() {
<-me.done
}
func (me *ServerManager) setupListener(port int) {
portStr := strconv.Itoa(port)
addr, err := net.ResolveTCPAddr("tcp", "0.0.0.0:"+portStr)
if err != nil {
log.Print("Could not resolve port and listen address:", err)
return
}
// listen on port
go func() {
l, err := net.ListenTCP("tcp", addr)
if err != nil {
log.Print("Could not listen for TCP connection:", err)
} else {
for {
conn, err := l.AcceptTCP()
if err != nil {
log.Print("Could not accept TCP connection:", err)
} else { // connection accepted
// spinup machine
me.Spinup(conn)
}
}
}
}()
}
func (me *ServerManager) serveAction(event serverManagerEvent) bool {
running := true
switch event.eventType {
case SERVERMANAGER_SPINUP:
targetIp, err := me.server.Spinup(me.name)
me.lastKeepAliveTime = time.Now()
if err == nil {
log.Println("ServerManager: Got IP for", me.name+":", targetIp)
wanAddr := event.tcpConn.LocalAddr().String()
_, port, _ := net.SplitHostPort(wanAddr)
go portForward(event.tcpConn, targetIp, port, me.connStatus)
} else {
log.Println("ServerManager: Could not spin up "+me.name+":", err)
}
case SERVERMANAGER_SPINDOWN:
err := me.server.Spindown(me.name)
if err != nil {
log.Println("ServerManager: Could not spin down "+me.name+":", err)
}
case SERVERMANAGER_STOP:
running = false
}
return running
}