Lines Matching refs:b
389 static void fastcgi_status_copy_procname(buffer *b, fcgi_extension_host *host, fcgi_proc *proc) { in fastcgi_status_copy_procname() argument
390 buffer_copy_string_len(b, CONST_STR_LEN("fastcgi.backend.")); in fastcgi_status_copy_procname()
391 buffer_append_string_buffer(b, host->id); in fastcgi_status_copy_procname()
393 buffer_append_string_len(b, CONST_STR_LEN(".")); in fastcgi_status_copy_procname()
394 buffer_append_long(b, proc->id); in fastcgi_status_copy_procname()
460 static int fastcgi_status_init(server *srv, buffer *b, fcgi_extension_host *host, fcgi_proc *proc) { in fastcgi_status_init() argument
462 fastcgi_status_copy_procname(b, host, proc); \ in fastcgi_status_init()
463 buffer_append_string_len(b, CONST_STR_LEN(x)); \ in fastcgi_status_init()
464 status_counter_set(srv, CONST_BUF_LEN(b), 0); in fastcgi_status_init()
475 fastcgi_status_copy_procname(b, host, NULL); \ in fastcgi_status_init()
476 buffer_append_string_len(b, CONST_STR_LEN(x)); \ in fastcgi_status_init()
477 status_counter_set(srv, CONST_BUF_LEN(b), 0); in fastcgi_status_init()
791 static int parse_binpath(char_array *env, buffer *b) { in parse_binpath() argument
796 start = b->ptr; in parse_binpath()
797 for (i = 0; i < b->used - 1; i++) { in parse_binpath()
798 switch(b->ptr[i]) { in parse_binpath()
811 b->ptr[i] = '\0'; in parse_binpath()
815 start = b->ptr + i + 1; in parse_binpath()
1819 buffer *b; in fcgi_create_env() local
1844 b = chunkqueue_get_append_buffer(hctx->wb); in fcgi_create_env()
1846 buffer_copy_memory(b, (const char *)&beginRecord, sizeof(beginRecord)); in fcgi_create_env()
2041 buffer_append_memory(b, (const char *)&header, sizeof(header)); in fcgi_create_env()
2042 buffer_append_memory(b, (const char *)p->fcgi_env->ptr, p->fcgi_env->used); in fcgi_create_env()
2045 buffer_append_memory(b, (const char *)&header, sizeof(header)); in fcgi_create_env()
2047 b->used++; /* add virtual \0 */ in fcgi_create_env()
2048 hctx->wb->bytes_in += b->used - 1; in fcgi_create_env()
2065 b = chunkqueue_get_append_buffer(hctx->wb); in fcgi_create_env()
2067 buffer_copy_memory(b, (const char *)&header, sizeof(header)); in fcgi_create_env()
2140 buffer_append_memory(b, req_c->mem->ptr + req_c->offset, weHave); in fcgi_create_env()
2160 b->used++; /* add virtual \0 */ in fcgi_create_env()
2165 b = chunkqueue_get_append_buffer(hctx->wb); in fcgi_create_env()
2168 buffer_copy_memory(b, (const char *)&header, sizeof(header)); in fcgi_create_env()
2169 b->used++; /* add virtual \0 */ in fcgi_create_env()
2384 buffer *b; member
2399 packet->b = buffer_init(); in fastcgi_get_packet()
2412 if (packet->b->used == 0) { in fastcgi_get_packet()
2413 buffer_copy_string_len(packet->b, c->mem->ptr + c->offset, weHave); in fastcgi_get_packet()
2415 buffer_append_string_len(packet->b, c->mem->ptr + c->offset, weHave); in fastcgi_get_packet()
2423 if ((packet->b->used == 0) || in fastcgi_get_packet()
2424 (packet->b->used - 1 < sizeof(FCGI_Header))) { in fastcgi_get_packet()
2426 buffer_free(packet->b); in fastcgi_get_packet()
2429 …log_error_write(srv, __FILE__, __LINE__, "sdsds", "FastCGI: header too small:", packet->b->used, "… in fastcgi_get_packet()
2435 header = (FCGI_Header *)(packet->b->ptr); in fastcgi_get_packet()
2443 buffer_copy_string_len(packet->b, CONST_STR_LEN("")); /* used == 1 */ in fastcgi_get_packet()
2447 for (; c && (packet->b->used < packet->len + 1); c = c->next) { in fastcgi_get_packet()
2448 size_t weWant = packet->len - (packet->b->used - 1); in fastcgi_get_packet()
2453 buffer_append_string_len(packet->b, c->mem->ptr + c->offset + offset, weHave); in fastcgi_get_packet()
2459 if (packet->b->used < packet->len + 1) { in fastcgi_get_packet()
2462 buffer_free(packet->b); in fastcgi_get_packet()
2466 packet->b->used -= packet->padding; in fastcgi_get_packet()
2467 packet->b->ptr[packet->b->used - 1] = '\0'; in fastcgi_get_packet()
2513 buffer *b; in fcgi_demux_response() local
2517 b = chunkqueue_get_append_buffer(hctx->rb); in fcgi_demux_response()
2518 buffer_prepare_copy(b, toread + 1); in fcgi_demux_response()
2521 if (-1 == (r = read(hctx->fd, b->ptr, toread))) { in fcgi_demux_response()
2540 b->used = r + 1; /* one extra for the fake \0 */ in fcgi_demux_response()
2541 b->ptr[b->used - 1] = '\0'; in fcgi_demux_response()
2583 buffer_copy_string_buffer(hctx->response_header, packet.b); in fcgi_demux_response()
2585 buffer_append_string_buffer(hctx->response_header, packet.b); in fcgi_demux_response()
2662 } else if (hctx->send_content_body && packet.b->used > 1) { in fcgi_demux_response()
2669 http_chunk_append_mem(srv, con, packet.b->ptr, packet.b->used); in fcgi_demux_response()
2677 "FastCGI-stderr:", packet.b); in fcgi_demux_response()
2698 buffer_free(packet.b); in fcgi_demux_response()