5 #include <php5/main/php_network.h>
6 #include <php5/ext/standard/file.h>
13 #define PHP_ANCILLARY_VERSION "1.0"
14 #define PHP_ANCILLARY_EXTNAME "ancillary"
16 extern zend_module_entry ancillary_module_entry;
17 #define phpext_ancillary_ptr &ancillary_module_entry
19 // declaration of a custom mop_function()
20 PHP_FUNCTION(ancillary_getstream);
22 // list of custom PHP functions provided by this extension
23 // set {NULL, NULL, NULL} as the last record to mark the end of list
24 static function_entry ancillary_getstream[] = {
25 PHP_FE(ancillary_getstream, NULL)
29 // the following code creates an entry for the module and registers it with Zend.
30 zend_module_entry ancillary_module_entry = {
31 #if ZEND_MODULE_API_NO >= 20010901
32 STANDARD_MODULE_HEADER,
34 PHP_ANCILLARY_EXTNAME,
36 NULL, // name of the MINIT function or NULL if not applicable
37 NULL, // name of the MSHUTDOWN function or NULL if not applicable
38 NULL, // name of the RINIT function or NULL if not applicable
39 NULL, // name of the RSHUTDOWN function or NULL if not applicable
40 NULL, // name of the MINFO function or NULL if not applicable
41 #if ZEND_MODULE_API_NO >= 20010901
42 PHP_ANCILLARY_VERSION,
44 STANDARD_MODULE_PROPERTIES
47 ZEND_GET_MODULE(ancillary)
49 #define CTRL_BUFF_MAX_SZ (8*1024)
51 // starting from a unix socket receive a socket from an external process
52 PHP_FUNCTION(ancillary_getstream)
56 int fd_in, fd_out[2], retrecv, curpos = 0;
59 php_netstream_data_t *sock;
61 if ((headers = calloc(CTRL_BUFF_MAX_SZ, 1)) == NULL) {
65 if (FAILURE == zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "rz", &zstream, &zheaders)) {
70 php_stream_from_zval(stream, &zstream);
72 if (php_stream_cast(stream, PHP_STREAM_AS_FD, (void*)&fd_in, REPORT_ERRORS) == FAILURE) {
77 if(ancil_recv_fds(fd_in, fd_out, 2) == 0) {
85 sprintf(bf, "zero: [%d] uno: [%d]\n", fd_out[0], fd_out[1]);
86 write(1, bf, strlen(bf));
89 write(1, "LOOP\n", 5);
90 retrecv = recv(fd_out[1], &(headers[curpos]), CTRL_BUFF_MAX_SZ - curpos - 1, 0);
95 else if (retrecv == 0) {
101 sprintf(bf, "CURPOS: %d\n", curpos);
102 write(1, bf, strlen(bf));
103 if (curpos == CTRL_BUFF_MAX_SZ - 1) {
109 shutdown(fd_out[1], SHUT_RDWR);
111 ZVAL_STRING(zheaders, headers, 1);
117 if ((fh = open("/tmp/out_php-anc.txt", O_WRONLY | O_CREAT | O_APPEND)) > -1) {
118 write(fh, headers, curpos);
123 sock = pemalloc(sizeof(php_netstream_data_t), 0);
124 memset(sock, 0, sizeof(php_netstream_data_t));
126 sock->is_blocked = 1;
127 sock->timeout.tv_sec = FG(default_socket_timeout);
128 sock->timeout.tv_usec = 0;
130 /* we don't know the socket until we have determined if we are binding or
132 sock->socket = fd_out[0];
134 stream = php_stream_alloc_rel(&php_stream_socket_ops, sock, NULL, "r+");
136 if (stream == NULL) {
140 php_stream_to_zval(stream, return_value);