diff --git a/src/runtime/connector.rs b/src/runtime/connector.rs index 88d5b2607eb9e17283d4a8fdd8b33118e3b93b2f..5a10a83706fdca6bb462cc2d8b0ec2dea08a846f 100644 --- a/src/runtime/connector.rs +++ b/src/runtime/connector.rs @@ -113,16 +113,16 @@ impl Connector { Connector::Connected(connected) => connected, _ => return Err(NotConnected), }; - let (ekey, native_polarity) = + let (port, native_polarity) = *connected.native_interface.get(native_port_index).ok_or(IndexOutOfBounds)?; if native_polarity != Putter { return Err(WrongPolarity); } let sync_batch = connected.sync_batches.iter_mut().last().expect("no sync batch!"); - if sync_batch.puts.contains_key(&ekey) { + if sync_batch.puts.contains_key(&port) { return Err(DuplicateOperation); } - sync_batch.puts.insert(ekey, payload); + sync_batch.puts.insert(port, payload); Ok(()) } @@ -132,16 +132,16 @@ impl Connector { Connector::Connected(connected) => connected, _ => return Err(NotConnected), }; - let (ekey, native_polarity) = + let (port, native_polarity) = *connected.native_interface.get(native_port_index).ok_or(IndexOutOfBounds)?; if native_polarity != Getter { return Err(WrongPolarity); } let sync_batch = connected.sync_batches.iter_mut().last().expect("no sync batch!"); - if sync_batch.gets.contains(&ekey) { + if sync_batch.gets.contains(&port) { return Err(DuplicateOperation); } - sync_batch.gets.insert(ekey); + sync_batch.gets.insert(port); Ok(()) } pub fn next_batch(&mut self) -> Result {