X-Git-Url: http://git.pjr.cc/?p=goDBhammer.git;a=blobdiff_plain;f=src%2Fwebconnector.go;h=ee4271368166bfe451f6b216aced5f9981008be4;hp=a25b6406768ca507031c4190a26fa561c638c694;hb=27752c010de1e4cef47dc97efbdfb285bccbef01;hpb=16788bb4bfa235d1cd49311529ea4a687d703f96
diff --git a/src/webconnector.go b/src/webconnector.go
index a25b640..ee42713 100644
--- a/src/webconnector.go
+++ b/src/webconnector.go
@@ -26,121 +26,20 @@ func JSONResponder(c *http.Conn, req *http.Request)
{
//stat := <- cominstatus;
- j, _, _ := json.StringToJson("{\"somestring\":\"somevalue\"}");
+ if(req.Method == "GET") {
- io.WriteString(c, fmt.Sprintf("%s\n", json.JsonToString(j)));
-
- /*if ret {
- fmt.Printf("err was true\n");
- } else {
- fmt.Printf("err was false\n");
- }*/
-
- //fmt.Printf("errto %s\n", errto);
-
-}
-
-
-// hello world, the web server
-func ServerResponder(c *http.Conn, req *http.Request) {
- //comout <- 2;
- //comout <- 3;
- //comout <- 1;
- fmt.Printf("lk: %s %s %s\n", req.Method, req.RawURL, req.URL);
- if req.RawURL == "/" {
- mainPage(c, req);
- }
-
- if req.RawURL == "/confirm" {
- confirmPage(c, req);
- }
-
- if req.RawURL == "/begin" {
- beginPage(c, req);
- }
-
- //k := <- comin;
- //fmt.Printf("%d\n", k);
-}
-
-func beginPage(c *http.Conn, req *http.Request)
-{
-
- if req.Method != "GET" {
- http.Redirect(c, "/begin", 301);
- } else {
- header(c);
- io.WriteString(c, "
Starting hammer
");
- //dbhost := req.FormValue("dbhost");
- //dbuser := req.FormValue("dbuser");
- //dbpass := req.FormValue("dbpass");
- //dbname := req.FormValue("dbname");
- //nthreads := req.FormValue("nthreads");
- //dbmult := req.FormValue("dbmult");
- comout <- "begin:setup";
+ j, _, _ := json.StringToJson("{\"status\":1, \"complete\":90}");
- footer(c);
+ io.WriteString(c, fmt.Sprintf("%s\n", json.JsonToString(j)));
+ fmt.Printf("i got a get\n");
+ }
+ if(req.Method == "POST") {
+ fmt.Printf("i got a post...\n");
+ http.Redirect(c, "/", 301);
}
}
-func confirmPage(c *http.Conn, req *http.Request)
-{
- header(c);
- io.WriteString(c, "Confirm
");
- dbhost := req.FormValue("dbhost");
- dbuser := req.FormValue("dbuser");
- dbpass := req.FormValue("dbpass");
- dbname := req.FormValue("dbname");
- nthreads := req.FormValue("nthreads");
- dbmult := req.FormValue("dbmult");
- var dbtype string;
-
- io.WriteString(c, "You are trying to perform a benchmark with the following values:
");
- io.WriteString(c, "");
- io.WriteString(c, fmt.Sprintf("Host | %s |
", dbhost));
- io.WriteString(c, fmt.Sprintf("User | %s |
", dbuser));
- io.WriteString(c, fmt.Sprintf("Password | %s |
", dbpass));
- io.WriteString(c, fmt.Sprintf("Database | %s |
", dbname));
- io.WriteString(c, fmt.Sprintf("Data Multiplier | %s |
", dbmult));
- io.WriteString(c, fmt.Sprintf("Number of Threads | %s |
", nthreads));
- io.WriteString(c, "
");
- io.WriteString(c, "");
-
- dbtype = "mysql";
-
- footer(c);
- comout <- fmt.Sprintf("configure:%s:%s:%s:%s:%s:%s:%s", dbtype, dbhost, dbuser, dbpass, dbname, dbmult, nthreads);
-
-}
-
-func mainPage(c *http.Conn, req *http.Request)
-{
- header(c);
- io.WriteString(c, "goDBHammer
");
- io.WriteString(c, "Welcome to goDBHammer, the go based database benchmarking tool
");
- io.WriteString(c, "");
- fmt.Printf("%s\n", req.FormValue("dbhost"));
- footer(c);
-}
func header(c *http.Conn)
{
@@ -162,7 +61,7 @@ func main()
bc := benchcontroller.CreateController();
go benchcontroller.MainLoop(bc, comout, comin, cominstatus);
- http.Handle("/", http.FileServer("./web", "/web"));
+ http.Handle("/", http.FileServer("./web/", "/"));
http.Handle("/json", http.HandlerFunc(JSONResponder));
err := http.ListenAndServe(":22222", nil);
if err != nil {