remove BlockUntilReady because it was unused

bufferflow.go

@@ -2,7 +2,6 @@ package main
 
 type Bufferflow interface {
 	Init()
-	BlockUntilReady(cmd string, id string) (bool, bool) // implement this method
-	OnIncomingData(data string)                         // implement this method
-	Close()                                             // implement this method
+	OnIncomingData(data string) // implement this method
+	Close()                     // implement this method
 }

bufferflow_default.go

@@ -42,11 +42,6 @@ Loop:
 	close(b.input) // close the input channel at the end of the computation
 }
 
-func (b *BufferflowDefault) BlockUntilReady(cmd string, id string) (bool, bool) {
-	//log.Printf("BlockUntilReady() start\n")
-	return true, false
-}
-
 func (b *BufferflowDefault) OnIncomingData(data string) {
 	b.input <- data
 }

bufferflow_timed.go

@@ -57,11 +57,6 @@ Loop:
 	close(b.input)
 }
 
-func (b *BufferflowTimed) BlockUntilReady(cmd string, id string) (bool, bool) {
-	//log.Printf("BlockUntilReady() start\n")
-	return true, false
-}
-
 func (b *BufferflowTimed) OnIncomingData(data string) {
 	b.input <- data
 }

bufferflow_timedraw.go

@@ -58,11 +58,6 @@ Loop:
 	close(b.input)
 }
 
-func (b *BufferflowTimedRaw) BlockUntilReady(cmd string, id string) (bool, bool) {
-	//log.Printf("BlockUntilReady() start\n")
-	return true, false
-}
-
 func (b *BufferflowTimedRaw) OnIncomingData(data string) {
 	b.input <- data
 }

serialport.go

@@ -174,18 +174,10 @@ func (p *serport) writerBuffered() {
 	// sees something come in
 	for data := range p.sendBuffered {
 
-		// we want to block here if we are being asked to pause.
-		goodToGo, _ := p.bufferwatcher.BlockUntilReady(string(data), "")
-
-		if goodToGo == false {
-			log.Println("We got back from BlockUntilReady() but apparently we must cancel this cmd")
-			// since we won't get a buffer decrement in p.sendNoBuf, we must do it here
-			p.itemsInBuffer--
-		} else {
-			// send to the non-buffered serial port writer
-			//log.Println("About to send to p.sendNoBuf channel")
-			p.sendNoBuf <- []byte(data)
-		}
+		// send to the non-buffered serial port writer
+		//log.Println("About to send to p.sendNoBuf channel")
+		p.sendNoBuf <- []byte(data)
+
 	}
 	msgstr := "writerBuffered just got closed. make sure you make a new one. port:" + p.portConf.Name
 	log.Println(msgstr)
@@ -249,17 +241,9 @@ func (p *serport) writerRaw() {
 		}
 		log.Println(string(sDec))
 
-		// we want to block here if we are being asked to pause.
-		goodToGo, _ := p.bufferwatcher.BlockUntilReady(string(data), "")
+		// send to the non-buffered serial port writer
+		p.sendNoBuf <- sDec
 
-		if goodToGo == false {
-			log.Println("We got back from BlockUntilReady() but apparently we must cancel this cmd")
-			// since we won't get a buffer decrement in p.sendNoBuf, we must do it here
-			p.itemsInBuffer--
-		} else {
-			// send to the non-buffered serial port writer
-			p.sendNoBuf <- sDec
-		}
 	}
 	msgstr := "writerRaw just got closed. make sure you make a new one. port:" + p.portConf.Name
 	log.Println(msgstr)