Noratrieb/haesli
1
0
Fork 0
mirror of https://github.com/Noratrieb/haesli.git synced 2026-01-16 20:55:03 +01:00
Code Issues Projects Releases Packages Wiki Activity Actions

codegen

Browse source
This commit is contained in:
nora 2022-02-09 17:39:46 +01:00
parent e5fa49a05a
commit d5fd9abdf7
10 changed files with 640 additions and 7 deletions
Download patch file Download diff file Expand all files Collapse all files

10
amqp_transport/src/connection.rs
View file

@ -32,8 +32,8 @@ impl Connection {
async fn negotiate_version(&mut self) -> Result<(), TransError> {
const HEADER_SIZE: usize = 8;
const PROTOCOL_VERSION: &[u8] = &[0, 9, 1];
const PROTOCOL_HEADER: &[u8] = b"AMQP\0\0\x09\x01";
const SUPPORTED_PROTOCOL_VERSION: &[u8] = &[0, 9, 1];
const OWN_PROTOCOL_HEADER: &[u8] = b"AMQP\0\0\x09\x01";
debug!("Negotiating version");
@ -49,15 +49,15 @@ impl Connection {
let version = &read_header_buf[5..8];
self.stream
.write_all(PROTOCOL_HEADER)
.write_all(OWN_PROTOCOL_HEADER)
.await
.context("write protocol header")?;
if &read_header_buf[0..5] == b"AMQP\0" && version == PROTOCOL_VERSION {
if &read_header_buf[0..5] == b"AMQP\0" && version == SUPPORTED_PROTOCOL_VERSION {
debug!(?version, "Version negotiation successful");
Ok(())
} else {
debug!(?version, expected_version = ?PROTOCOL_VERSION, "Version negotiation failed, unsupported version");
debug!(?version, expected_version = ?SUPPORTED_PROTOCOL_VERSION, "Version negotiation failed, unsupported version");
Err(ProtocolError::OtherCloseConnection.into())
}
}