function advagg_async_send_http_request

Perform an HTTP request; does not wait for reply & you never will get it back.

Parameters

$fp: (optional) A file pointer.

$request: (optional) A string containing the request headers to send to the server.

$timeout: (optional) An integer holding the stream timeout value.

Return value

bool TRUE if function worked as planed.

See also

drupal_http_request()

This is a flexible and powerful HTTP client implementation. Correctly handles GET, POST, PUT or any other HTTP requests.

3 calls to advagg_async_send_http_request()

advagg_async_connect_http_request in ./advagg.module

Perform an HTTP request; does not wait for reply & you will never get it back.

advagg_install_test_async_stream in ./advagg.install

Test if STREAM_CLIENT_ASYNC_CONNECT can be used.

advagg_process_html in ./advagg.module

Implements hook_process_html().

File

./advagg.module, line 2975

Code

function advagg_async_send_http_request($fp = NULL, $request = '', $timeout = 30) {
    static $requests = array();
    static $registered = FALSE;
    // Store data in a static, and register a shutdown function.
    $args = array(
        $fp,
        $request,
        $timeout,
    );
    if (!empty($fp)) {
        $requests[] = $args;
        if (!$registered) {
            register_shutdown_function(__FUNCTION__);
            $registered = TRUE;
        }
        return TRUE;
    }
    // Shutdown function run.
    if (empty($requests)) {
        return FALSE;
    }
    $streams = array();
    foreach ($requests as $id => $values) {
        list($fp, $request, $timeout) = $values;
        $streams[$id] = $fp;
    }
    $retry_count = 2;
    // Run the loop as long as we have a stream to write to.
    while (!empty($streams)) {
        // Set the read and write vars to the streams var.
        $read = $write = $streams;
        $except = array();
        // Do some voodoo and open all streams at once.
        $n = @stream_select($read, $write, $except, $timeout);
        // We have some streams to write to.
        if (!empty($n)) {
            // Write to each stream if it is available.
            foreach ($write as $id => $w) {
                fwrite($w, $requests[$id][1]);
                fclose($w);
                unset($streams[$id]);
            }
        }
        elseif (!empty($retry_count)) {
            $retry_count--;
        }
        else {
            break;
        }
    }
    // Free memory.
    $requests = array();
    if ($n !== FALSE && empty($streams)) {
        return TRUE;
    }
    else {
        return FALSE;
    }
}