conncache: keep bundles on host+port bases, not only host names
Previously we counted all connections to a specific host name and that would be used for the CURLMOPT_MAX_HOST_CONNECTIONS check for example, while servers on different port numbers are normally considered different "origins" on the web and should thus be considered different hosts.
This commit is contained in:
@@ -32,6 +32,7 @@
|
|||||||
#include "sendf.h"
|
#include "sendf.h"
|
||||||
#include "rawstr.h"
|
#include "rawstr.h"
|
||||||
#include "conncache.h"
|
#include "conncache.h"
|
||||||
|
#include "curl_printf.h"
|
||||||
|
|
||||||
#include "curl_memory.h"
|
#include "curl_memory.h"
|
||||||
/* The last #include file should be: */
|
/* The last #include file should be: */
|
||||||
@@ -128,28 +129,36 @@ void Curl_conncache_destroy(struct conncache *connc)
|
|||||||
Curl_hash_clean(&connc->hash);
|
Curl_hash_clean(&connc->hash);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/* returns an allocated key to find a bundle for this connection */
|
||||||
|
static char *hashkey(struct connectdata *conn)
|
||||||
|
{
|
||||||
|
return aprintf("%s:%d",
|
||||||
|
conn->bits.proxy?conn->proxy.name:conn->host.name,
|
||||||
|
conn->localport);
|
||||||
|
}
|
||||||
|
|
||||||
/* Look up the bundle with all the connections to the same host this
|
/* Look up the bundle with all the connections to the same host this
|
||||||
connectdata struct is setup to use. */
|
connectdata struct is setup to use. */
|
||||||
struct connectbundle *Curl_conncache_find_bundle(struct connectdata *conn,
|
struct connectbundle *Curl_conncache_find_bundle(struct connectdata *conn,
|
||||||
struct conncache *connc)
|
struct conncache *connc)
|
||||||
{
|
{
|
||||||
struct connectbundle *bundle = NULL;
|
struct connectbundle *bundle = NULL;
|
||||||
|
if(connc) {
|
||||||
char *hostname = conn->bits.proxy?conn->proxy.name:conn->host.name;
|
char *key = hashkey(conn);
|
||||||
|
if(key) {
|
||||||
if(connc)
|
bundle = Curl_hash_pick(&connc->hash, key, strlen(key));
|
||||||
bundle = Curl_hash_pick(&connc->hash, hostname, strlen(hostname)+1);
|
free(key);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
return bundle;
|
return bundle;
|
||||||
}
|
}
|
||||||
|
|
||||||
static bool conncache_add_bundle(struct conncache *connc,
|
static bool conncache_add_bundle(struct conncache *connc,
|
||||||
char *hostname,
|
char *key,
|
||||||
struct connectbundle *bundle)
|
struct connectbundle *bundle)
|
||||||
{
|
{
|
||||||
void *p;
|
void *p = Curl_hash_add(&connc->hash, key, strlen(key), bundle);
|
||||||
|
|
||||||
p = Curl_hash_add(&connc->hash, hostname, strlen(hostname)+1, bundle);
|
|
||||||
|
|
||||||
return p?TRUE:FALSE;
|
return p?TRUE:FALSE;
|
||||||
}
|
}
|
||||||
@@ -188,13 +197,20 @@ CURLcode Curl_conncache_add_conn(struct conncache *connc,
|
|||||||
|
|
||||||
bundle = Curl_conncache_find_bundle(conn, data->state.conn_cache);
|
bundle = Curl_conncache_find_bundle(conn, data->state.conn_cache);
|
||||||
if(!bundle) {
|
if(!bundle) {
|
||||||
char *hostname = conn->bits.proxy?conn->proxy.name:conn->host.name;
|
char *key;
|
||||||
|
int rc;
|
||||||
|
|
||||||
result = bundle_create(data, &new_bundle);
|
result = bundle_create(data, &new_bundle);
|
||||||
if(result)
|
if(result)
|
||||||
return result;
|
return result;
|
||||||
|
|
||||||
if(!conncache_add_bundle(data->state.conn_cache, hostname, new_bundle)) {
|
key = hashkey(conn);
|
||||||
|
if(!key)
|
||||||
|
return CURLE_OUT_OF_MEMORY;
|
||||||
|
|
||||||
|
rc = conncache_add_bundle(data->state.conn_cache, key, new_bundle);
|
||||||
|
free(key);
|
||||||
|
if(!rc) {
|
||||||
bundle_destroy(new_bundle);
|
bundle_destroy(new_bundle);
|
||||||
return CURLE_OUT_OF_MEMORY;
|
return CURLE_OUT_OF_MEMORY;
|
||||||
}
|
}
|
||||||
|
Reference in New Issue
Block a user