Skip to content

gfa-server: Add support for Unix domain sockets #36

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
0xaf1f wants to merge 1 commit into
base: master
Choose a base branch
from
Open

gfa-server: Add support for Unix domain sockets #36

Changes from all commits
Commits
Show all changes
1 commit
Select commit
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
31 changes: 29 additions & 2 deletions gfa-server.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -2,12 +2,15 @@ package main

import (
"os"
"os/signal"
"fmt"
"unsafe"
"strconv"
"net"
"net/http"
"strings"
"regexp"
"syscall"
"time"
)

Expand Down Expand Up @@ -107,6 +110,7 @@ func getopt(args []string, ostr string) (int, string) {
************/

var gfa_server_port string = "8000";
var gfa_server_socket string = "";
var gfa_server_ver string = "r294";
var gfa_endpoint string = "/view";
var gfa_graphs map[string]*C.gfa_t;
Expand Down Expand Up @@ -254,9 +258,11 @@ func main() {

// parse command line options
for {
opt, arg := getopt(os.Args, "p:e:j:d:vm:");
opt, arg := getopt(os.Args, "p:s:e:j:d:vm:");
if opt == 'p' {
gfa_server_port = arg;
} else if opt == 's' {
gfa_server_socket = arg;
} else if opt == 'e' {
gfa_endpoint = arg;
} else if opt == 'j' {
Expand All @@ -276,6 +282,7 @@ func main() {
fmt.Fprintln(os.Stderr, "Usage: gfa-server [options] <graph1.gfa> [graph2.gfa [...]]");
fmt.Fprintln(os.Stderr, "Options:");
fmt.Fprintf(os.Stderr, " -p INT port number [%s or from $PORT env]\n", gfa_server_port);
fmt.Fprintf(os.Stderr, " -s STR path to Unix domain socket to use instead of a port\n");
fmt.Fprintf(os.Stderr, " -j DIR directory to gfa javascript files [%s]\n", gfa_js_dir);
fmt.Fprintf(os.Stderr, " -d DIR directory to HTML pages to be served at \"/\" []\n");
fmt.Fprintf(os.Stderr, " -e STR endpoint [%s]\n", gfa_endpoint);
Expand Down Expand Up @@ -311,5 +318,25 @@ func main() {
http.Handle("/", http.FileServer(http.Dir(gfa_html_dir)));
}
fmt.Fprintf(os.Stderr, "[%d] server started at %s\n", time.Now().UnixNano(), gfa_endpoint);
http.ListenAndServe(fmt.Sprintf(":%s", gfa_server_port), nil);

if gfa_server_socket != "" {
socket, err := net.Listen("unix", gfa_server_socket);
if err != nil {
fmt.Fprintf(os.Stderr, "[%d] could not create socket '%s'\n", time.Now().UnixNano(), gfa_server_socket);
os.Exit(1);
}

c := make(chan os.Signal, 1);
signal.Notify(c, os.Interrupt, syscall.SIGTERM);
go func() {
<-c;
os.Remove(gfa_server_socket);
os.Exit(1);
}()

http.Serve(socket, nil);

} else {
http.ListenAndServe(fmt.Sprintf(":%s", gfa_server_port), nil);
}
}