]> granicus.if.org Git - apache/commitdiff
Introduce new function ap_get_conn_socket() to access the socket of
authorStefan Fritsch <sf@apache.org>
Mon, 13 Jun 2011 16:02:18 +0000 (16:02 +0000)
committerStefan Fritsch <sf@apache.org>
Mon, 13 Jun 2011 16:02:18 +0000 (16:02 +0000)
a connection

git-svn-id: https://svn.apache.org/repos/asf/httpd/httpd/trunk@1135153 13f79535-47bb-0310-9956-ffa450edef68

13 files changed:
CHANGES
docs/manual/developer/new_api_2_4.xml
include/ap_mmn.h
include/http_core.h
modules/echo/mod_echo.c
modules/experimental/mod_noloris.c
modules/filters/mod_reqtimeout.c
modules/http/http_core.c
modules/proxy/mod_proxy_connect.c
modules/proxy/mod_proxy_fdpass.c
server/connection.c
server/core.c
server/protocol.c

diff --git a/CHANGES b/CHANGES
index 8ee3111657b483f444d6911db863b26abfb239ee..b704e4ce61f5719fa25399bad59434934a75242c 100644 (file)
--- a/CHANGES
+++ b/CHANGES
@@ -2,6 +2,9 @@
 
 Changes with Apache 2.3.13
 
+  *) core: Introduce new function ap_get_conn_socket() to access the socket of
+     a connection. [Stefan Fritsch]
+
   *) mod_data: Introduce a filter to support RFC2397 data URLs. [Graham
      Leggett]
 
index b3bdf13bd489ab9e02275923d4595d0446ae579f..6bce75589f54e581c4eadbf81ee6e5a6669f016e 100644 (file)
           initial configuration preflight phase or not. This is both easier to
           use and more correct than the old method of creating a pool userdata
           entry in the process pool.</li>
+      <li>New function ap_get_conn_socket to get the socket descriptor for a
+          connection. This should be used instead of accessing the core
+          connection config directly.</li>
     </ul>
   </section>
 
index be41daea7ecdcbcedbc236577f28e8df8261775d..b7f927ca26c6a9f817dc7b1999969492d66a9b74 100644 (file)
  *                         context_document_root, context_prefix.
  *                         Add ap_context_*(), ap_set_context_info(), ap_set_document_root()
  * 20110605.1 (2.3.13-dev) add ap_(get|set)_core_module_config()
+ * 20110605.2 (2.3.13-dev) add ap_get_conn_socket()
  */
 
 #define MODULE_MAGIC_COOKIE 0x41503234UL /* "AP24" */
 #ifndef MODULE_MAGIC_NUMBER_MAJOR
 #define MODULE_MAGIC_NUMBER_MAJOR 20110605
 #endif
-#define MODULE_MAGIC_NUMBER_MINOR 1                    /* 0...n */
+#define MODULE_MAGIC_NUMBER_MINOR 2                    /* 0...n */
 
 /**
  * Determine if the server's current MODULE_MAGIC_NUMBER is at least a
index b64e0b2986dce38040a16ad161b36f7325a2d038..f3644ad8ab753374bad70ecbc3d477b8f62d5fc6 100644 (file)
@@ -336,6 +336,13 @@ AP_DECLARE(void *) ap_get_core_module_config(const ap_conf_vector_t *cv);
  */
 AP_DECLARE(void) ap_set_core_module_config(ap_conf_vector_t *cv, void *val);
 
+/** Get the socket from the core network filter. This should be used instead of
+ * accessing the core connection config directly.
+ * @param c The connection record
+ * @return The socket
+ */
+AP_DECLARE(apr_socket_t *) ap_get_conn_socket(conn_rec *c);
+
 #ifndef AP_DEBUG
 #define AP_CORE_MODULE_INDEX  0
 #define ap_get_core_module_config(v) \
index 7d21fd5b1c879f3e5ab68d13d8daa5173adf82fb..c595496b479e624112f25dc8bd0778a2c0bd3907 100644 (file)
@@ -168,7 +168,7 @@ static int process_echo_connection(conn_rec *c)
         }
 
         if (!csd) {
-            csd = ap_get_core_module_config(c->conn_config);
+            csd = ap_get_conn_socket(c);
             apr_socket_timeout_set(csd, c->base_server->keep_alive_timeout);
         }
 
