Commit b8ceac6f authored by Nawasan Wisitsingkhon's avatar Nawasan Wisitsingkhon

refactor: change ofpheader to ofp_header

parent f8cf0109
...@@ -26,11 +26,12 @@ impl<OME: OfpMsgEvent> Controller<OME> { ...@@ -26,11 +26,12 @@ impl<OME: OfpMsgEvent> Controller<OME> {
pub fn send_msg<T: MessageMarshal>(&self, msg: T, xid: u32, stream: &mut TcpStream) { pub fn send_msg<T: MessageMarshal>(&self, msg: T, xid: u32, stream: &mut TcpStream) {
let mut header_bytes: Vec<u8> = Vec::new(); let mut header_bytes: Vec<u8> = Vec::new();
let mut body_bytes: Vec<u8> = Vec::new(); let mut body_bytes: Vec<u8> = Vec::new();
msg.marshal(&mut body_bytes); msg.marshal(&mut body_bytes);
let ofpheader = let ofp_header =
self.ofp self.ofp
.header(msg.msg_usize(&self.ofp) as u8, body_bytes.len() as u16, xid); .header(msg.msg_usize(&self.ofp) as u8, body_bytes.len() as u16, xid);
ofpheader.marshal(&mut header_bytes); ofp_header.marshal(&mut header_bytes);
header_bytes.append(&mut body_bytes); header_bytes.append(&mut body_bytes);
let _ = stream.write_all(&header_bytes); let _ = stream.write_all(&header_bytes);
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment