[Phpfreechat-svn] SF.net SVN: phpfreechat: [1080] branches/pfc-comet/misc/comet-tests/iframe2 /readwrite.php

[<ke...@us...>]

Revision: 1080
          http://phpfreechat.svn.sourceforge.net/phpfreechat/?rev=1080&view=rev
Author:   kerphi
Date:     2007-08-03 09:12:56 -0700 (Fri, 03 Aug 2007)

Log Message:
-----------
testcase script used to know the best method to to multithreaded write on a simple file

Added Paths:
-----------
    branches/pfc-comet/misc/comet-tests/iframe2/readwrite.php

Added: branches/pfc-comet/misc/comet-tests/iframe2/readwrite.php
===================================================================
--- branches/pfc-comet/misc/comet-tests/iframe2/readwrite.php	                        (rev 0)
+++ branches/pfc-comet/misc/comet-tests/iframe2/readwrite.php	2007-08-03 16:12:56 UTC (rev 1080)
@@ -0,0 +1,87 @@
+<?php
+
+$method = 2;
+$msgid_filename = '/tmp/readwrite';
+
+$uid = md5(uniqid(rand(), true));
+$msgid = 0;
+while(1)
+{
+  // improved method to request a msgid
+  if ($method == 1)
+  {
+    clearstatcache();
+    if (file_exists($msgid_filename)) {
+      $fh = fopen($msgid_filename, 'r+');
+      while(1) {
+        if (flock($fh, LOCK_EX)) {
+          $msgid = chop(fread($fh, filesize($msgid_filename)));
+          $msgid++;
+          rewind($fh);
+          fwrite($fh, $msgid);
+          fflush($fh);
+          ftruncate($fh, ftell($fh));
+          flock($fh, LOCK_UN);
+          break;
+        }
+      }
+    }
+    else {
+      $fh = fopen($msgid_filename, 'w+');
+      fwrite($fh, "1");
+      $msgid="1";
+    }
+    fclose($fh);
+  } 
+
+
+  // method used in pfc to request a new msgid
+  if ($method == 2)
+  {
+    $msgid = file_get_contents_flock($msgid_filename);
+    $msgid++;
+    file_put_contents($msgid_filename, $msgid, LOCK_EX);
+  }
+
+  echo "uid=".$uid." ".trim($msgid)."\n";
+  usleep(rand(0,1000)); // a very small pause
+}
+
+
+/**
+ * file_get_contents_flock
+ * define an alternative file_get_contents when this function doesn't exists on the used php version (<4.3.0)
+ */
+
+if (!defined('LOCK_SH')) {
+    define('LOCK_SH', 1);
+}
+
+function file_get_contents_flock($filename, $incpath = false, $resource_context = null)
+{
+    if (false === $fh = fopen($filename, 'rb', $incpath)) {
+        user_error('file_get_contents() failed to open stream: No such file or directory ['.$filename.']',
+            E_USER_WARNING);
+        return false;
+    }
+
+    // Attempt to get a shared (read) lock
+    if (!$flock = flock($fh, LOCK_SH)) {
+      return false;
+    }
+
+    clearstatcache();
+    if ($fsize = filesize($filename)) {
+        $data = fread($fh, $fsize);
+    } else {
+        $data = '';
+        while (!feof($fh)) {
+            $data .= fread($fh, 8192);
+        }
+    }
+
+    fclose($fh);
+    return $data;
+}
+
+?>


This was sent by the SourceForge.net collaborative development platform, the world's largest Open Source development site.