mynewt-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ccoll...@apache.org
Subject [2/3] incubator-mynewt-newtmgr git commit: nmxact ble_dual ex: send more commands.
Date Wed, 12 Apr 2017 18:23:27 GMT
nmxact ble_dual ex: send more commands.


Project: http://git-wip-us.apache.org/repos/asf/incubator-mynewt-newtmgr/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-mynewt-newtmgr/commit/9e80738e
Tree: http://git-wip-us.apache.org/repos/asf/incubator-mynewt-newtmgr/tree/9e80738e
Diff: http://git-wip-us.apache.org/repos/asf/incubator-mynewt-newtmgr/diff/9e80738e

Branch: refs/heads/master
Commit: 9e80738e6f3296469b8469f10f846312767d9922
Parents: 34c5eb8
Author: Christopher Collins <ccollins@apache.org>
Authored: Wed Apr 12 11:21:09 2017 -0700
Committer: Christopher Collins <ccollins@apache.org>
Committed: Wed Apr 12 11:21:09 2017 -0700

----------------------------------------------------------------------
 nmxact/example/ble_dual/ble_dual.go | 113 +++++++++++++++++++++++++++----
 1 file changed, 99 insertions(+), 14 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-mynewt-newtmgr/blob/9e80738e/nmxact/example/ble_dual/ble_dual.go
----------------------------------------------------------------------
diff --git a/nmxact/example/ble_dual/ble_dual.go b/nmxact/example/ble_dual/ble_dual.go
index e4615fe..b1e2a67 100644
--- a/nmxact/example/ble_dual/ble_dual.go
+++ b/nmxact/example/ble_dual/ble_dual.go
@@ -59,6 +59,91 @@ func configExitHandler(x xport.Xport) {
 	}()
 }
 
+func sendEcho(s sesn.Sesn) error {
+	c := xact.NewEchoCmd()
+	c.Payload = fmt.Sprintf("hello %p", s)
+
+	res, err := c.Run(s)
+	if err != nil {
+		fmt.Fprintf(os.Stderr, "error executing echo command: %s\n",
+			err.Error())
+		return err
+	}
+
+	if res.Status() != 0 {
+		fmt.Printf("Peer responded negatively to echo command; status=%d\n",
+			res.Status())
+	}
+
+	eres := res.(*xact.EchoResult)
+	fmt.Printf("Peer echoed back: %s\n", eres.Rsp.Payload)
+
+	return nil
+}
+
+func sendImageState(s sesn.Sesn) error {
+	c := xact.NewImageStateReadCmd()
+
+	res, err := c.Run(s)
+	if err != nil {
+		fmt.Fprintf(os.Stderr, "error executing image state command: %s\n",
+			err.Error())
+		return err
+	}
+
+	if res.Status() != 0 {
+		fmt.Printf("Peer responded negatively to image state command; "+
+			"status=%d\n", res.Status())
+	}
+
+	eres := res.(*xact.ImageStateReadResult)
+	fmt.Printf("Peer responded with image state: %#v\n", eres.Rsp)
+
+	return nil
+}
+
+func sendMpStat(s sesn.Sesn) error {
+	c := xact.NewMempoolStatCmd()
+
+	res, err := c.Run(s)
+	if err != nil {
+		fmt.Fprintf(os.Stderr, "error executing mempool stat command: %s\n",
+			err.Error())
+		return err
+	}
+
+	if res.Status() != 0 {
+		fmt.Printf("Peer responded negatively to mempool stat command; "+
+			"status=%d\n", res.Status())
+	}
+
+	eres := res.(*xact.MempoolStatResult)
+	fmt.Printf("Peer responded with mempool stat: %#v\n", eres.Rsp)
+
+	return nil
+}
+
+func sendTaskStat(s sesn.Sesn) error {
+	c := xact.NewTaskStatCmd()
+
+	res, err := c.Run(s)
+	if err != nil {
+		fmt.Fprintf(os.Stderr, "error executing task stat command: %s\n",
+			err.Error())
+		return err
+	}
+
+	if res.Status() != 0 {
+		fmt.Printf("Peer responded negatively to task stat command; "+
+			"status=%d\n", res.Status())
+	}
+
+	eres := res.(*xact.TaskStatResult)
+	fmt.Printf("Peer responded with task stat: %#v\n", eres.Rsp)
+
+	return nil
+}
+
 func sendOne(s sesn.Sesn) {
 	// Repeatedly:
 	//     * Connect to peer if unconnected.
@@ -74,27 +159,27 @@ func sendOne(s sesn.Sesn) {
 			return
 		}
 	}
+	defer s.Close()
 
 	// Send an echo command to the peer.
-	c := xact.NewEchoCmd()
-	c.Payload = fmt.Sprintf("hello %p", s)
-
-	res, err := c.Run(s)
-	if err != nil {
-		fmt.Fprintf(os.Stderr, "error executing echo command: %s\n",
-			err.Error())
+	if err := sendEcho(s); err != nil {
 		return
 	}
 
-	if res.Status() != 0 {
-		fmt.Printf("Peer responded negatively to echo command; status=%d\n",
-			res.Status())
+	// Image list
+	if err := sendImageState(s); err != nil {
+		return
 	}
 
-	eres := res.(*xact.EchoResult)
-	fmt.Printf("Peer echoed back: %s\n", eres.Rsp.Payload)
+	// MP stat
+	if err := sendMpStat(s); err != nil {
+		return
+	}
 
-	s.Close()
+	// Task stat
+	if err := sendTaskStat(s); err != nil {
+		return
+	}
 }
 
 func main() {
@@ -124,7 +209,7 @@ func main() {
 	configExitHandler(x)
 
 	peerNames := []string{
-		"ccollins",
+		"ccollins1",
 		"ccollins2",
 		"ccollins3",
 	}


Mime
View raw message