Lines Matching refs:stream
51 static int php_tcp_sockop_set_option(php_stream *stream, int option, int value, void *ptrparam TSRM…
54 static size_t php_sockop_write(php_stream *stream, const char *buf, size_t count TSRMLS_DC) in php_sockop_write() argument
56 php_netstream_data_t *sock = (php_netstream_data_t*)stream->abstract; in php_sockop_write()
104 php_stream_notify_progress_increment(stream->context, didwrite, 0); in php_sockop_write()
114 static void php_sock_stream_wait_for_data(php_stream *stream, php_netstream_data_t *sock TSRMLS_DC) in php_sock_stream_wait_for_data() argument
144 static size_t php_sockop_read(php_stream *stream, char *buf, size_t count TSRMLS_DC) in php_sockop_read() argument
146 php_netstream_data_t *sock = (php_netstream_data_t*)stream->abstract; in php_sockop_read()
154 php_sock_stream_wait_for_data(stream, sock TSRMLS_CC); in php_sockop_read()
161 stream->eof = (nr_bytes == 0 || (nr_bytes == -1 && php_socket_errno() != EWOULDBLOCK)); in php_sockop_read()
164 php_stream_notify_progress_increment(stream->context, nr_bytes, 0); in php_sockop_read()
175 static int php_sockop_close(php_stream *stream, int close_handle TSRMLS_DC) in php_sockop_close() argument
177 php_netstream_data_t *sock = (php_netstream_data_t*)stream->abstract; in php_sockop_close()
209 pefree(sock, php_stream_is_persistent(stream)); in php_sockop_close()
214 static int php_sockop_flush(php_stream *stream TSRMLS_DC) in php_sockop_flush()
217 php_netstream_data_t *sock = (php_netstream_data_t*)stream->abstract; in php_sockop_flush()
223 static int php_sockop_stat(php_stream *stream, php_stream_statbuf *ssb TSRMLS_DC) in php_sockop_stat() argument
225 php_netstream_data_t *sock = (php_netstream_data_t*)stream->abstract; in php_sockop_stat()
268 static int php_sockop_set_option(php_stream *stream, int option, int value, void *ptrparam TSRMLS_D… in php_sockop_set_option() argument
271 php_netstream_data_t *sock = (php_netstream_data_t*)stream->abstract; in php_sockop_set_option()
319 add_assoc_bool((zval *)ptrparam, "eof", stream->eof); in php_sockop_set_option()
412 static int php_sockop_cast(php_stream *stream, int castas, void **ret TSRMLS_DC) in php_sockop_cast() argument
414 php_netstream_data_t *sock = (php_netstream_data_t*)stream->abstract; in php_sockop_cast()
419 *(FILE**)ret = fdopen(sock->socket, stream->mode); in php_sockop_cast()
568 static inline int php_tcp_sockop_bind(php_stream *stream, php_netstream_data_t *sock, in php_tcp_sockop_bind() argument
575 if (stream->ops == &php_stream_unix_socket_ops || stream->ops == &php_stream_unixdg_socket_ops) { in php_tcp_sockop_bind()
578 …sock->socket = socket(PF_UNIX, stream->ops == &php_stream_unix_socket_ops ? SOCK_STREAM : SOCK_DGR… in php_tcp_sockop_bind()
583 stream->ops == &php_stream_unix_socket_ops ? "" : "datagram", in php_tcp_sockop_bind()
603 stream->ops == &php_stream_udp_socket_ops ? SOCK_DGRAM : SOCK_STREAM, in php_tcp_sockop_bind()
615 static inline int php_tcp_sockop_connect(php_stream *stream, php_netstream_data_t *sock, in php_tcp_sockop_connect() argument
625 if (stream->ops == &php_stream_unix_socket_ops || stream->ops == &php_stream_unixdg_socket_ops) { in php_tcp_sockop_connect()
628 …sock->socket = socket(PF_UNIX, stream->ops == &php_stream_unix_socket_ops ? SOCK_STREAM : SOCK_DGR… in php_tcp_sockop_connect()
657 …if (stream->context && php_stream_context_get_option(stream->context, "socket", "bindto", &tmpzval… in php_tcp_sockop_connect()
673 stream->ops == &php_stream_udp_socket_ops ? SOCK_DGRAM : SOCK_STREAM, in php_tcp_sockop_connect()
704 static inline int php_tcp_sockop_accept(php_stream *stream, php_netstream_data_t *sock, in php_tcp_sockop_accept() argument
733 xparam->outputs.client = php_stream_alloc_rel(stream->ops, clisockdata, NULL, "r+"); in php_tcp_sockop_accept()
735 xparam->outputs.client->context = stream->context; in php_tcp_sockop_accept()
736 if (stream->context) { in php_tcp_sockop_accept()
737 zend_list_addref(stream->context->rsrc_id); in php_tcp_sockop_accept()
746 static int php_tcp_sockop_set_option(php_stream *stream, int option, int value, void *ptrparam TSRM… in php_tcp_sockop_set_option() argument
748 php_netstream_data_t *sock = (php_netstream_data_t*)stream->abstract; in php_tcp_sockop_set_option()
758 xparam->outputs.returncode = php_tcp_sockop_connect(stream, sock, xparam TSRMLS_CC); in php_tcp_sockop_set_option()
762 xparam->outputs.returncode = php_tcp_sockop_bind(stream, sock, xparam TSRMLS_CC); in php_tcp_sockop_set_option()
767 xparam->outputs.returncode = php_tcp_sockop_accept(stream, sock, xparam STREAMS_CC TSRMLS_CC); in php_tcp_sockop_set_option()
774 return php_sockop_set_option(stream, option, value, ptrparam TSRMLS_CC); in php_tcp_sockop_set_option()
784 php_stream *stream = NULL; in php_stream_generic_socket_factory() local
817 stream = php_stream_alloc_rel(ops, sock, persistent_id, "r+"); in php_stream_generic_socket_factory()
819 if (stream == NULL) { in php_stream_generic_socket_factory()
825 return stream; in php_stream_generic_socket_factory()
828 return stream; in php_stream_generic_socket_factory()
