mirror of
https://github.com/zevenet/zproxy.git
synced 2025-10-26 11:19:19 +00:00
d484fc2929
The http parser might parse the body content several times, when the core enters a cycle of reads from client / backend. The core might read from client / backend more than once before the data is written to the backend / client. This might lead to parse the http response in chunked transfer mode several times, this bogusly increases message_total_bytes. Add a new ctx->buf_tail_len that specifies the number of bytes in the ctx->buf that have been read from client / backend in the last cycle. The http parser only consider the new bytes that are specified by ctx->buf_tail_len, hence, it does not parse the same data twice or more.
72 lines
2.2 KiB
C
72 lines
2.2 KiB
C
/*
|
|
* Copyright (C) 2023 Zevenet S.L. <support@zevenet.com>
|
|
*
|
|
* This program is free software: you can redistribute it and/or modify
|
|
* it under the terms of the GNU Affero General Public License as
|
|
* published by the Free Software Foundation, either version 3 of the
|
|
* License, or (at your option) any later version.
|
|
*
|
|
* This program is distributed in the hope that it will be useful,
|
|
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
* GNU Affero General Public License for more details.
|
|
*
|
|
* You should have received a copy of the GNU Affero General Public License
|
|
* along with this program. If not, see <http://www.gnu.org/licenses/>.
|
|
*/
|
|
|
|
#ifndef _ZPROXY_HTTP_H_
|
|
#define _ZPROXY_HTTP_H_
|
|
|
|
#include "proxy.h"
|
|
|
|
#include <stdint.h>
|
|
|
|
enum class RETURN_HTTP {
|
|
// * http wants to send a error/redirect to client and closes the connection
|
|
// * it will respond 100 continue to the client and next, it will receive the
|
|
// same request with the body appended. The HTTP lib should remove the
|
|
// 100 continue header and send the client buffer to the backend
|
|
PROXY_RESPONSE = -1,
|
|
// The request/response is not complete, it needs to continue reading
|
|
INCOMPLETE = 0,
|
|
// The http managing was properly. If a ctx->backend is set, the core will connect
|
|
SUCCESS = 1,
|
|
};
|
|
|
|
enum zproxy_http_origin {
|
|
ZPROXY_HTTP_CLIENT = 0,
|
|
ZPROXY_HTTP_BACKEND,
|
|
};
|
|
|
|
struct zproxy_http_ctx {
|
|
const struct zproxy_proxy_cfg *cfg;
|
|
HttpStream *stream;
|
|
void *state;
|
|
|
|
const char *buf;
|
|
uint32_t buf_len;
|
|
uint32_t buf_tail_len;
|
|
uint32_t buf_siz;
|
|
enum zproxy_http_origin from;
|
|
const struct sockaddr_in *addr;
|
|
uint64_t resp_len;
|
|
|
|
/* custom reply to client. */
|
|
const char *resp_buf;
|
|
bool http_continue;
|
|
bool http_close;
|
|
|
|
/* selected backend to connect to. */
|
|
struct zproxy_backend *backend;
|
|
uint64_t req_len;
|
|
};
|
|
|
|
int zproxy_http_request_parser(struct zproxy_http_ctx *ctx);
|
|
int zproxy_http_request_reconnect(struct zproxy_http_ctx *ctx);
|
|
int zproxy_http_response_parser(struct zproxy_http_ctx *ctx);
|
|
int zproxy_http_event_timeout(struct zproxy_http_ctx *ctx);
|
|
int zproxy_http_event_nossl(struct zproxy_http_ctx *ctx);
|
|
|
|
#endif
|