Lines Matching refs:m
11 let mut m = Message::new(); in test_message_buffer() localVariable
12 m.typ = MessageType { in test_message_buffer()
16 m.transaction_id = TransactionId::new(); in test_message_buffer()
17 m.add(ATTR_ERROR_CODE, &[0xff, 0xfe, 0xfa]); in test_message_buffer()
18 m.write_header(); in test_message_buffer()
21 let mut reader = BufReader::new(m.raw.as_slice()); in test_message_buffer()
24 assert_eq!(m_decoded, m, "{m_decoded} != {m}"); in test_message_buffer()
97 let mut m = MessageType::default(); in test_message_type_read_value() localVariable
98 m.read_value(input); in test_message_type_read_value()
99 assert_eq!(m, output, "ReadValue({input}) -> {m}, want {output}"); in test_message_type_read_value()
127 let mut m = MessageType::default(); in test_message_type_read_write_value() localVariable
129 m.read_value(v); in test_message_type_read_write_value()
130 assert_eq!(m, test, "ReadValue({test} -> {v}) = {m}, should be {test}"); in test_message_type_read_write_value()
138 let mut m = Message::new(); in test_message_write_to() localVariable
139 m.typ = MessageType { in test_message_write_to()
143 m.transaction_id = TransactionId::new(); in test_message_write_to()
144 m.add(ATTR_ERROR_CODE, &[0xff, 0xfe, 0xfa]); in test_message_write_to()
145 m.write_header(); in test_message_write_to()
149 m.write_to(&mut writer)?; in test_message_write_to()
155 assert_eq!(m_decoded, m, "{m_decoded} != {m}"); in test_message_write_to()
188 let mut m = Message { in test_message_bad_length() localVariable
194 m.add(AttrType(0x1), &[1, 2]); in test_message_bad_length()
195 m.write_header(); in test_message_bad_length()
196 m.raw[20 + 3] = 10; // set attr length = 10 in test_message_bad_length()
199 let result = m_decoded.write(&m.raw); in test_message_bad_length()
217 let mut m = Message { in test_message_attr_length_less_than_header() localVariable
223 m.encode(); in test_message_attr_length_less_than_header()
226 m.raw[3] = 2; // rewrite to bad length in test_message_attr_length_less_than_header()
228 let mut reader = BufReader::new(&m.raw[..20 + 2]); in test_message_attr_length_less_than_header()
247 let mut m = Message { in test_message_attr_size_less_than_length() localVariable
253 m.write_attributes(); in test_message_attr_size_less_than_length()
254 m.write_header(); in test_message_attr_size_less_than_length()
255 m.raw[3] = 5; // rewrite to bad length in test_message_attr_size_less_than_length()
258 let mut reader = BufReader::new(&m.raw[..20 + 5]); in test_message_attr_size_less_than_length()
547 let mut m = Message::new(); in test_message_grow() localVariable
548 m.grow(512, false); in test_message_grow()
549 assert_eq!(m.raw.len(), 512, "Bad length {}", m.raw.len()); in test_message_grow()
556 let mut m = Message::new(); in test_message_grow_smaller() localVariable
557 m.grow(2, false); in test_message_grow_smaller()
558 assert!(m.raw.capacity() >= 20, "Bad capacity {}", m.raw.capacity()); in test_message_grow_smaller()
560 assert!(m.raw.len() >= 20, "Bad length {}", m.raw.len()); in test_message_grow_smaller()
567 let m = Message::new(); in test_message_string() localVariable
568 assert_ne!(m.to_string(), "", "bad string"); in test_message_string()
575 let mut m = Message::new(); in test_is_message() localVariable
580 a.add_to(&mut m)?; in test_is_message()
581 m.write_header(); in test_is_message()
588 (m.raw.to_vec(), true), // 5 in test_is_message()
607 let mut m = Message::new(); in test_message_contains() localVariable
608 m.add(ATTR_SOFTWARE, "value".as_bytes()); in test_message_contains()
610 assert!(m.contains(ATTR_SOFTWARE), "message should contain software"); in test_message_contains()
611 assert!(!m.contains(ATTR_NONCE), "message should not contain nonce"); in test_message_contains()
618 let mut m = Message::new(); in test_message_full_size() localVariable
619 m.build(&[ in test_message_full_size()
630 let l = m.raw.len(); in test_message_full_size()
631 m.raw = m.raw[..l - 10].to_vec(); in test_message_full_size()
634 let l = m.raw.len(); in test_message_full_size()
635 decoder.raw = m.raw[..l - 10].to_vec(); in test_message_full_size()
644 let mut m = Message::new(); in test_message_clone_to() localVariable
645 m.build(&[ in test_message_clone_to()
656 m.encode(); in test_message_clone_to()
659 m.clone_to(&mut b)?; in test_message_clone_to()
660 assert_eq!(b, m, "not equal"); in test_message_clone_to()
674 let mut m = Message::new(); in test_message_add_to() localVariable
675 m.build(&[ in test_message_add_to()
680 m.encode(); in test_message_add_to()
683 m.clone_to(&mut b)?; in test_message_add_to()
685 m.transaction_id = TransactionId([1, 2, 3, 4, 5, 6, 7, 8, 9, 0, 2, 0]); in test_message_add_to()
686 assert_ne!(b, m, "should not be equal"); in test_message_add_to()
688 m.add_to(&mut b)?; in test_message_add_to()
689 assert_eq!(b, m, "should be equal"); in test_message_add_to()
696 let mut m = Message::new(); in test_decode() localVariable
697 m.typ = MessageType { in test_decode()
701 m.transaction_id = TransactionId::new(); in test_decode()
702 m.add(ATTR_ERROR_CODE, &[0xff, 0xfe, 0xfa]); in test_decode()
703 m.write_header(); in test_decode()
707 m_decoded.raw.extend_from_slice(&m.raw); in test_decode()
710 m_decoded, m, in test_decode()
719 let mut m = Message::new(); in test_message_marshal_binary() localVariable
720 m.build(&[ in test_message_marshal_binary()
728 let mut data = m.marshal_binary()?; in test_message_marshal_binary()
730 for i in 0..m.raw.len() { in test_message_marshal_binary()
731 m.raw[i] = 0; in test_message_marshal_binary()
733 m.unmarshal_binary(&data)?; in test_message_marshal_binary()
741 m.decode()?; in test_message_marshal_binary()