check for matches and games counter of TOS version
[brisk.git] / web / Obj / zlibstream.phh
1 <?php
2 class ZLibStream {
3     var $s;
4     var $head;
5     var $type;
6     var $filter;
7
8     function ZLibStream($type)
9     {
10         $this->type = $type;
11         $this->s = array( FALSE, FALSE );
12         $this->filter = FALSE;
13     }
14
15     static function create($type)
16     {
17         if ($type == 'plain')
18             return (FALSE);
19
20         if (($thiz = new ZLibStream($type)) == FALSE)
21             return (FALSE);
22
23         for ($i = 0 ; $i < 2 ; $i++)
24             $thiz->s[$i] = FALSE;
25         if (($thiz->s = stream_socket_pair(STREAM_PF_UNIX, STREAM_SOCK_STREAM, STREAM_IPPROTO_IP)) == FALSE)
26             return (FALSE);
27
28         for ($i = 0 ; $i < 2 ; $i++)
29             stream_set_blocking  ( $thiz->s[$i], 0); // 0 -> not blocking
30         
31         if ($type == 'gzip') {
32             $params = array('level' => 6, 'window' => -15, 'memory' => 9);
33             
34             if (($thiz->filter = stream_filter_append($thiz->s[1], "zlib.deflate", STREAM_FILTER_READ, $params)) == FALSE) {
35                 return (FALSE);
36             }
37             $thiz->head = "\037\213\010\000\000\000\000\000\000\003";
38         }
39         else if ($type  == 'deflate') {
40             if (($thiz->filter = stream_filter_append($thiz->s[1], "zlib.deflate", STREAM_FILTER_READ)) == FALSE) {
41                 return (FALSE);
42             }
43         }
44         return ($thiz);
45     }
46
47     function destroy()
48     {
49         if ($this->filter != FALSE) {
50             stream_filter_remove($this->filter);
51         }
52
53         for ($i = 0 ; $i < 2 ; $i++) {
54             if ($this->s[$i] != FALSE)
55                 fclose($this->s[$i]);
56         }
57     }
58
59         /*
60           too many actors, an explanation is needed to clarify:
61
62           - fwrite: all data MUST be passed to write with success
63           - fflush: probably reduntant
64           - fread: all reads after successfull writes must go well, 
65           
66          */
67     function compress_chunk($s_in)
68     {
69         $s_in_l = mb_strlen($s_in, 'ASCII');
70
71         if ($this->head != FALSE) {
72             $s_out = $this->head;
73             $this->head = FALSE;
74         }
75         else {
76             $s_out = "";
77         }
78
79         for ($to_be_proc = $s_in_l, $max_fail = 0 ; $to_be_proc > 0 && $max_fail < 2 ; $max_fail++) {
80             if ($to_be_proc > 0) {
81                 $max_fail = 0;
82                 if (($ct = fwrite($this->s[0], $s_in)) == FALSE) 
83                     return FALSE;
84                 
85                 $to_be_proc -= $ct;
86             }
87             fflush($this->s[0]); // maybe reduntant but light so ...
88         
89             while (($ret = fread($this->s[1],  8192)) != FALSE) {
90                 $s_out .= $ret;
91             }
92         }
93
94         if ($max_fail < 2)
95             return ($s_out);
96         else
97             return (FALSE);
98     }
99
100     static function compress($enc, $s)
101     {
102         // fprintf(STDERR, "compress: [%s][%s]\n", $enc, $s);
103
104         if ($enc == 'gzip') {
105             return (gzencode($s, -1, FORCE_GZIP));
106         }
107         else if ($enc == 'deflate') {
108             return (gzencode($s, -1, FORCE_DEFLATE));
109         }
110         else
111             return $s;
112     }
113 } // class ZLibStream 
114
115
116
117 function zlibstream_test()
118 {
119     $cont = array( "pippo", "pluto", "paperino");
120
121     for ($f = 0 ; $f < 2 ; $f++) {
122         if (($zls = ZLibStream::create('gzip')) == FALSE) {
123             printf("ZLibStream Creation failed\n");
124             exit(1);
125         }
126         
127         if (($fp = fopen("../../test/zlibstream".$f.".gz", "w")) == FALSE) {
128             printf("ZLibStream test output file failed\n");
129             exit(2);
130         }   
131         
132         for ($i = 0 ; $i < 9 ; $i++) {
133             $idx = $i % 3;
134             
135             $comp = $zls->compress_chunk($cont[$idx]);
136             
137             fwrite($fp, $comp);
138             fflush($fp);
139             sleep(3);
140         }
141         fclose($fp);
142         $zls->destroy();
143     }
144 }
145
146 // zlibstream_test();
147
148 ?>