fuel/fuel/core/classes/redis/db.php
public function execute()
	{
		// open a Redis connection and execute the queued commands
		foreach ($this->queue as $command)
		{
			for ($written = 0; $written < strlen($command); $written += $fwrite)
			{
				$fwrite = fwrite($this->connection, substr($command, $written));
				if ($fwrite === false)
				{
					throw new \RedisException('Failed to write entire command to stream');
				}
			}
		}

		// Read in the results from the pipelined commands
		$responses = array();
		for ($i = 0; $i < count($this->queue); $i++)
		{
			$responses[] = $this->readResponse();
		}

		// Clear the queue and return the response
		$this->queue = array();

		if ($this->pipelined)
		{
			$this->pipelined = false;
			return $responses;
		}
		else
		{
			return $responses[0];
		}
	}
public function execute()
	{
		// open a Redis connection and execute the queued commands
		foreach ($this->queue as $command)
		{
			for ($written = 0; $written < strlen($command); $written += $fwrite)
			{
				$fwrite = fwrite($this->connection, substr($command, $written));
				if ($fwrite === false)
				{
					throw new \RedisException('Failed to write entire command to stream');
				}
			}
		}

		// Read in the results from the pipelined commands
		$responses = array();
		for ($i = 0; $i < count($this->queue); $i++)
		{
			$responses[] = $this->readResponse();
		}

		// Clear the queue and return the response
		$this->queue = array();

		if ($this->pipelined)
		{
			$this->pipelined = false;
			return $responses;
		}
		else
		{
			return $responses[0];
		}
	}
public function execute ( ) { // open a Redis connection and execute the queued commands foreach ( $ this -> queue as $ command ) { for ( $ written = 0 ; $ written < strlen ( $ command ) ; $ written += $ fwrite ) { $ fwrite = fwrite ( $ this -> connection , substr ( $ command , $ written ) ) ; if ( $ fwrite === false ) { throw new \ RedisException ( 'Failed to write entire command to stream' ) ; } } } // Read in the results from the pipelined commands $ responses = array ( ) ; for ( $ i = 0 ; $ i < count ( $ this -> queue ) ; $ i ++ ) { $ responses [ ] = $ this -> readResponse ( ) ; } // Clear the queue and return the response $ this -> queue = array ( ) ; if ( $ this -> pipelined ) { $ this -> pipelined = false ; return $ responses ; } else { return $ responses [ 0 ] ; } }
Flushes the commands in the pipeline queue to Redis and returns the responses.
@see pipeline
Flushes the commands in the pipeline queue to Redis and returns the responses .