| 33 | } |
| 34 | |
| 35 | type server struct { |
| 36 | logger |
| 37 | id []byte |
| 38 | suite suites.Suite |
| 39 | secKey kyber.Scalar |
| 40 | pubKey kyber.Point |
| 41 | |
| 42 | addr net.IP |
| 43 | port string |
| 44 | listener net.Listener |
| 45 | |
| 46 | //client lookup |
| 47 | members discover.Membership |
| 48 | calling chan p2pRequest |
| 49 | replying chan p2pRequest |
| 50 | |
| 51 | addIncomingC chan *client |
| 52 | removeIncomingC chan []byte |
| 53 | addCallingC chan *client |
| 54 | removeCallingC chan []byte |
| 55 | incomingNum int |
| 56 | callingNum int |
| 57 | |
| 58 | //Msg |
| 59 | peersFeed chan P2PMessage |
| 60 | subscribeMsg chan *subscription |
| 61 | unscribeMsg chan string |
| 62 | |
| 63 | //Event |
| 64 | peersEvent chan discover.P2PEvent |
| 65 | subscribeEvent chan *subscription |
| 66 | unscribeEvent chan int |
| 67 | |
| 68 | ctx context.Context |
| 69 | cancel context.CancelFunc |
| 70 | } |
| 71 | |
| 72 | type subscription struct { |
| 73 | subID int |
nothing calls this directly
no outgoing calls
no test coverage detected