Merge branch 'fix_idle_times'

Conflicts:
	README.md

Author: miketheprogrammer

CHANGELOG.md

@@ -1,3 +1,7 @@
+NOV132014 (Version 0.3.3):
+  Improved CPU Usage - More battery power for all.
+  Added basic chat client/server example.
+
 NOV132014 (Version 0.3.2):
 
 Important Changes:

README.md

@@ -1,7 +1,6 @@
 go-thrust
 =========
-[![Gitter](https://badges.gitter.im/Join Chat.svg)](https://gitter.im/miketheprogrammer/go-thrust?utm_source=badge&utm_medium=badge&utm_campaign=pr-badge&utm_content=badge)
-Current Go-Thrust Version 0.3.2
+Current Go-Thrust Version 0.3.3
 Current Thrust Version 0.7.5
 
 ![Logo Thrust](http://i.imgur.com/DwFKI0J.png)
@@ -11,6 +10,7 @@ Chat with us
 ==================
 irc: #breach on freenode - this is the entire breach/thrust community
 gitter.im : https://gitter.im/miketheprogrammer/go-thrust - focused on go-thrust.
+[![Gitter](https://badges.gitter.im/Join Chat.svg)](https://gitter.im/miketheprogrammer/go-thrust?utm_source=badge&utm_medium=badge&utm_campaign=pr-badge&utm_content=badge)
 
 
 Quick Start, see it in action

common/versions.go

@@ -2,5 +2,5 @@ package common
 
 const (
 	THRUST_VERSION    = "0.7.5"
-	THRUST_GO_VERSION = "0.3.2"
+	THRUST_GO_VERSION = "0.3.3"
 )

connection/connection.go

@@ -5,9 +5,7 @@ import (
 	"encoding/json"
 	"fmt"
 	"io"
-	"os"
 	"strings"
-	"time"
 
 	"github.com/miketheprogrammer/go-thrust/commands"
 	. "github.com/miketheprogrammer/go-thrust/common"
@@ -70,42 +68,28 @@ func GetCommunicationChannels() (*Out, *In) {
 
 func Reader(out *Out, in *In) {
 
-	r := bufio.NewReader(Stdout)
+	reader := bufio.NewReader(Stdout)
 	defer Stdin.Close()
 	for {
-		select {
-		case quit := <-in.Quit:
-			Log.Errorf("Connection Reader Received a Quit message from somewhere ... Exiting Now")
-			os.Exit(quit)
-		default:
-			//a := <-in.Quit
-			//fmt.Println(a)
-			line, err := r.ReadString(byte('\n'))
-			if err != nil {
-				fmt.Println(err)
-				panic(err)
-			}
-
-			Log.Debug("SOCKET::Line", line)
-			if !strings.Contains(line, SOCKET_BOUNDARY) {
-				response := commands.CommandResponse{}
-				json.Unmarshal([]byte(line), &response)
-				//Log.Debug(response)
-				out.CommandResponses <- response
-			}
-
+		line, err := reader.ReadString(byte('\n'))
+		if err != nil {
+			fmt.Println(err)
+			panic(err)
 		}
-		time.Sleep(time.Microsecond * 100)
 
+		Log.Debug("SOCKET::Line", line)
+		if !strings.Contains(line, SOCKET_BOUNDARY) {
+			response := commands.CommandResponse{}
+			json.Unmarshal([]byte(line), &response)
+			out.CommandResponses <- response
+		}
 	}
-
 }
 
 func Writer(out *Out, in *In) {
 	for {
 		select {
 		case response := <-in.CommandResponses:
-			Log.Info("CommandResponse Marhshaling.")
 			cmd, _ := json.Marshal(response)
 			Log.Debug("Writing RESPONSE", string(cmd), "\n", SOCKET_BOUNDARY)
 
@@ -126,7 +110,5 @@ func Writer(out *Out, in *In) {
 			Stdin.Write([]byte(SOCKET_BOUNDARY))
 			Stdin.Write([]byte("\n"))
 		}
-
-		time.Sleep(time.Microsecond * 100)
 	}
 }

dispatcher/dispatcher.go

@@ -1,8 +1,6 @@
 package dispatcher
 
 import (
-	"time"
-
 	"github.com/miketheprogrammer/go-thrust/commands"
 	"github.com/miketheprogrammer/go-thrust/connection"
 )
@@ -34,22 +32,16 @@ need this loop to be the blocking loop.
 For Instance, in a HTTP Server setting, you might want to run this as a
 goroutine and then let the servers blocking handler keep the process open.
 As long as there are commands in the channel, this loop will dispatch as fast
-as possible, when all commands are exhausted this loop will run on iterations
-of 10 microseconds optimistically.
+as possible
 */
 func RunLoop() {
 	outChannels := connection.GetOutputChannels()
 	for {
 		Run(outChannels)
-		time.Sleep(time.Microsecond * 10)
 	}
 }
 
 func Run(outChannels *connection.Out) {
-	select {
-	case response := <-outChannels.CommandResponses:
-		Dispatch(response)
-	default:
-		break
-	}
+	response := <-outChannels.CommandResponses
+	Dispatch(response)
 }

menu/menu.go

@@ -224,7 +224,7 @@ func (menu *Menu) SendThread() {
 			if menu.IsTreeStable() {
 				menu.Sync.TreeStableChan <- true
 			}
-			time.Sleep(time.Microsecond * 10)
+			time.Sleep(time.Microsecond * 100)
 		}
 	}()
 
@@ -272,7 +272,6 @@ func (menu *Menu) SendThread() {
 				menu.Sync.TreeStableQueue = CremoveItemAt(menu.Sync.TreeStableQueue, 0)
 				menu.Call(command)
 			}
-			time.Sleep(time.Microsecond * 10)
 		}
 	}()
 }