Fixed possible dataloss on crash during enqueue issue

Author: Tris Forster

Diff for: ConcurrentFIFO.php

@@ -153,13 +153,14 @@ function enqueue($data) {
 			$index = array('start' => self::INDEX_SIZE, 'end' => self::INDEX_SIZE, 'len' => 0);
 		}
 
-		$this->_write_index($index['start'], $index['end'] + $c + self::LENGTH_SIZE, $index['len'] + 1);
 		fseek($this->fp, $index['end']);
 
 		// write length followed by data
 		fwrite($this->fp, pack(self::LENGTH_FORMAT, $c), self::LENGTH_SIZE);
 		fwrite($this->fp, $data, $c);
 
+		$this->_write_index($index['start'], $index['end'] + $c + self::LENGTH_SIZE, $index['len'] + 1);
+
 		//echo "Wrote {$data} at {$index['end']}\n";
 		// release lock
 		flock($this->fp, LOCK_UN);
@@ -307,4 +308,4 @@ function __toString() {
 		return "<FIFO: {$this->filename}>";
 	}
 
-}
+}

Diff for: RedisQueues.php

@@ -1,4 +1,4 @@
-<?
+<?php
 require_once "ConcurrentFIFO.php";
 
 /**

Diff for: bench.php

@@ -1,6 +1,6 @@
 <?php
 
-define('LOOP', 10000);
+define('LOOP', 100000);
 define('TEST_FIFO', 'test.fifo');
 
 include "ConcurrentFIFO.php";

Diff for: tests/RedisTest.php

@@ -33,4 +33,4 @@ function testUsage() {
 		$this->assertSame('test2', $this->redis->rpop('list2'));
 	}
 
-}
+}