Dominique.Fournier/DomFramework
1
0
Fork 0
Code Issues Pull Requests Projects Releases Activity

Change all the "new class" by "new Class"

Browse Source
This commit is contained in:
Dominique Fournier
2021-05-07 13:10:37 +02:00
parent c8d275be31
commit c09fa961cd
39 changed files with 430 additions and 432 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
src/Queuefile.php
View File

@@ -36,7 +36,7 @@ class Queuefile extends Queue
throw new \Exception ("Invalid DSN provided to queuefile : not starting ".
"by file://", 500);
$this->queue = substr ($dsn, 7);
$file = new \file ();
$file = new File ();
if (! $file->file_exists (dirname ($this->queue)))
$file->mkdir (dirname ($this->queue), 0777, true);
if (! $file->file_exists ($this->queue))
@@ -52,7 +52,7 @@ class Queuefile extends Queue
public function add ($entry)
// {{{
{
$file = new \file ();
$file = new File ();
$file->lockEX ($this->queue);
$file->file_put_contents ($this->queue,
json_encode ($entry)."\n", FILE_APPEND);
@@ -68,7 +68,7 @@ class Queuefile extends Queue
public function getAll ($delete =false)
// {{{
{
$file = new \file ();
$file = new File ();
if ($delete)
$file->lockEX ($this->queue);
else
@@ -93,7 +93,7 @@ class Queuefile extends Queue
public function count ()
// {{{
{
$file = new \file ();
$file = new File ();
$file->lockSH ($this->queue);
$content = $file->file_get_contents ($this->queue);
$count = substr_count ($content, "\n");
@@ -108,7 +108,7 @@ class Queuefile extends Queue
public function clear ()
// {{{
{
$file = new \file ();
$file = new File ();
$file->lockEX ($this->queue);
$file->file_put_contents ($this->queue, "");
$file->lockUN ($this->queue);
@@ -124,7 +124,7 @@ class Queuefile extends Queue
public function getFirst ($delete = false)
// {{{
{
$file = new \file ();
$file = new File ();
if ($delete)
$file->lockEX ($this->queue);
else
@@ -156,7 +156,7 @@ class Queuefile extends Queue
public function getLast ($delete = false)
// {{{
{
$file = new \file ();
$file = new File ();
if ($delete)
$file->lockEX ($this->queue);
else
@@ -190,7 +190,7 @@ class Queuefile extends Queue
public function getRange ($start, $number, $delete = false)
// {{{
{
$file = new \file ();
$file = new File ();
if ($delete)
$file->lockEX ($this->queue);
else