gnunet-svn
[Top][All Lists]
Advanced

[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.



reply via email to

[Prev in Thread] Current Thread [Next in Thread]