[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]
[libmicrohttpd] 02/06: Renamed request processing states for clarity and
From: |
gnunet |
Subject: |
[libmicrohttpd] 02/06: Renamed request processing states for clarity and readability |
Date: |
Tue, 27 Sep 2022 18:02:16 +0200 |
This is an automated email from the git hooks/post-receive script.
karlson2k pushed a commit to branch master
in repository libmicrohttpd.
commit b9972291435a373b7d92905f3ba153774e759b6b
Author: Evgeny Grin (Karlson2k) <k2k@narod.ru>
AuthorDate: Tue Sep 27 16:26:28 2022 +0300
Renamed request processing states for clarity and readability
---
src/microhttpd/connection.c | 37 ++++++++++++++++++-------------------
src/microhttpd/internal.c | 8 ++++----
src/microhttpd/internal.h | 16 +++++++++-------
3 files changed, 31 insertions(+), 30 deletions(-)
diff --git a/src/microhttpd/connection.c b/src/microhttpd/connection.c
index 7624711a..ddc60d85 100644
--- a/src/microhttpd/connection.c
+++ b/src/microhttpd/connection.c
@@ -2280,7 +2280,7 @@ build_connection_chunked_response_footer (struct
MHD_Connection *connection)
mhd_assert (connection->rp.props.chunked);
/* TODO: allow combining of the final footer with the last chunk,
* modify the next assert. */
- mhd_assert (MHD_CONNECTION_BODY_SENT == connection->state);
+ mhd_assert (MHD_CONNECTION_CHUNKED_BODY_SENT == connection->state);
mhd_assert (NULL != c->rp.response);
buf_size = connection_maximize_write_buffer (c);
@@ -2624,13 +2624,13 @@ MHD_connection_update_event_loop_info (struct
MHD_Connection *connection)
case MHD_CONNECTION_CHUNKED_BODY_UNREADY:
connection->event_loop_info = MHD_EVENT_LOOP_INFO_BLOCK;
break;
- case MHD_CONNECTION_BODY_SENT:
+ case MHD_CONNECTION_CHUNKED_BODY_SENT:
mhd_assert (0);
break;
case MHD_CONNECTION_FOOTERS_SENDING:
connection->event_loop_info = MHD_EVENT_LOOP_INFO_WRITE;
break;
- case MHD_CONNECTION_FOOTERS_SENT:
+ case MHD_CONNECTION_FULL_REPLY_SENT:
mhd_assert (0);
break;
case MHD_CONNECTION_CLOSED:
@@ -4208,9 +4208,9 @@ MHD_connection_handle_read (struct MHD_Connection
*connection,
case MHD_CONNECTION_NORMAL_BODY_READY:
case MHD_CONNECTION_CHUNKED_BODY_UNREADY:
case MHD_CONNECTION_CHUNKED_BODY_READY:
- case MHD_CONNECTION_BODY_SENT:
+ case MHD_CONNECTION_CHUNKED_BODY_SENT:
case MHD_CONNECTION_FOOTERS_SENDING:
- case MHD_CONNECTION_FOOTERS_SENT:
+ case MHD_CONNECTION_FULL_REPLY_SENT:
default:
mhd_assert (0); /* Should not be possible */
}
@@ -4466,7 +4466,7 @@ MHD_connection_handle_write (struct MHD_Connection
*connection)
}
if (connection->rp.rsp_write_position ==
connection->rp.response->total_size)
- connection->state = MHD_CONNECTION_FOOTERS_SENT; /* have no footers */
+ connection->state = MHD_CONNECTION_FULL_REPLY_SENT;
return;
case MHD_CONNECTION_NORMAL_BODY_UNREADY:
mhd_assert (0);
@@ -4500,11 +4500,11 @@ MHD_connection_handle_write (struct MHD_Connection
*connection)
check_write_done (connection,
(connection->rp.response->total_size ==
connection->rp.rsp_write_position) ?
- MHD_CONNECTION_BODY_SENT :
+ MHD_CONNECTION_CHUNKED_BODY_SENT :
MHD_CONNECTION_CHUNKED_BODY_UNREADY);
return;
case MHD_CONNECTION_CHUNKED_BODY_UNREADY:
- case MHD_CONNECTION_BODY_SENT:
+ case MHD_CONNECTION_CHUNKED_BODY_SENT:
mhd_assert (0);
return;
case MHD_CONNECTION_FOOTERS_SENDING:
@@ -4534,9 +4534,9 @@ MHD_connection_handle_write (struct MHD_Connection
*connection)
if (MHD_CONNECTION_FOOTERS_SENDING != connection->state)
return;
check_write_done (connection,
- MHD_CONNECTION_FOOTERS_SENT);
+ MHD_CONNECTION_FULL_REPLY_SENT);
return;
- case MHD_CONNECTION_FOOTERS_SENT:
+ case MHD_CONNECTION_FULL_REPLY_SENT:
mhd_assert (0);
return;
case MHD_CONNECTION_CLOSED:
@@ -5065,7 +5065,6 @@ MHD_connection_handle_idle (struct MHD_Connection
*connection)
/* no default action */
break;
case MHD_CONNECTION_HEADERS_SENT:
- /* Some clients may take some actions right after header receive */
#ifdef UPGRADE_SUPPORT
if (NULL != connection->rp.response->upgrade_handler)
{
@@ -5099,7 +5098,7 @@ MHD_connection_handle_idle (struct MHD_Connection
*connection)
connection->state = MHD_CONNECTION_NORMAL_BODY_UNREADY;
}
else
- connection->state = MHD_CONNECTION_FOOTERS_SENT;
+ connection->state = MHD_CONNECTION_FULL_REPLY_SENT;
continue;
case MHD_CONNECTION_NORMAL_BODY_READY:
/* nothing to do here */
@@ -5116,9 +5115,9 @@ MHD_connection_handle_idle (struct MHD_Connection
*connection)
MHD_mutex_unlock_chk_ (&connection->rp.response->mutex);
#endif
if (connection->rp.props.chunked)
- connection->state = MHD_CONNECTION_BODY_SENT;
+ connection->state = MHD_CONNECTION_CHUNKED_BODY_SENT;
else
- connection->state = MHD_CONNECTION_FOOTERS_SENT;
+ connection->state = MHD_CONNECTION_FULL_REPLY_SENT;
continue;
}
if (MHD_NO != try_ready_normal_body (connection))
@@ -5151,7 +5150,7 @@ MHD_connection_handle_idle (struct MHD_Connection
*connection)
if (NULL != connection->rp.response->crc)
MHD_mutex_unlock_chk_ (&connection->rp.response->mutex);
#endif
- connection->state = MHD_CONNECTION_BODY_SENT;
+ connection->state = MHD_CONNECTION_CHUNKED_BODY_SENT;
continue;
}
if (1)
@@ -5163,14 +5162,14 @@ MHD_connection_handle_idle (struct MHD_Connection
*connection)
if (NULL != connection->rp.response->crc)
MHD_mutex_unlock_chk_ (&connection->rp.response->mutex);
#endif
- connection->state = finished ? MHD_CONNECTION_BODY_SENT :
+ connection->state = finished ? MHD_CONNECTION_CHUNKED_BODY_SENT :
MHD_CONNECTION_CHUNKED_BODY_READY;
continue;
}
/* mutex was already unlocked by try_ready_chunked_body */
}
break;
- case MHD_CONNECTION_BODY_SENT:
+ case MHD_CONNECTION_CHUNKED_BODY_SENT:
mhd_assert (connection->rp.props.chunked);
if (MHD_NO == build_connection_chunked_response_footer (connection))
@@ -5185,14 +5184,14 @@ MHD_connection_handle_idle (struct MHD_Connection
*connection)
if ( (! connection->rp.props.chunked) ||
(connection->write_buffer_send_offset ==
connection->write_buffer_append_offset) )
- connection->state = MHD_CONNECTION_FOOTERS_SENT;
+ connection->state = MHD_CONNECTION_FULL_REPLY_SENT;
else
connection->state = MHD_CONNECTION_FOOTERS_SENDING;
continue;
case MHD_CONNECTION_FOOTERS_SENDING:
/* no default action */
break;
- case MHD_CONNECTION_FOOTERS_SENT:
+ case MHD_CONNECTION_FULL_REPLY_SENT:
if (MHD_HTTP_PROCESSING == connection->rp.responseCode)
{
/* After this type of response, we allow sending another! */
diff --git a/src/microhttpd/internal.c b/src/microhttpd/internal.c
index 57553251..dee21e9e 100644
--- a/src/microhttpd/internal.c
+++ b/src/microhttpd/internal.c
@@ -75,12 +75,12 @@ MHD_state_to_string (enum MHD_CONNECTION_STATE state)
return "chunked body unready";
case MHD_CONNECTION_CHUNKED_BODY_READY:
return "chunked body ready";
- case MHD_CONNECTION_BODY_SENT:
- return "body sent";
+ case MHD_CONNECTION_CHUNKED_BODY_SENT:
+ return "chunked body sent";
case MHD_CONNECTION_FOOTERS_SENDING:
return "footers sending";
- case MHD_CONNECTION_FOOTERS_SENT:
- return "footers sent";
+ case MHD_CONNECTION_FULL_REPLY_SENT:
+ return "reply sent completely";
case MHD_CONNECTION_CLOSED:
return "closed";
default:
diff --git a/src/microhttpd/internal.h b/src/microhttpd/internal.h
index adb69b32..37f38eea 100644
--- a/src/microhttpd/internal.h
+++ b/src/microhttpd/internal.h
@@ -706,31 +706,33 @@ enum MHD_CONNECTION_STATE
MHD_CONNECTION_CHUNKED_BODY_READY = MHD_CONNECTION_CHUNKED_BODY_UNREADY + 1,
/**
- * We have sent the response body. Prepare the footers.
+ * We have sent the chunked response body. Prepare the footers.
*/
- MHD_CONNECTION_BODY_SENT = MHD_CONNECTION_CHUNKED_BODY_READY + 1,
+ MHD_CONNECTION_CHUNKED_BODY_SENT = MHD_CONNECTION_CHUNKED_BODY_READY + 1,
/**
* We have prepared the response footer. Send it.
*/
- MHD_CONNECTION_FOOTERS_SENDING = MHD_CONNECTION_BODY_SENT + 1,
+ MHD_CONNECTION_FOOTERS_SENDING = MHD_CONNECTION_CHUNKED_BODY_SENT + 1,
/**
- * We have sent the response footer. Shutdown or restart.
+ * We have sent the entire reply.
+ * Shutdown connection or restart processing to get a new request.
*/
- MHD_CONNECTION_FOOTERS_SENT = MHD_CONNECTION_FOOTERS_SENDING + 1,
+ MHD_CONNECTION_FULL_REPLY_SENT = MHD_CONNECTION_FOOTERS_SENDING + 1,
/**
* This connection is to be closed.
*/
- MHD_CONNECTION_CLOSED = MHD_CONNECTION_FOOTERS_SENT + 1,
+ MHD_CONNECTION_CLOSED = MHD_CONNECTION_FULL_REPLY_SENT + 1
#ifdef UPGRADE_SUPPORT
+ ,
/**
* Connection was "upgraded" and socket is now under the
* control of the application.
*/
- MHD_CONNECTION_UPGRADE
+ MHD_CONNECTION_UPGRADE = MHD_CONNECTION_CLOSED + 1
#endif /* UPGRADE_SUPPORT */
} _MHD_FIXED_ENUM;
--
To stop receiving notification emails like this one, please contact
gnunet@gnunet.org.
- [libmicrohttpd] branch master updated (77303a4a -> 889b74b6), gnunet, 2022/09/27
- [libmicrohttpd] 03/06: Removed one debug member from release builds, gnunet, 2022/09/27
- [libmicrohttpd] 06/06: connection.c: removed unused check for chunked replies, gnunet, 2022/09/27
- [libmicrohttpd] 01/06: configure: fixed typos in messages, gnunet, 2022/09/27
- [libmicrohttpd] 02/06: Renamed request processing states for clarity and readability,
gnunet <=
- [libmicrohttpd] 04/06: connection.c: fixed typo in comment, gnunet, 2022/09/27
- [libmicrohttpd] 05/06: connection.c: added asserts for connection's states processing logic, gnunet, 2022/09/27