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

body process

This commit is contained in:
freemine 2020-08-01 13:28:39 +08:00
parent d9c04b18e9
commit 93cb6386df
2 changed files with 18 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
src/plugins/http/src/httpContext.c
View File

@ -337,6 +337,7 @@ static void on_header_field(void *arg, const char *key, const char *val) {
if (pParser->failed) return;
D("==key:[%s], val:[%s]==", key, val);
int avail = sizeof(pParser->buffer) - (pParser->pLast - pParser->buffer);
int n = snprintf(pParser->pLast, avail,
"%s: %s\r\n", key, val);
@ -350,7 +351,7 @@ static void on_header_field(void *arg, const char *key, const char *val) {
break;
}
pParser->bufsize += n;
pParser->pCur = pParser->pLast;
pParser->pCur = pParser->pLast + n;
if (!httpParseHead(pContext)) {
httpDebug("context:%p, fd:%d, ip:%s, thread:%s, accessTimes:%d, on_header_field(%s,%s), parse head failed",
@ -372,9 +373,19 @@ static void on_body(void *arg, const char *chunk, size_t len) {
if (pParser->failed) return;
if (pParser->data.pos == 0) pParser->data.pos = pParser->pLast;
if (pParser->data.pos == 0) {
pParser->data.pos = pParser->pLast;
pParser->data.len = 0;
}
A("not implemented yet");
int avail = sizeof(pParser->buffer) - (pParser->pLast - pParser->buffer);
if (len+1>=avail) {
pParser->failed |= EHTTP_CONTEXT_PROCESS_FAILED;
return;
}
memcpy(pParser->pLast, chunk, len);
pParser->pLast += len;
pParser->data.len += len;
}
static void on_end(void *arg) {

6
src/plugins/http/src/httpServer.c
View File

@ -138,7 +138,7 @@ static bool httpDecompressData(HttpContext *pContext) {
}
static bool httpReadData(HttpContext *pContext) {
if (0) return ehttpReadData(pContext);
if (1) return ehttpReadData(pContext);
if (!pContext->parsed) {
httpInitContext(pContext);
@ -448,7 +448,9 @@ static bool ehttpReadData(HttpContext *pContext) {
return false;
}
if (pContext->parsed) {
int ret = httpCheckReadCompleted(pContext);
// int ret = httpCheckReadCompleted(pContext);
// already done in ehttp_parser
int ret = HTTP_CHECK_BODY_SUCCESS;
if (ret == HTTP_CHECK_BODY_CONTINUE) {
//httpDebug("context:%p, fd:%d, ip:%s, not finished yet, wait another event", pContext, pContext->fd, pContext->ipstr);
httpReleaseContext(pContext);