(ctx context.Context, pc *protocol.Conn, req Request)
| 1271 | } |
| 1272 | |
| 1273 | func (c *conn) roundTrip(ctx context.Context, pc *protocol.Conn, req Request) (Response, error) { |
| 1274 | pprof.SetGoroutineLabels(ctx) |
| 1275 | defer pprof.SetGoroutineLabels(context.Background()) |
| 1276 | |
| 1277 | if deadline, hasDeadline := ctx.Deadline(); hasDeadline { |
| 1278 | pc.SetDeadline(deadline) |
| 1279 | defer pc.SetDeadline(time.Time{}) |
| 1280 | } |
| 1281 | |
| 1282 | return pc.RoundTrip(req) |
| 1283 | } |
| 1284 | |
| 1285 | // authenticateSASL performs all of the required requests to authenticate this |
| 1286 | // connection. If any step fails, this function returns with an error. A nil |
no test coverage detected