mpyw / co

examples/localhost/server.php

Doc Comments +9 added lines

@@ -12,6 +12,10 @@ 
         throw new \RuntimeException($error['message']);
     }
 }
+/**
+ * @param integer $status
+ * @param string $message
+ */
 function respond_rest($con, $status, $message, $content) {
     try {
         $length = strlen($content);
@@ -24,6 +28,11 @@ 
     }
     fclose($con);
 }
+/**
+ * @param Closure $tick_function
+ * @param integer $tick
+ * @param integer $times
+ */
 function respond_streaming($con, $tick_function, $tick, $times) {
     try {
         fsend($con, "HTTP/1.1 200 OK\r\n");

Braces +6 added lines, -3 removed lines

@@ -55,8 +55,9 @@ 
         $con = @stream_socket_accept($socket, -1);
         if (!$con) {
             $err = error_get_last(); // どーなんだこれ strerror(EINTR)
-            if (strpos($err["message"], "Interrupted system call") !== false)
-                continue;
+            if (strpos($err["message"], "Interrupted system call") !== false) {
+                            continue;
+            }
             fwrite(STDERR, "[Server] " . $err["message"] . "\n");
             exit(1);
         }
@@ -91,7 +92,9 @@ 
         parse_str(isset($parsed['query']) ? $parsed['query'] : '', $q);
         foreach ($endpoints as $endpoint => $action) {
             if ($parsed['path'] === $endpoint || $endpoint === '') {
-                if ($endpoint === '') $endpoint = '[Undefined]';
+                if ($endpoint === '') {
+                    $endpoint = '[Undefined]';
+                }
                 fwrite(STDERR, "Request: $parts[1]\n");
                 $action($con, $q);
                 exit(0);

src/Co.php

Braces +3 added lines, -1 removed lines

@@ -323,8 +323,10 @@
             // NOTE: DO NOT call curl_multi_remove_handle
             //       or curl_multi_add_handle while looping curl_multi_info_read!
             $entries = array();
-            do if ($entry = curl_multi_info_read($this->mh, $remains)) {
+            do {
+                if ($entry = curl_multi_info_read($this->mh, $remains)) {
                 $entries[] = $entry;
+            }
             } while ($remains);
             // Remove done and consume queue.
             foreach ($entries as $entry) {