--- AnyEvent-HTTP/HTTP.pm	2008/06/05 16:43:45	1.13
+++ AnyEvent-HTTP/HTTP.pm	2008/06/06 10:12:44	1.15
@@ -46,7 +46,7 @@
 
 use base Exporter::;
 
-our $VERSION = '1.0';
+our $VERSION = '1.1';
 
 our @EXPORT = qw(http_get http_request);
 
@@ -61,6 +61,7 @@
 our $MAX_PER_HOST       = 4;
 
 our $PROXY;
+our $ACTIVE = 0;
 
 my %KA_COUNT; # number of open keep-alive connections per host
 my %CO_SLOT;  # number of open connections, and wait queue, per host
@@ -193,8 +194,10 @@
       if (my $cb = shift @{ $CO_SLOT{$host}[1] }) {
          # somebody wants that slot
          ++$CO_SLOT{$host}[0];
+         ++$ACTIVE;
 
          $cb->(AnyEvent::Util::guard {
+            --$ACTIVE;
             --$CO_SLOT{$host}[0];
             _slot_schedule $host;
          });
@@ -213,7 +216,7 @@
    _slot_schedule $_[0];
 }
 
-sub http_request($$$;@) {
+sub http_request($$@) {
    my $cb = pop;
    my ($method, $url, %arg) = @_;
 
@@ -326,8 +329,9 @@
          # (re-)configure handle
          $state{handle}->timeout ($timeout);
          $state{handle}->on_error (sub {
+            my $errno = "$!";
             %state = ();
-            $cb->(undef, { Status => 599, Reason => "$!" });
+            $cb->(undef, { Status => 599, Reason => $errno });
          });
          $state{handle}->on_eof (sub {
             %state = ();
@@ -445,17 +449,17 @@
    defined wantarray && AnyEvent::Util::guard { %state = () }
 }
 
-sub http_get($$;@) {
+sub http_get($@) {
    unshift @_, "GET";
    &http_request
 }
 
-sub http_head($$;@) {
+sub http_head($@) {
    unshift @_, "HEAD";
    &http_request
 }
 
-sub http_post($$$;@) {
+sub http_post($$@) {
    unshift @_, "POST", "body";
    &http_request
 }
@@ -492,6 +496,12 @@
 
 Not implemented currently.
 
+=item $AnyEvent::HTTP::ACTIVE
+
+The number of active connections. This is not the number of currently
+running requests, but the number of currently open and non-idle TCP
+connections. This number of can be useful for load-leveling.
+
 =back
 
 =cut