61 lines
1.2 KiB
Rust
61 lines
1.2 KiB
Rust
macro_rules! try_pg_conn(
|
|
($e:expr) => (
|
|
match $e {
|
|
Ok(ok) => ok,
|
|
Err(err) => return Err(PgConnectStreamError(err))
|
|
}
|
|
)
|
|
)
|
|
|
|
macro_rules! try_pg(
|
|
($e:expr) => (
|
|
match $e {
|
|
Ok(ok) => ok,
|
|
Err(err) => return Err(PgStreamError(err))
|
|
}
|
|
)
|
|
)
|
|
|
|
macro_rules! try_desync(
|
|
($s:expr, $e:expr) => (
|
|
match $e {
|
|
Ok(ok) => ok,
|
|
Err(err) => {
|
|
$s.desynchronized = true;
|
|
return Err(err);
|
|
}
|
|
}
|
|
)
|
|
)
|
|
|
|
macro_rules! try_pg_desync(
|
|
($s:expr, $e:expr) => (
|
|
match $e {
|
|
Ok(ok) => ok,
|
|
Err(err) => {
|
|
$s.desynchronized = true;
|
|
return Err(PgStreamError(err))
|
|
}
|
|
}
|
|
)
|
|
)
|
|
|
|
macro_rules! check_desync(
|
|
($e:expr) => ({
|
|
if $e.canary() != CANARY {
|
|
panic!("PostgresConnection use after free. See mozilla/rust#13246.");
|
|
}
|
|
if $e.is_desynchronized() {
|
|
return Err(PgStreamDesynchronized);
|
|
}
|
|
})
|
|
)
|
|
|
|
macro_rules! bad_response(
|
|
($s:expr) => ({
|
|
debug!("Unexpected response");
|
|
$s.desynchronized = true;
|
|
return Err(PgBadResponse);
|
|
})
|
|
)
|