Tweet
60 int php_exec(int type, char *cmd, zval *array, zval *return_value TSRMLS_DC)
61 {
62 FILE *fp;
63 char *buf;
64 int l, pclose_return;
65 char *cmd_p, *b, *d=NULL;
66 php_stream *stream;
67 size_t buflen, bufl = 0;
68 #if PHP_SIGCHILD
69 void (*sig_handler)() = NULL;
70 #endif
71
72 cmd_p = cmd;
73
74 #if PHP_SIGCHILD
75 sig_handler = signal (SIGCHLD, SIG_DFL);
76 #endif
77
78 #ifdef PHP_WIN32
79 fp = VCWD_POPEN(cmd_p, "rb");
80 #else
81 fp = VCWD_POPEN(cmd_p, "r");
82 #endif
83 if (!fp) {
84 php_error_docref(NULL TSRMLS_CC, E_WARNING, "Unable to fork [%s]", cmd);
85 goto err;
86 }
87
88 stream = php_stream_fopen_from_pipe(fp, "rb");
89
90 buf = (char *) emalloc(EXEC_INPUT_BUF);
91 buflen = EXEC_INPUT_BUF;
92
93 if (type != 3) {
94 b = buf;
95
96 while (php_stream_get_line(stream, ZSTR(b), EXEC_INPUT_BUF, &bufl)) {
97 /* no new line found, let's read some more */
98 if (b[bufl - 1] != '\n' && !php_stream_eof(stream)) {
99 if (buflen < (bufl + (b - buf) + EXEC_INPUT_BUF)) {
100 bufl += b - buf;
101 buflen = bufl + EXEC_INPUT_BUF;
102 buf = erealloc(buf, buflen);
103 b = buf + bufl;
104 } else {
105 b += bufl;
106 }
107 continue;
108 } else if (b != buf) {
109 bufl += b - buf;
110 }
111
112 if (type == 1) {
113 PHPWRITE(buf, bufl);
114 sapi_flush(TSRMLS_C);
115 } else if (type == 2) {
116 /* strip trailing whitespaces */
117 l = bufl;
118 while (l-- && isspace(((unsigned char *)buf)[l]));
119 if (l != (bufl - 1)) {
120 bufl = l + 1;
121 buf[bufl] = '\0';
122 }
123 add_next_index_stringl(array, buf, bufl, 1);
124 }
125 b = buf;
126 }
127 if (bufl) {
128 /* strip trailing whitespaces if we have not done so already */
129 if (type != 2) {
130 l = bufl;
131 while (l-- && isspace(((unsigned char *)buf)[l]));
132 if (l != (bufl - 1)) {
133 bufl = l + 1;
134 buf[bufl] = '\0';
135 }
136 }
137
138 /* Return last line from the shell command */
139 RETVAL_STRINGL(buf, bufl, 1);
140 } else { /* should return NULL, but for BC we return "" */
141 RETVAL_EMPTY_STRING();
142 }
143 } else {
144 while((bufl = php_stream_read(stream, buf, EXEC_INPUT_BUF)) > 0) {
145 PHPWRITE(buf, bufl);
146 }
147 }
148
149 pclose_return = php_stream_close(stream);
150 efree(buf);
151
152 done:
153 #if PHP_SIGCHILD
154 if (sig_handler) {
155 signal(SIGCHLD, sig_handler);
156 }
157 #endif
158 if (d) {
159 efree(d);
160 }
161 return pclose_return;
162 err:
163 pclose_return = -1;
164 goto done;
165 }
Kommentar