#include "config.h"
#endif
#include "php.h"
+#include <ancillary.h>
+
+#include <sys/types.h>
+#include <sys/stat.h>
+#include <fcntl.h>
#define PHP_ANCILLARY_VERSION "1.0"
#define PHP_ANCILLARY_EXTNAME "ancillary"
#define phpext_ancillary_ptr &ancillary_module_entry
// declaration of a custom mop_function()
-PHP_FUNCTION(mop_function);
+PHP_FUNCTION(ancillary_getstream);
// list of custom PHP functions provided by this extension
// set {NULL, NULL, NULL} as the last record to mark the end of list
-static function_entry mop_functions[] = {
- PHP_FE(mop_function, NULL)
+static function_entry ancillary_getstream[] = {
+ PHP_FE(ancillary_getstream, NULL)
{NULL, NULL, NULL}
};
STANDARD_MODULE_HEADER,
#endif
PHP_ANCILLARY_EXTNAME,
- mop_functions,
+ ancillary_getstream,
NULL, // name of the MINIT function or NULL if not applicable
NULL, // name of the MSHUTDOWN function or NULL if not applicable
NULL, // name of the RINIT function or NULL if not applicable
};
ZEND_GET_MODULE(ancillary)
+
+#define CTRL_BUFF_MAX_SZ (8*1024)
-// implementation of a custom mop_function()
-PHP_FUNCTION(mop_function)
+// starting from a unix socket receive a socket from an external process
+PHP_FUNCTION(ancillary_getstream)
{
- RETURN_STRING("This is my function", 1);
+ zval *zstream;
+ php_stream *stream;
+ int fd_in, fd_out[2], retrecv, curpos = 0;
+ char *headers;
+ zval *zheaders;
+
+ if ((headers = calloc(CTRL_BUFF_MAX_SZ, 1)) == NULL) {
+ return;
+ }
+
+ if (FAILURE == zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "rz", &zstream, &zheaders))
+ return;
+
+ php_stream_from_zval(stream, &zstream);
+
+ if (php_stream_cast(stream, PHP_STREAM_AS_FD, (void*)&fd_in, REPORT_ERRORS) == FAILURE) {
+ RETURN_FALSE;
+ }
+
+ if(ancil_recv_fds(fd_in, fd_out, 2) == 0) {
+ RETURN_FALSE;
+ }
+
+ {
+ char bf[2048];
+
+ sprintf(bf, "zero: [%d] uno: [%d]\n", fd_out[0], fd_out[1]);
+ write(1, bf, strlen(bf));
+ }
+ while(1) {
+ write(1, "LOOP\n", 5);
+ retrecv = recv(fd_out[1], &(headers[curpos]), CTRL_BUFF_MAX_SZ - curpos - 1, 0);
+ if (retrecv < 0) {
+ RETURN_FALSE;
+ }
+ else if (retrecv == 0) {
+ break;
+ }
+ else {
+ char bf[1024];
+ curpos += retrecv;
+ sprintf(bf, "CURPOS: %d\n", curpos);
+ write(1, bf, strlen(bf));
+ if (curpos == CTRL_BUFF_MAX_SZ - 1) {
+ free(headers);
+ RETURN_FALSE;
+ }
+ }
+ }
+ shutdown(fd_out[1], SHUT_RDWR);
+
+ ZVAL_STRING(zheaders, headers, 1);
+ free(headers);
+
+ {
+ int fh;
+
+ if ((fh = open("/tmp/out_php-anc.txt", O_WRONLY | O_CREAT | O_APPEND)) > -1) {
+ write(fh, headers, curpos);
+ close(fh);
+ }
+ }
+
+ if ((stream = php_stream_fopen_from_fd(fd_out[0], "r+b", NULL)) == NULL) {
+ RETURN_FALSE;
+ }
+
+ php_stream_to_zval(stream, return_value);
}
+