@@ -60,7 +60,7 @@ |
||
60 | 60 | $message = json_encode( $message ); |
61 | 61 | } |
62 | 62 | |
63 | - $message = '<' . $facility . '> ' . date( 'Y-m-d H:i:s' ) . ' ' . $priority . ' ' . $message . PHP_EOL; |
|
63 | + $message = '<'.$facility.'> '.date( 'Y-m-d H:i:s' ).' '.$priority.' '.$message.PHP_EOL; |
|
64 | 64 | |
65 | 65 | if( file_put_contents( $this->filename, $message, FILE_APPEND ) === false ) { |
66 | 66 | throw new \Aimeos\MW\Logger\Exception( sprintf( 'Unable to write to file "%1$s', $this->filename ) ); |
@@ -92,9 +92,12 @@ |
||
92 | 92 | } |
93 | 93 | catch( \PDOException $e ) |
94 | 94 | { |
95 | - try { |
|
95 | + try |
|
96 | + { |
|
96 | 97 | $result = $this->reconnect( $e )->exec(); |
97 | - } catch( \PDOException $e ) { |
|
98 | + } |
|
99 | + catch( \PDOException $e ) |
|
100 | + { |
|
98 | 101 | throw new \Aimeos\MW\DB\Exception( $e->getMessage(), $e->getCode() ); |
99 | 102 | } |
100 | 103 | } |
@@ -65,9 +65,12 @@ |
||
65 | 65 | } |
66 | 66 | catch( \PDOException $e ) |
67 | 67 | { |
68 | - try { |
|
68 | + try |
|
69 | + { |
|
69 | 70 | $stmt = $this->reconnect( $e )->exec(); |
70 | - } catch( \PDOException $e ) { |
|
71 | + } |
|
72 | + catch( \PDOException $e ) |
|
73 | + { |
|
71 | 74 | throw new \Aimeos\MW\DB\Exception( $e->getMessage(), $e->getCode(), $e->errorInfo ); |
72 | 75 | } |
73 | 76 | } |
@@ -91,9 +91,12 @@ |
||
91 | 91 | } |
92 | 92 | catch( \Doctrine\DBAL\DBALException $e ) |
93 | 93 | { |
94 | - try { |
|
94 | + try |
|
95 | + { |
|
95 | 96 | $result = $this->reconnect( $e )->exec(); |
96 | - } catch( \Doctrine\DBAL\DBALException $e ) { |
|
97 | + } |
|
98 | + catch( \Doctrine\DBAL\DBALException $e ) |
|
99 | + { |
|
97 | 100 | throw new \Aimeos\MW\DB\Exception( $e->getMessage(), $e->getCode() ); |
98 | 101 | } |
99 | 102 | } |
@@ -64,9 +64,12 @@ |
||
64 | 64 | } |
65 | 65 | catch( \Doctrine\DBAL\DBALException $e ) |
66 | 66 | { |
67 | - try { |
|
67 | + try |
|
68 | + { |
|
68 | 69 | $stmt = $this->reconnect( $e )->exec(); |
69 | - } catch( \Doctrine\DBAL\DBALException $e ) { |
|
70 | + } |
|
71 | + catch( \Doctrine\DBAL\DBALException $e ) |
|
72 | + { |
|
70 | 73 | throw new \Aimeos\MW\DB\Exception( $e->getMessage(), $e->getCode() ); |
71 | 74 | } |
72 | 75 | } |
@@ -174,7 +174,7 @@ discard block |
||
174 | 174 | $num++; |
175 | 175 | } |
176 | 176 | |
177 | - $this->status( $num > 0 ? $num . '/' . $total : 'OK' ); |
|
177 | + $this->status( $num > 0 ? $num.'/'.$total : 'OK' ); |
|
178 | 178 | } |
179 | 179 | |
180 | 180 | |
@@ -211,7 +211,7 @@ discard block |
||
211 | 211 | $num++; |
212 | 212 | } |
213 | 213 | |
214 | - $this->status( $num > 0 ? $num . '/' . $total : 'OK' ); |
|
214 | + $this->status( $num > 0 ? $num.'/'.$total : 'OK' ); |
|
215 | 215 | } |
216 | 216 | |
217 | 217 |
@@ -240,9 +240,13 @@ |
||
240 | 240 | $localeItem->setPosition( $dataset['pos'] ); |
241 | 241 | $localeItem->setStatus( $dataset['status'] ); |
242 | 242 | |
243 | - try { |
|
243 | + try |
|
244 | + { |
|
244 | 245 | $localeItemManager->saveItem( $localeItem ); |
245 | - } catch( \Exception $e ) {; } // if locale combination was already available |
|
246 | + } |
|
247 | + catch( \Exception $e ) |
|
248 | + { |
|
249 | +; } // if locale combination was already available |
|
246 | 250 | } |
247 | 251 | |
248 | 252 | $this->status( 'done' ); |
@@ -45,7 +45,9 @@ discard block |
||
45 | 45 | |
46 | 46 | public function testStart() |
47 | 47 | { |
48 | - $fcn = function() {}; |
|
48 | + $fcn = function() |
|
49 | + { |
|
50 | +}; |
|
49 | 51 | |
50 | 52 | $this->stub->expects( $this->once() )->method( 'isAvailable' ) |
51 | 53 | ->will( $this->returnValue( true ) ); |
@@ -58,7 +60,9 @@ discard block |
||
58 | 60 | |
59 | 61 | public function testStartNotAvailable() |
60 | 62 | { |
61 | - $fcn = function() {}; |
|
63 | + $fcn = function() |
|
64 | + { |
|
65 | +}; |
|
62 | 66 | |
63 | 67 | $this->stub->expects( $this->once() )->method( 'isAvailable' ) |
64 | 68 | ->will( $this->returnValue( false ) ); |
@@ -71,7 +75,9 @@ discard block |
||
71 | 75 | |
72 | 76 | public function testWait() |
73 | 77 | { |
74 | - $fcn = function() {}; |
|
78 | + $fcn = function() |
|
79 | + { |
|
80 | +}; |
|
75 | 81 | |
76 | 82 | $this->stub->expects( $this->once() )->method( 'isAvailable' ) |
77 | 83 | ->will( $this->returnValue( true ) ); |
@@ -84,7 +90,9 @@ discard block |
||
84 | 90 | |
85 | 91 | public function testWaitNotAvailable() |
86 | 92 | { |
87 | - $fcn = function() {}; |
|
93 | + $fcn = function() |
|
94 | + { |
|
95 | +}; |
|
88 | 96 | |
89 | 97 | $this->stub->expects( $this->once() )->method( 'isAvailable' ) |
90 | 98 | ->will( $this->returnValue( false ) ); |
@@ -84,7 +84,7 @@ |
||
84 | 84 | * @param \Closure $fcn Anonymous function to execute |
85 | 85 | * @param array $data List of parameters that is passed to the closure function |
86 | 86 | * @param boolean $restart True if the task should be restarted if it fails (only once) |
87 | - * @return \Aimeos\MW\Process\Iface Self object for method chaining |
|
87 | + * @return null|Pcntl Self object for method chaining |
|
88 | 88 | * @throws \Aimeos\MW\Process\Exception If starting the new task failed |
89 | 89 | */ |
90 | 90 | public function start( \Closure $fcn, array $data, $restart = false ) |
@@ -51,7 +51,7 @@ discard block |
||
51 | 51 | }; |
52 | 52 | |
53 | 53 | if( pcntl_signal( SIGTERM, $handler ) === false ) { |
54 | - throw new Exception( 'Unable to install signal handler: ' . pcntl_strerror( pcntl_get_last_error() ) ); |
|
54 | + throw new Exception( 'Unable to install signal handler: '.pcntl_strerror( pcntl_get_last_error() ) ); |
|
55 | 55 | } |
56 | 56 | } |
57 | 57 | } |
@@ -104,7 +104,7 @@ discard block |
||
104 | 104 | flush(); // flush all pending output so it's not printed in childs again |
105 | 105 | |
106 | 106 | if( ( $pid = pcntl_fork() ) === -1 ) { |
107 | - throw new Exception( 'Unable to fork new process: ' . pcntl_strerror( pcntl_get_last_error() ) ); |
|
107 | + throw new Exception( 'Unable to fork new process: '.pcntl_strerror( pcntl_get_last_error() ) ); |
|
108 | 108 | } |
109 | 109 | |
110 | 110 | if( $pid === 0 ) { // child process |
@@ -187,7 +187,7 @@ discard block |
||
187 | 187 | $status = -1; |
188 | 188 | |
189 | 189 | if( ( $pid = pcntl_wait( $status ) ) === -1 ) { |
190 | - throw new Exception( 'Unable to wait for child process: ' . pcntl_strerror( pcntl_get_last_error() ) ); |
|
190 | + throw new Exception( 'Unable to wait for child process: '.pcntl_strerror( pcntl_get_last_error() ) ); |
|
191 | 191 | } |
192 | 192 | |
193 | 193 | list( $fcn, $data, $restart ) = $this->list[$pid]; |
@@ -162,7 +162,7 @@ discard block |
||
162 | 162 | * Returns the message queue manager object. |
163 | 163 | * |
164 | 164 | * @return \Aimeos\MW\MQueue\Manager\Iface Message queue manager object |
165 | - */ |
|
165 | + */ |
|
166 | 166 | public function getMessageQueueManager(); |
167 | 167 | |
168 | 168 | /** |
@@ -186,7 +186,7 @@ discard block |
||
186 | 186 | * Returns the process object. |
187 | 187 | * |
188 | 188 | * @return \Aimeos\MW\Process\Iface Process object |
189 | - */ |
|
189 | + */ |
|
190 | 190 | public function getProcess(); |
191 | 191 | |
192 | 192 | /** |
@@ -201,7 +201,7 @@ discard block |
||
201 | 201 | * Returns the session object. |
202 | 202 | * |
203 | 203 | * @return \Aimeos\MW\Session\Iface Session object |
204 | - */ |
|
204 | + */ |
|
205 | 205 | public function getSession(); |
206 | 206 | |
207 | 207 | /** |
@@ -86,6 +86,7 @@ |
||
86 | 86 | * Sets the current date and time |
87 | 87 | * |
88 | 88 | * @param string $datetime Date and time as ISO string (YYYY-MM-DD HH:mm:ss) |
89 | + * @return Standard |
|
89 | 90 | */ |
90 | 91 | public function setDateTime( $datetime ); |
91 | 92 |