Lines Matching refs:conn

92     firehose_conn_t *conn;
140 rv = apr_file_write_full(ctx->conn->file, header, hdr_len, NULL);
142 if (ctx->conn->suppress) {
152 (apr_uint64_t)(hdr_len), ctx->conn->filename, ctx->conn->direction, ctx->uuid, ctx->count);
161 (apr_uint64_t)(hdr_len), ctx->conn->filename, ctx->conn->direction, ctx->uuid, ctx->count);
163 ctx->conn->suppress = 1;
166 ctx->conn->suppress = 0;
222 rv = apr_file_writev_full(ctx->conn->file, vec, 3, &bytes);
224 if (ctx->conn->suppress) {
234 (apr_uint64_t)(vec[0].iov_len + vec[1].iov_len + vec[2].iov_len), ctx->conn->filename, ctx->conn->direction, ctx->uuid, ctx->count);
243 (apr_uint64_t)(vec[0].iov_len + vec[1].iov_len + vec[2].iov_len), ctx->conn->filename, ctx->conn->direction, ctx->uuid, ctx->count);
245 ctx->conn->suppress = 1;
249 ctx->conn->suppress = 0;
355 if (ctx->conn->request == FIREHOSE_REQUEST) {
371 if (ctx->conn->request == FIREHOSE_REQUEST) {
415 firehose_conn_t *conn;
424 conn = (firehose_conn_t *) conf->firehoses->elts;
427 if (!conn->file || (conn->proxy == FIREHOSE_NORMAL
428 && !c->sbh) || (conn->proxy == FIREHOSE_PROXY && c->sbh)) {
429 conn++;
436 ctx->conn = conn;
440 if (conn->direction == FIREHOSE_IN) {
441 ctx->direction = conn->proxy == FIREHOSE_PROXY ? '>' : '<';
446 if (conn->direction == FIREHOSE_OUT) {
447 ctx->direction = conn->proxy == FIREHOSE_PROXY ? '<' : '>';
453 conn++;
466 firehose_conn_t *conn;
481 conn = (firehose_conn_t *) conf->firehoses->elts;
483 if (APR_SUCCESS != (rv = apr_file_open(&conn->file, conn->filename,
485 | conn->nonblock, APR_OS_DEFAULT, plog))) {
489 conn->filename, conn->proxy == FIREHOSE_PROXY ? "proxy " : "",
490 conn->request == FIREHOSE_REQUEST ? " request" : "connection",
491 conn->direction == FIREHOSE_IN ? "input" : "output");
493 conn++;