diff options
| author | Bryan Newbold <bnewbold@robocracy.org> | 2018-01-22 02:31:00 -0800 |
|---|---|---|
| committer | Bryan Newbold <bnewbold@robocracy.org> | 2018-01-22 02:31:00 -0800 |
| commit | 72f65d94b5eb95ef4fc1632adea1cfe4022281dd (patch) | |
| tree | a77ca4b558408027e79347f75d2b1f4ce79c8d85 /src/peer.rs | |
| parent | ef8ea37d26716869cd4572152ffedc047700f747 (diff) | |
| download | geniza-72f65d94b5eb95ef4fc1632adea1cfe4022281dd.tar.gz geniza-72f65d94b5eb95ef4fc1632adea1cfe4022281dd.zip | |
WIP on synchronizer state machine
Diffstat (limited to 'src/peer.rs')
| -rw-r--r-- | src/peer.rs | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/src/peer.rs b/src/peer.rs index c6f8c6d..0f04a40 100644 --- a/src/peer.rs +++ b/src/peer.rs @@ -13,15 +13,15 @@ use chan; /// Wraps a low-level DatConnection in a thread (or two). Contains very little context about /// itself. pub struct DatPeerThread { - handle: u64, + pub handle: u64, feeds: Vec<(u8, Key)>, outbound_chan: chan::Sender<(DatNetMessage, u8)>, } pub struct PeerMsg { - peer_handle: u64, - feed_index: u8, - msg: DatNetMessage, + pub peer_handle: u64, + pub feed_index: u8, + pub msg: DatNetMessage, } /// This is what the "receive" loop does: simply blocking reads on the TCP socket, passing any |