提交 3359db63 authored 作者: Serhij S's avatar Serhij S

no need to own in udp send

上级 1be35882
...@@ -65,7 +65,7 @@ impl Worker<Message, ()> for UdpOut { ...@@ -65,7 +65,7 @@ impl Worker<Message, ()> for UdpOut {
pressure: 1000.0, pressure: 1000.0,
set_at: u64::try_from(Monotonic::now().as_nanos()).unwrap(), set_at: u64::try_from(Monotonic::now().as_nanos()).unwrap(),
}; };
if let Err(e) = tx.send(data) { if let Err(e) = tx.send(&data) {
error!(worker=self.worker_name(), error=%e, "udp send error"); error!(worker=self.worker_name(), error=%e, "udp send error");
} }
if !context.is_online() { if !context.is_online() {
......
...@@ -87,7 +87,7 @@ where ...@@ -87,7 +87,7 @@ where
} }
/// Sends a value to the target address /// Sends a value to the target address
pub fn send(&mut self, value: T) -> Result<()> { pub fn send(&mut self, value: &T) -> Result<()> {
let mut buf = Cursor::new(&mut self.data_buf); let mut buf = Cursor::new(&mut self.data_buf);
value.write_le(&mut buf)?; value.write_le(&mut buf)?;
self.socket.send_to(&self.data_buf, self.target)?; self.socket.send_to(&self.data_buf, self.target)?;
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论