Advertisement
Guest User

Untitled

a guest
Mar 21st, 2018
78
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 0.66 KB | None | 0 0
  1. func main() {
  2. flag.Usage = usage
  3. flag.Parse()
  4. if *ffHelp {
  5. flag.Usage()
  6. os.Exit(0)
  7. }
  8.  
  9. clients := map[int]string{0: "127.0.0.1:65533", 1: "127.0.0.1:65534"}
  10.  
  11. // Network Layer
  12. netLayer := NL.NewNetworkLayer("tcp", clients[*client])
  13. go netLayer.Listen()
  14. fmt.Printf("Listening on %s\n", clients[*client])
  15.  
  16. client := Client{ClientID: "42", ClientSeq: 0, netLayer: &netLayer}
  17.  
  18. next := make(chan struct{})
  19.  
  20. go func() {
  21. for {
  22. client.bankMsg()
  23. <-next
  24. }
  25. }()
  26.  
  27. for {
  28. rsp := <-netLayer.RspChan
  29. var val bank.TransactionResult
  30. json.Unmarshal(rsp.Msg.Data, &val)
  31. fmt.Printf("\nValueType: %v\n", val)
  32. next <- struct{}{}
  33. }
  34. }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement