(&mut self)
| 1522 | } |
| 1523 | |
| 1524 | fn recover_non_trapping_protocol_error(&mut self) -> Result<()> { |
| 1525 | self.protocol |
| 1526 | .recover_error |
| 1527 | .call(&mut self.store) |
| 1528 | .context("PostgresMainLongJmp after backend ErrorResponse")?; |
| 1529 | self.protocol |
| 1530 | .send_ready |
| 1531 | .call(&mut self.store) |
| 1532 | .context("PostgresSendReadyForQueryIfNecessary after backend ErrorResponse")?; |
| 1533 | self.protocol |
| 1534 | .pq_flush |
| 1535 | .call(&mut self.store) |
| 1536 | .context("pgl_pq_flush after backend ErrorResponse recovery")?; |
| 1537 | let _ = self |
| 1538 | .io |
| 1539 | .take_output(&mut self.store, &self.env, &self.guest_allocator)?; |
| 1540 | Ok(()) |
| 1541 | } |
| 1542 | |
| 1543 | fn protocol_input_remaining(&mut self) -> Result<i32> { |
| 1544 | let host_remaining = self.io.available(&mut self.store)?; |
no test coverage detected