1 /*
2 +----------------------------------------------------------------------+
3 | PHP Version 7 |
4 +----------------------------------------------------------------------+
5 | Copyright (c) 1997-2018 The PHP Group |
6 +----------------------------------------------------------------------+
7 | This source file is subject to version 3.01 of the PHP license, |
8 | that is bundled with this package in the file LICENSE, and is |
9 | available through the world-wide-web at the following url: |
10 | http://www.php.net/license/3_01.txt |
11 | If you did not receive a copy of the PHP license and are unable to |
12 | obtain it through the world-wide-web, please send a note to |
13 | license@php.net so we can mail you a copy immediately. |
14 +----------------------------------------------------------------------+
15 | Authors: Rasmus Lerdorf <rasmus@php.net> |
16 | Jim Winstead <jimw@php.net> |
17 | Hartmut Holzgraefe <hholzgra@php.net> |
18 +----------------------------------------------------------------------+
19 */
20 /* $Id$ */
21
22 #include <stdio.h>
23 #include <stdlib.h>
24 #if HAVE_UNISTD_H
25 #include <unistd.h>
26 #endif
27
28 #include "php.h"
29 #include "php_globals.h"
30 #include "php_standard.h"
31 #include "php_fopen_wrappers.h"
32 #include "SAPI.h"
33
php_stream_output_write(php_stream * stream,const char * buf,size_t count)34 static size_t php_stream_output_write(php_stream *stream, const char *buf, size_t count) /* {{{ */
35 {
36 PHPWRITE(buf, count);
37 return count;
38 }
39 /* }}} */
40
php_stream_output_read(php_stream * stream,char * buf,size_t count)41 static size_t php_stream_output_read(php_stream *stream, char *buf, size_t count) /* {{{ */
42 {
43 stream->eof = 1;
44 return 0;
45 }
46 /* }}} */
47
php_stream_output_close(php_stream * stream,int close_handle)48 static int php_stream_output_close(php_stream *stream, int close_handle) /* {{{ */
49 {
50 return 0;
51 }
52 /* }}} */
53
54 php_stream_ops php_stream_output_ops = {
55 php_stream_output_write,
56 php_stream_output_read,
57 php_stream_output_close,
58 NULL, /* flush */
59 "Output",
60 NULL, /* seek */
61 NULL, /* cast */
62 NULL, /* stat */
63 NULL /* set_option */
64 };
65
66 typedef struct php_stream_input { /* {{{ */
67 php_stream *body;
68 zend_off_t position;
69 } php_stream_input_t;
70 /* }}} */
71
php_stream_input_write(php_stream * stream,const char * buf,size_t count)72 static size_t php_stream_input_write(php_stream *stream, const char *buf, size_t count) /* {{{ */
73 {
74 return -1;
75 }
76 /* }}} */
77
php_stream_input_read(php_stream * stream,char * buf,size_t count)78 static size_t php_stream_input_read(php_stream *stream, char *buf, size_t count) /* {{{ */
79 {
80 php_stream_input_t *input = stream->abstract;
81 size_t read;
82
83 if (!SG(post_read) && SG(read_post_bytes) < (int64_t)(input->position + count)) {
84 /* read requested data from SAPI */
85 size_t read_bytes = sapi_read_post_block(buf, count);
86
87 if (read_bytes > 0) {
88 php_stream_seek(input->body, 0, SEEK_END);
89 php_stream_write(input->body, buf, read_bytes);
90 }
91 }
92
93 if (!input->body->readfilters.head) {
94 /* If the input stream contains filters, it's not really seekable. The
95 input->position is likely to be wrong for unfiltered data. */
96 php_stream_seek(input->body, input->position, SEEK_SET);
97 }
98 read = php_stream_read(input->body, buf, count);
99
100 if (!read || read == (size_t) -1) {
101 stream->eof = 1;
102 } else {
103 input->position += read;
104 }
105
106 return read;
107 }
108 /* }}} */
109
php_stream_input_close(php_stream * stream,int close_handle)110 static int php_stream_input_close(php_stream *stream, int close_handle) /* {{{ */
111 {
112 efree(stream->abstract);
113 stream->abstract = NULL;
114
115 return 0;
116 }
117 /* }}} */
118
php_stream_input_flush(php_stream * stream)119 static int php_stream_input_flush(php_stream *stream) /* {{{ */
120 {
121 return -1;
122 }
123 /* }}} */
124
php_stream_input_seek(php_stream * stream,zend_off_t offset,int whence,zend_off_t * newoffset)125 static int php_stream_input_seek(php_stream *stream, zend_off_t offset, int whence, zend_off_t *newoffset) /* {{{ */
126 {
127 php_stream_input_t *input = stream->abstract;
128
129 if (input->body) {
130 int sought = php_stream_seek(input->body, offset, whence);
131 *newoffset = (input->body)->position;
132 return sought;
133 }
134
135 return -1;
136 }
137 /* }}} */
138
139 php_stream_ops php_stream_input_ops = {
140 php_stream_input_write,
141 php_stream_input_read,
142 php_stream_input_close,
143 php_stream_input_flush,
144 "Input",
145 php_stream_input_seek,
146 NULL, /* cast */
147 NULL, /* stat */
148 NULL /* set_option */
149 };
150
php_stream_apply_filter_list(php_stream * stream,char * filterlist,int read_chain,int write_chain)151 static void php_stream_apply_filter_list(php_stream *stream, char *filterlist, int read_chain, int write_chain) /* {{{ */
152 {
153 char *p, *token = NULL;
154 php_stream_filter *temp_filter;
155
156 p = php_strtok_r(filterlist, "|", &token);
157 while (p) {
158 php_url_decode(p, strlen(p));
159 if (read_chain) {
160 if ((temp_filter = php_stream_filter_create(p, NULL, php_stream_is_persistent(stream)))) {
161 php_stream_filter_append(&stream->readfilters, temp_filter);
162 } else {
163 php_error_docref(NULL, E_WARNING, "Unable to create filter (%s)", p);
164 }
165 }
166 if (write_chain) {
167 if ((temp_filter = php_stream_filter_create(p, NULL, php_stream_is_persistent(stream)))) {
168 php_stream_filter_append(&stream->writefilters, temp_filter);
169 } else {
170 php_error_docref(NULL, E_WARNING, "Unable to create filter (%s)", p);
171 }
172 }
173 p = php_strtok_r(NULL, "|", &token);
174 }
175 }
176 /* }}} */
177
php_stream_url_wrap_php(php_stream_wrapper * wrapper,const char * path,const char * mode,int options,zend_string ** opened_path,php_stream_context * context STREAMS_DC)178 php_stream * php_stream_url_wrap_php(php_stream_wrapper *wrapper, const char *path, const char *mode, int options,
179 zend_string **opened_path, php_stream_context *context STREAMS_DC) /* {{{ */
180 {
181 int fd = -1;
182 int mode_rw = 0;
183 php_stream * stream = NULL;
184 char *p, *token, *pathdup;
185 zend_long max_memory;
186 FILE *file = NULL;
187 #ifdef PHP_WIN32
188 int pipe_requested = 0;
189 #endif
190
191 if (!strncasecmp(path, "php://", 6)) {
192 path += 6;
193 }
194
195 if (!strncasecmp(path, "temp", 4)) {
196 path += 4;
197 max_memory = PHP_STREAM_MAX_MEM;
198 if (!strncasecmp(path, "/maxmemory:", 11)) {
199 path += 11;
200 max_memory = ZEND_STRTOL(path, NULL, 10);
201 if (max_memory < 0) {
202 zend_throw_error(NULL, "Max memory must be >= 0");
203 return NULL;
204 }
205 }
206 if (strpbrk(mode, "wa+")) {
207 mode_rw = TEMP_STREAM_DEFAULT;
208 } else {
209 mode_rw = TEMP_STREAM_READONLY;
210 }
211 return php_stream_temp_create(mode_rw, max_memory);
212 }
213
214 if (!strcasecmp(path, "memory")) {
215 if (strpbrk(mode, "wa+")) {
216 mode_rw = TEMP_STREAM_DEFAULT;
217 } else {
218 mode_rw = TEMP_STREAM_READONLY;
219 }
220 return php_stream_memory_create(mode_rw);
221 }
222
223 if (!strcasecmp(path, "output")) {
224 return php_stream_alloc(&php_stream_output_ops, NULL, 0, "wb");
225 }
226
227 if (!strcasecmp(path, "input")) {
228 php_stream_input_t *input;
229
230 if ((options & STREAM_OPEN_FOR_INCLUDE) && !PG(allow_url_include) ) {
231 if (options & REPORT_ERRORS) {
232 php_error_docref(NULL, E_WARNING, "URL file-access is disabled in the server configuration");
233 }
234 return NULL;
235 }
236
237 input = ecalloc(1, sizeof(*input));
238 if ((input->body = SG(request_info).request_body)) {
239 php_stream_rewind(input->body);
240 } else {
241 input->body = php_stream_temp_create_ex(TEMP_STREAM_DEFAULT, SAPI_POST_BLOCK_SIZE, PG(upload_tmp_dir));
242 SG(request_info).request_body = input->body;
243 }
244
245 return php_stream_alloc(&php_stream_input_ops, input, 0, "rb");
246 }
247
248 if (!strcasecmp(path, "stdin")) {
249 if ((options & STREAM_OPEN_FOR_INCLUDE) && !PG(allow_url_include) ) {
250 if (options & REPORT_ERRORS) {
251 php_error_docref(NULL, E_WARNING, "URL file-access is disabled in the server configuration");
252 }
253 return NULL;
254 }
255 if (!strcmp(sapi_module.name, "cli")) {
256 static int cli_in = 0;
257 fd = STDIN_FILENO;
258 if (cli_in) {
259 fd = dup(fd);
260 } else {
261 cli_in = 1;
262 file = stdin;
263 }
264 } else {
265 fd = dup(STDIN_FILENO);
266 }
267 #ifdef PHP_WIN32
268 pipe_requested = 1;
269 #endif
270 } else if (!strcasecmp(path, "stdout")) {
271 if (!strcmp(sapi_module.name, "cli")) {
272 static int cli_out = 0;
273 fd = STDOUT_FILENO;
274 if (cli_out++) {
275 fd = dup(fd);
276 } else {
277 cli_out = 1;
278 file = stdout;
279 }
280 } else {
281 fd = dup(STDOUT_FILENO);
282 }
283 #ifdef PHP_WIN32
284 pipe_requested = 1;
285 #endif
286 } else if (!strcasecmp(path, "stderr")) {
287 if (!strcmp(sapi_module.name, "cli")) {
288 static int cli_err = 0;
289 fd = STDERR_FILENO;
290 if (cli_err++) {
291 fd = dup(fd);
292 } else {
293 cli_err = 1;
294 file = stderr;
295 }
296 } else {
297 fd = dup(STDERR_FILENO);
298 }
299 #ifdef PHP_WIN32
300 pipe_requested = 1;
301 #endif
302 } else if (!strncasecmp(path, "fd/", 3)) {
303 const char *start;
304 char *end;
305 zend_long fildes_ori;
306 int dtablesize;
307
308 if (strcmp(sapi_module.name, "cli")) {
309 if (options & REPORT_ERRORS) {
310 php_error_docref(NULL, E_WARNING, "Direct access to file descriptors is only available from command-line PHP");
311 }
312 return NULL;
313 }
314
315 if ((options & STREAM_OPEN_FOR_INCLUDE) && !PG(allow_url_include) ) {
316 if (options & REPORT_ERRORS) {
317 php_error_docref(NULL, E_WARNING, "URL file-access is disabled in the server configuration");
318 }
319 return NULL;
320 }
321
322 start = &path[3];
323 fildes_ori = ZEND_STRTOL(start, &end, 10);
324 if (end == start || *end != '\0') {
325 php_stream_wrapper_log_error(wrapper, options,
326 "php://fd/ stream must be specified in the form php://fd/<orig fd>");
327 return NULL;
328 }
329
330 #if HAVE_UNISTD_H
331 dtablesize = getdtablesize();
332 #else
333 dtablesize = INT_MAX;
334 #endif
335
336 if (fildes_ori < 0 || fildes_ori >= dtablesize) {
337 php_stream_wrapper_log_error(wrapper, options,
338 "The file descriptors must be non-negative numbers smaller than %d", dtablesize);
339 return NULL;
340 }
341
342 fd = dup((int)fildes_ori);
343 if (fd == -1) {
344 php_stream_wrapper_log_error(wrapper, options,
345 "Error duping file descriptor " ZEND_LONG_FMT "; possibly it doesn't exist: "
346 "[%d]: %s", fildes_ori, errno, strerror(errno));
347 return NULL;
348 }
349 } else if (!strncasecmp(path, "filter/", 7)) {
350 /* Save time/memory when chain isn't specified */
351 if (strchr(mode, 'r') || strchr(mode, '+')) {
352 mode_rw |= PHP_STREAM_FILTER_READ;
353 }
354 if (strchr(mode, 'w') || strchr(mode, '+') || strchr(mode, 'a')) {
355 mode_rw |= PHP_STREAM_FILTER_WRITE;
356 }
357 pathdup = estrndup(path + 6, strlen(path + 6));
358 p = strstr(pathdup, "/resource=");
359 if (!p) {
360 zend_throw_error(NULL, "No URL resource specified");
361 efree(pathdup);
362 return NULL;
363 }
364
365 if (!(stream = php_stream_open_wrapper(p + 10, mode, options, opened_path))) {
366 efree(pathdup);
367 return NULL;
368 }
369
370 *p = '\0';
371
372 p = php_strtok_r(pathdup + 1, "/", &token);
373 while (p) {
374 if (!strncasecmp(p, "read=", 5)) {
375 php_stream_apply_filter_list(stream, p + 5, 1, 0);
376 } else if (!strncasecmp(p, "write=", 6)) {
377 php_stream_apply_filter_list(stream, p + 6, 0, 1);
378 } else {
379 php_stream_apply_filter_list(stream, p, mode_rw & PHP_STREAM_FILTER_READ, mode_rw & PHP_STREAM_FILTER_WRITE);
380 }
381 p = php_strtok_r(NULL, "/", &token);
382 }
383 efree(pathdup);
384
385 return stream;
386 } else {
387 /* invalid php://thingy */
388 php_error_docref(NULL, E_WARNING, "Invalid php:// URL specified");
389 return NULL;
390 }
391
392 /* must be stdin, stderr or stdout */
393 if (fd == -1) {
394 /* failed to dup */
395 return NULL;
396 }
397
398 #if defined(S_IFSOCK) && !defined(WIN32) && !defined(__BEOS__)
399 do {
400 zend_stat_t st;
401 memset(&st, 0, sizeof(st));
402 if (zend_fstat(fd, &st) == 0 && (st.st_mode & S_IFMT) == S_IFSOCK) {
403 stream = php_stream_sock_open_from_socket(fd, NULL);
404 if (stream) {
405 stream->ops = &php_stream_socket_ops;
406 return stream;
407 }
408 }
409 } while (0);
410 #endif
411
412 if (file) {
413 stream = php_stream_fopen_from_file(file, mode);
414 } else {
415 stream = php_stream_fopen_from_fd(fd, mode, NULL);
416 if (stream == NULL) {
417 close(fd);
418 }
419 }
420
421 #ifdef PHP_WIN32
422 if (pipe_requested && stream && context) {
423 zval *blocking_pipes = php_stream_context_get_option(context, "pipe", "blocking");
424 if (blocking_pipes) {
425 convert_to_long(blocking_pipes);
426 php_stream_set_option(stream, PHP_STREAM_OPTION_PIPE_BLOCKING, Z_LVAL_P(blocking_pipes), NULL);
427 }
428 }
429 #endif
430 return stream;
431 }
432 /* }}} */
433
434 static php_stream_wrapper_ops php_stdio_wops = {
435 php_stream_url_wrap_php,
436 NULL, /* close */
437 NULL, /* fstat */
438 NULL, /* stat */
439 NULL, /* opendir */
440 "PHP",
441 NULL, /* unlink */
442 NULL, /* rename */
443 NULL, /* mkdir */
444 NULL, /* rmdir */
445 NULL
446 };
447
448 PHPAPI php_stream_wrapper php_stream_php_wrapper = {
449 &php_stdio_wops,
450 NULL,
451 0, /* is_url */
452 };
453
454
455 /*
456 * Local variables:
457 * tab-width: 4
458 * c-basic-offset: 4
459 * End:
460 * vim600: sw=4 ts=4 fdm=marker
461 * vim<600: sw=4 ts=4
462 */
463
