()
| 2131 | } |
| 2132 | |
| 2133 | func (pgConn *PgConn) flushWithPotentialWriteReadDeadlock() error { |
| 2134 | pgConn.enterPotentialWriteReadDeadlock() |
| 2135 | defer pgConn.exitPotentialWriteReadDeadlock() |
| 2136 | err := pgConn.frontend.Flush() |
| 2137 | return err |
| 2138 | } |
| 2139 | |
| 2140 | // SyncConn prepares the underlying net.Conn for direct use. PgConn may internally buffer reads or use goroutines for |
| 2141 | // background IO. This means that any direct use of the underlying net.Conn may be corrupted if a read is already |
no test coverage detected