WordPress.org

Make WordPress Core

Changeset 8519


Ignore:
Timestamp:
08/01/08 16:36:50 (7 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.