Lint Fixes (#202)

* examples: fix dropped errors

* test: break from loop, not just select

* internal/core: remove unused dialing field from dialer

examples/context/context.go

@@ -89,6 +89,9 @@ func server(url string) {
 				die("can't create context on rep socket: %s", err)
 			}
 			msg, err = ctx.Recv()
+			if err != nil {
+				die("can't receive from context: %s", err)
+			}
 			fmt.Printf("Worker %d: Received request '%s'\n", id, string(msg))
 
 			// Sleep for a random amount of time to simulate "work"

examples/pipeline/pipeline.go

@@ -57,6 +57,9 @@ func node0(url string) {
 	for {
 		// Could also use sock.RecvMsg to get header
 		msg, err = sock.Recv()
+		if err != nil {
+			die("cannot receive from mangos Socket: %s", err.Error())
+		}
 		fmt.Printf("NODE0: RECEIVED \"%s\"\n", msg)
 
 		if string(msg) == "STOP" {

examples/reqrep/reqrep.go

@@ -60,6 +60,9 @@ func node0(url string) {
 	for {
 		// Could also use sock.RecvMsg to get header
 		msg, err = sock.Recv()
+		if err != nil {
+			die("cannot receive on rep socket: %s", err.Error())
+		}
 		if string(msg) == "DATE" { // no need to terminate
 			fmt.Println("NODE0: RECEIVED DATE REQUEST")
 			d := date()

internal/core/dialer.go

@@ -31,7 +31,6 @@ type dialer struct {
 	addr          string
 	closed        bool
 	active        bool
-	dialing       bool
 	asynch        bool
 	redialer      *time.Timer
 	reconnTime    time.Duration

test/common_test.go

@@ -549,14 +549,15 @@ func slowStart(_ *testing.T, cases []TestCase) bool {
 	}
 
 	timeout := time.After(time.Second * 5)
+Loop:
 	for numexit < needrdy {
 		select {
 		case <-timeout:
 			if !exitqclosed {
 				close(exitq)
 				exitqclosed = true
 			}
-			break
+			break Loop
 		case <-wakeq:
 			numexit++
 		}