WordPress.org

Make WordPress Core

Changeset 8519


Ignore:
Timestamp:
08/01/2008 04:36:50 PM (10 years ago)
Author:
ryan
Message:

Formatting changes and non-blocking mode. Props DD32. see #4779

Location:
trunk/wp-includes
Files:
2 edited

Legend:

Unmodified
Added
Removed
  • trunk/wp-includes/cron.php

    r8516 r8519  
    9191    $cron_url = get_option( 'siteurl' ) . '/wp-cron.php?check=' . wp_hash('187425');
    9292
    93     wp_remote_post($cron_url, array('timeout' => 0.01));
     93    wp_remote_post($cron_url, array('timeout' => 0.01, 'blocking' => false));
    9494}
    9595
  • trunk/wp-includes/http.php

    r8518 r8519  
    116116            'method' => 'GET', 'timeout' => 3,
    117117            'redirection' => 5, 'redirected' => false,
    118             'httpversion' => '1.0'
     118            'httpversion' => '1.0', 'blocking' => true
    119119        );
    120120
     
    262262
    263263        $newheaders = array();
    264         foreach($headers as $tempheader) {
     264        foreach ( $headers as $tempheader ) {
    265265            if ( empty($tempheader) )
    266266                continue;
     
    307307        $defaults = array(
    308308            'method' => 'GET', 'timeout' => 3,
    309             'redirection' => 5, 'httpversion' => '1.0'
     309            'redirection' => 5, 'httpversion' => '1.0',
     310            'blocking' => true
    310311        );
    311312
     
    324325                $arrURL['port'] = apply_filters('http_request_default_port', 443);
    325326                $secure_transport = true;
     327            } else {
     328                $arrURL['port'] = apply_filters('http_request_default_port', 80);
    326329            }
    327             else
    328                 $arrURL['port'] = apply_filters('http_request_default_port', 80);
     330        } else {
     331            $arrURL['port'] = apply_filters('http_request_port', $arrURL['port']);
    329332        }
    330         else
    331             $arrURL['port'] = apply_filters('http_request_port', $arrURL['port']);
    332333
    333334        if ( true === $secure_transport )
     
    336337        $handle = fsockopen($arrURL['host'], $arrURL['port'], $iError, $strError, apply_filters('http_request_timeout', absint($r['timeout']) ) );
    337338
    338         if ( false === $handle ) {
     339        if ( false === $handle )
    339340            return new WP_Error('http_request_failed', $iError . ': ' . $strError);
    340         }
    341341
    342342        $requestPath = $arrURL['path'] . ( isset($arrURL['query']) ? '?' . $arrURL['query'] : '' );
    343         $requestPath = (empty($requestPath)) ? '/' : $requestPath;
     343        $requestPath = empty($requestPath) ? '/' : $requestPath;
    344344
    345345        $strHeaders = '';
     
    348348
    349349        if ( is_array($header) ) {
    350             foreach( (array) $this->getHeaders() as $header => $headerValue)
     350            foreach ( (array) $this->getHeaders() as $header => $headerValue )
    351351                $strHeaders .= $header . ': ' . $headerValue . "\r\n";
    352         } else
     352        } else {
    353353            $strHeaders .= $header;
     354        }
    354355
    355356        $strHeaders .= "\r\n";
     
    359360
    360361        fwrite($handle, $strHeaders);
     362
     363        if ( ! $r['blocking'] )
     364            return array( 'headers' => array(), 'body' => '', 'response' => array() );
    361365
    362366        $strResponse = '';
     
    431435        $defaults = array(
    432436            'method' => 'GET', 'timeout' => 3,
    433             'redirection' => 5, 'httpversion' => '1.0'
     437            'redirection' => 5, 'httpversion' => '1.0',
     438            'blocking' => true
    434439        );
    435440
     
    448453        if ( function_exists('stream_set_timeout') )
    449454            stream_set_timeout($handle, apply_filters('http_request_timeout', $r['timeout']) );
     455
     456        if ( ! $r['blocking'] )
     457            return array( 'headers' => array(), 'body' => '', 'response' => array() );
    450458
    451459        $strResponse = '';
     
    508516        $defaults = array(
    509517            'method' => 'GET', 'timeout' => 3,
    510             'redirection' => 5, 'httpversion' => '1.0'
     518            'redirection' => 5, 'httpversion' => '1.0',
     519            'blocking' => true
    511520        );
    512521
     
    537546        stream_set_timeout($handle, apply_filters('http_request_stream_timeout', $this->timeout) );
    538547
    539         if (! $handle)
     548        if ( ! $handle)
    540549            return new WP_Error('http_request_failed', sprintf(__('Could not open handle for fopen() to %s'), $url));
     550
     551        if ( ! $r['blocking'] )
     552            return array( 'headers' => array(), 'body' => '', 'response' => array() );
    541553
    542554        $strResponse = stream_get_contents($handle);
     
    575587 *
    576588 * Last ditch effort to retrieve the URL before complete failure.
     589 * Does not support non-blocking requests.
    577590 *
    578591 * @package WordPress
     
    599612            'method' => 'GET', 'timeout' => 3,
    600613            'redirection' => 5, 'httpversion' => '1.0',
    601             'user_agent' => apply_filters('http_headers_useragent', 'WordPress/' . $wp_version)
     614            'blocking' => true, 'user_agent' => apply_filters('http_headers_useragent', 'WordPress/' . $wp_version)
    602615        );
    603616
Note: See TracChangeset for help on using the changeset viewer.