- $content_sz = mb_strlen($content, "LATIN1");
- $hea = headers_render($header_out);
-
- // TODO: FIX THIS PART TO A SPAWN WRITE AS CUEUE.
- printf("OUT: [%d]\n", $content_sz);
- for ($w = 0 ; $w < 10 ; $w++) {
- if (($wret = fwrite($new_socket, $content, $content_sz)) == $content_sz
- || $wret <= 0)
- break;
- printf("wret: [%d]\n", $wret);
- $content = substr($content, $wret, $content_sz - $wret);
- usleep(100000);
+
+ $pgflush = new PageFlush($new_socket, $curtime, 20, $header_out, $content);
+
+ if ($pgflush->try_flush($curtime) == FALSE) {
+ // Add $pgflush to the pgflush array
+ array_push($pages_flush, $pgflush);