xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

add http interface

This commit is contained in:
Yihao Deng 2024-07-08 03:25:41 +00:00
parent 392e65c2ac
commit c3caa8475a
1 changed files with 3 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
source/libs/transport/src/thttp.c
View File

@ -509,7 +509,6 @@ static void httpHandleReq(SHttpMsg* msg) {
terrno = TSDB_CODE_OUT_OF_MEMORY; terrno = TSDB_CODE_OUT_OF_MEMORY;
goto END; goto END;
} }
wb[0] = uv_buf_init((char*)header, strlen(header)); // heap var wb[0] = uv_buf_init((char*)header, strlen(header)); // heap var
wb[1] = uv_buf_init((char*)msg->cont, msg->len); // heap var wb[1] = uv_buf_init((char*)msg->cont, msg->len); // heap var
@ -520,17 +519,17 @@ static void httpHandleReq(SHttpMsg* msg) {
goto END; goto END;
} }
cli->wbuf = wb;
cli->conn.data = cli; cli->conn.data = cli;
cli->tcp.data = cli; cli->tcp.data = cli;
cli->req.data = cli; cli->req.data = cli;
cli->addr = msg->server;
cli->port = msg->port;
cli->dest = dest; cli->dest = dest;
cli->chanId = chanId; cli->chanId = chanId;
cli->addr = msg->server;
cli->port = msg->port;
taosMemoryFree(msg->uri); taosMemoryFree(msg->uri);
taosMemoryFree(msg); taosMemoryFree(msg);
cli->wbuf = wb;
cli->rbuf = taosMemoryCalloc(1, HTTP_RECV_BUF_SIZE); cli->rbuf = taosMemoryCalloc(1, HTTP_RECV_BUF_SIZE);
if (cli->rbuf == NULL) { if (cli->rbuf == NULL) {
tError("http-report failed to alloc read buf, dst:%s:%d,chanId:%" PRId64 ", reason:%s", cli->addr, cli->port, tError("http-report failed to alloc read buf, dst:%s:%d,chanId:%" PRId64 ", reason:%s", cli->addr, cli->port,