protected function Acquia_Search_Service::_makeHttpRequest in Acquia Search 6

3 calls to Acquia_Search_Service::_makeHttpRequest()

Acquia_Search_Service::makeServletRequest in ./Acquia_Search_Service.php

Make a request to a servlet (a path) that's not a standard path.

Acquia_Search_Service::_sendRawGet in ./Acquia_Search_Service.php

Central method for making a get operation against this Solr Server

Acquia_Search_Service::_sendRawPost in ./Acquia_Search_Service.php

Central method for making a post operation against this Solr Server

File

./Acquia_Search_Service.php, line 187

Class

Acquia_Search_Service

Starting point for the Solr API. Represents a Solr server resource and has methods for pinging, adding, deleting, committing, optimizing and searching.

Code

protected function _makeHttpRequest($url, $method = 'GET', $headers = array(), $content = '', $timeout = FALSE) {

  // Set a response timeout
  if ($timeout) {
    $default_socket_timeout = ini_set('default_socket_timeout', $timeout);
  }

  // Gets necessary values from configuration.
  $connect_timeout = variable_get('acquia_search_connect_timeout', '3.0');
  if (FALSE === $timeout) {
    $request_timeout = variable_get('acquia_search_request_timeout', '20.0');
  }
  else {
    $request_timeout = $timeout;
  }
  $ctx = acquia_agent_stream_context_create($url, 'acquia_search');
  if (!$ctx) {
    throw new Exception(t("Could not create stream context"));
  }
  $result = acquia_agent_http_request($ctx, $url, $headers, $method, $content, $request_timeout, $connect_timeout);

  // Restore the response timeout
  if ($timeout) {
    ini_set('default_socket_timeout', $default_socket_timeout);
  }

  // This will no longer be needed after http://drupal.org/node/345591 is committed
  $responses = array(
    -1 => 'Timeout expired',
    0 => 'Request failed',
    100 => 'Continue',
    101 => 'Switching Protocols',
    200 => 'OK',
    201 => 'Created',
    202 => 'Accepted',
    203 => 'Non-Authoritative Information',
    204 => 'No Content',
    205 => 'Reset Content',
    206 => 'Partial Content',
    300 => 'Multiple Choices',
    301 => 'Moved Permanently',
    302 => 'Found',
    303 => 'See Other',
    304 => 'Not Modified',
    305 => 'Use Proxy',
    307 => 'Temporary Redirect',
    400 => 'Bad Request',
    401 => 'Unauthorized',
    402 => 'Payment Required',
    403 => 'Forbidden',
    404 => 'Not Found',
    405 => 'Method Not Allowed',
    406 => 'Not Acceptable',
    407 => 'Proxy Authentication Required',
    408 => 'Request Time-out',
    409 => 'Conflict',
    410 => 'Gone',
    411 => 'Length Required',
    412 => 'Precondition Failed',
    413 => 'Request Entity Too Large',
    414 => 'Request-URI Too Large',
    415 => 'Unsupported Media Type',
    416 => 'Requested range not satisfiable',
    417 => 'Expectation Failed',
    500 => 'Internal Server Error',
    501 => 'Not Implemented',
    502 => 'Bad Gateway',
    503 => 'Service Unavailable',
    504 => 'Gateway Time-out',
    505 => 'HTTP Version not supported',
  );
  if (!isset($result->code) || $result->code < 0) {
    $result->code = 0;
  }
  if (isset($result->error)) {
    $responses[0] .= ': ' . check_plain($result->error);
  }
  if (!isset($result->data)) {
    $result->data = '';
  }
  if (!isset($result->error)) {
    $result->error = '';
  }
  if (!isset($responses[$result->code])) {
    $result->code = floor($result->code / 100) * 100;
  }
  $protocol = "HTTP/1.1";
  $headers[] = "{$protocol} {$result->code} {$responses[$result->code]}. {$result->error}";
  if (isset($result->headers)) {
    foreach ($result->headers as $name => $value) {
      $headers[] = "{$name}: {$value}";
    }
  }
  return array(
    $result->data,
    $headers,
  );
}