index f2abeef32b3bc9e8f53d52ea11a8cffe0f6a2228..cfc217e1eaa1240e909721e9ba899342407071de 100644 (file)
@@ -68,7 +68,7 @@ static int noloris_conn(conn_rec *conn)
     shm_rec = apr_shm_baseaddr_get(shm);
     while (shm_rec[0] != '\0') {
         if (!strcmp(shm_rec, conn->remote_ip)) {
-            apr_socket_t *csd = ap_get_core_module_config(conn->conn_config);
+            apr_socket_t *csd = ap_get_conn_socket(conn);
             ap_log_cerror(APLOG_MARK, APLOG_ERR, 0, conn,
                           "Dropping connection from banned IP %s",
                           conn->remote_ip);
index 709e0923ea65eb2bd73b515c6e8bf21975771a95..5e7f4fbcec97c0d78530048207930af7b2989ff8 100644 (file)
@@ -186,7 +186,7 @@ static apr_status_t reqtimeout_filter(ap_filter_t *f,
     }
 
     if (!ccfg->socket) {
-        ccfg->socket = ap_get_core_module_config(f->c->conn_config);
+        ccfg->socket = ap_get_conn_socket(f->c);
     }
 
     rv = check_time_left(ccfg, &time_left);
index 932f6f28f3ccf26bee777a6b067f43203c7c895e..fe26de70cdb605b9655d95a5c18d207a9be7effe 100644 (file)
@@ -208,7 +208,7 @@ static int ap_process_http_sync_connection(conn_rec *c)
         }
 
         if (!csd) {
-            csd = ap_get_core_module_config(c->conn_config);
+            csd = ap_get_conn_socket(c);
         }
         apr_socket_opt_set(csd, APR_INCOMPLETE_READ, 1);
         apr_socket_timeout_set(csd, c->base_server->keep_alive_timeout);
index 578313ad2d2be7a9b165b106ab75af83b975c586..6da0a2d4ddec2deeaf17fd03b61f4573ded07388 100644 (file)
@@ -209,7 +209,7 @@ static int proxy_connect_handler(request_rec *r, proxy_worker *worker,
     apr_status_t err, rv;
     apr_size_t nbytes;
     char buffer[HUGE_STRING_LEN];
-    apr_socket_t *client_socket = ap_get_core_module_config(c->conn_config);
+    apr_socket_t *client_socket = ap_get_conn_socket(c);
     int failed, rc;
     int client_error = 0;
     apr_pollset_t *pollset;
index 2da9395ac278a9c34e0f1ab3799f9a1240ef5d55..ca547f8f501c9f209d543eeb77ed1b6b43a16f0f 100644 (file)
@@ -221,9 +221,7 @@ static int proxy_fdpass_handler(request_rec *r, proxy_worker *worker,
         }
     }
 
-    /* XXXXX: THIS IS AN EVIL HACK */
-    /* There should really be a (documented) public API for this ! */
-    clientsock = ap_get_core_module_config(r->connection->conn_config);
+    clientsock = ap_get_conn_socket(r->connection);
 
     rv = send_socket(r->pool, sock, clientsock);
     if (rv != APR_SUCCESS) {
index 9d9d582499afd4e8ae49d67c28d19002a6738149..31279b3338e1936cbb1b90b833ec6477dc167519 100644 (file)
@@ -98,7 +98,7 @@ AP_DECLARE(void) ap_lingering_close(conn_rec *c)
     char dummybuf[512];
     apr_size_t nbytes;
     apr_time_t timeup = 0;
-    apr_socket_t *csd = ap_get_core_module_config(c->conn_config);
+    apr_socket_t *csd = ap_get_conn_socket(c);
 
     if (!csd) {
         return;
index c51759e4f86904a49a77d00ae0a5c720961856dd..d416266304a6d582a1b68c1d4a6e82b967cdc882 100644 (file)
@@ -4302,6 +4302,11 @@ AP_DECLARE(void **) ap_get_request_note(request_rec *r, apr_size_t note_num)
     return &(req_cfg->notes[note_num]);
 }
 
+AP_DECLARE(apr_socket_t *) ap_get_conn_socket(conn_rec *c)
+{
+    return ap_get_core_module_config(c->conn_config);
+}
+
 static int core_create_req(request_rec *r)
 {
     /* Alloc the config struct and the array of request notes in
index ef1906aed0d57e10c6f786fb18068641db2bc878..d78290af8fa29e24508694d1aa492efd5c3cd8cb 100644 (file)
@@ -953,7 +953,7 @@ request_rec *ap_read_request(conn_rec *conn)
      * to the normal timeout mode as we fetch the header lines,
      * as necessary.
      */
-    csd = ap_get_core_module_config(conn->conn_config);
+    csd = ap_get_conn_socket(conn);
     apr_socket_timeout_get(csd, &cur_timeout);
     if (cur_timeout != conn->base_server->timeout) {
         apr_socket_timeout_set(csd, conn->base_server->timeout);