Lines Matching refs:stream
54 static int php_tcp_sockop_set_option(php_stream *stream, int option, int value, void *ptrparam);
57 static ssize_t php_sockop_write(php_stream *stream, const char *buf, size_t count) in php_sockop_write() argument
59 php_netstream_data_t *sock = (php_netstream_data_t*)stream->abstract; in php_sockop_write()
107 if (!(stream->flags & PHP_STREAM_FLAG_SUPPRESS_ERRORS)) { in php_sockop_write()
117 php_stream_notify_progress_increment(PHP_STREAM_CONTEXT(stream), didwrite, 0); in php_sockop_write()
123 static void php_sock_stream_wait_for_data(php_stream *stream, php_netstream_data_t *sock) in php_sock_stream_wait_for_data() argument
153 static ssize_t php_sockop_read(php_stream *stream, char *buf, size_t count) in php_sockop_read() argument
155 php_netstream_data_t *sock = (php_netstream_data_t*)stream->abstract; in php_sockop_read()
164 php_sock_stream_wait_for_data(stream, sock); in php_sockop_read()
176 stream->eof = 1; in php_sockop_read()
179 stream->eof = 1; in php_sockop_read()
183 php_stream_notify_progress_increment(PHP_STREAM_CONTEXT(stream), nr_bytes, 0); in php_sockop_read()
190 static int php_sockop_close(php_stream *stream, int close_handle) in php_sockop_close() argument
192 php_netstream_data_t *sock = (php_netstream_data_t*)stream->abstract; in php_sockop_close()
228 pefree(sock, php_stream_is_persistent(stream)); in php_sockop_close()
233 static int php_sockop_flush(php_stream *stream) in php_sockop_flush() argument
236 php_netstream_data_t *sock = (php_netstream_data_t*)stream->abstract; in php_sockop_flush()
242 static int php_sockop_stat(php_stream *stream, php_stream_statbuf *ssb) in php_sockop_stat() argument
247 php_netstream_data_t *sock = (php_netstream_data_t*)stream->abstract; in php_sockop_stat()
309 static int php_sockop_set_option(php_stream *stream, int option, int value, void *ptrparam) in php_sockop_set_option() argument
312 php_netstream_data_t *sock = (php_netstream_data_t*)stream->abstract; in php_sockop_set_option()
374 add_assoc_bool((zval *)ptrparam, "eof", stream->eof); in php_sockop_set_option()
463 static int php_sockop_cast(php_stream *stream, int castas, void **ret) in php_sockop_cast() argument
465 php_netstream_data_t *sock = (php_netstream_data_t*)stream->abstract; in php_sockop_cast()
474 *(FILE**)ret = fdopen(sock->socket, stream->mode); in php_sockop_cast()
623 static inline int php_tcp_sockop_bind(php_stream *stream, php_netstream_data_t *sock, in php_tcp_sockop_bind() argument
632 if (stream->ops == &php_stream_unix_socket_ops || stream->ops == &php_stream_unixdg_socket_ops) { in php_tcp_sockop_bind()
635 …sock->socket = socket(PF_UNIX, stream->ops == &php_stream_unix_socket_ops ? SOCK_STREAM : SOCK_DGR… in php_tcp_sockop_bind()
640 stream->ops == &php_stream_unix_socket_ops ? "" : "datagram", in php_tcp_sockop_bind()
660 if (PHP_STREAM_CONTEXT(stream) in php_tcp_sockop_bind()
661 …&& (tmpzval = php_stream_context_get_option(PHP_STREAM_CONTEXT(stream), "socket", "ipv6_v6only")) … in php_tcp_sockop_bind()
670 if (PHP_STREAM_CONTEXT(stream) in php_tcp_sockop_bind()
671 …&& (tmpzval = php_stream_context_get_option(PHP_STREAM_CONTEXT(stream), "socket", "so_reuseport"))… in php_tcp_sockop_bind()
679 if (stream->ops == &php_stream_udp_socket_ops /* SO_BROADCAST is only applicable for UDP */ in php_tcp_sockop_bind()
680 && PHP_STREAM_CONTEXT(stream) in php_tcp_sockop_bind()
681 …&& (tmpzval = php_stream_context_get_option(PHP_STREAM_CONTEXT(stream), "socket", "so_broadcast"))… in php_tcp_sockop_bind()
689 stream->ops == &php_stream_udp_socket_ops ? SOCK_DGRAM : SOCK_STREAM, in php_tcp_sockop_bind()
702 static inline int php_tcp_sockop_connect(php_stream *stream, php_netstream_data_t *sock, in php_tcp_sockop_connect() argument
713 if (stream->ops == &php_stream_unix_socket_ops || stream->ops == &php_stream_unixdg_socket_ops) { in php_tcp_sockop_connect()
716 …sock->socket = socket(PF_UNIX, stream->ops == &php_stream_unix_socket_ops ? SOCK_STREAM : SOCK_DGR… in php_tcp_sockop_connect()
745 …if (PHP_STREAM_CONTEXT(stream) && (tmpzval = php_stream_context_get_option(PHP_STREAM_CONTEXT(stre… in php_tcp_sockop_connect()
757 if (stream->ops == &php_stream_udp_socket_ops /* SO_BROADCAST is only applicable for UDP */ in php_tcp_sockop_connect()
758 && PHP_STREAM_CONTEXT(stream) in php_tcp_sockop_connect()
759 …&& (tmpzval = php_stream_context_get_option(PHP_STREAM_CONTEXT(stream), "socket", "so_broadcast"))… in php_tcp_sockop_connect()
766 if (stream->ops != &php_stream_udp_socket_ops /* TCP_NODELAY is only applicable for TCP */ in php_tcp_sockop_connect()
768 && stream->ops != &php_stream_unix_socket_ops in php_tcp_sockop_connect()
769 && stream->ops != &php_stream_unixdg_socket_ops in php_tcp_sockop_connect()
771 && PHP_STREAM_CONTEXT(stream) in php_tcp_sockop_connect()
772 …&& (tmpzval = php_stream_context_get_option(PHP_STREAM_CONTEXT(stream), "socket", "tcp_nodelay")) … in php_tcp_sockop_connect()
783 stream->ops == &php_stream_udp_socket_ops ? SOCK_DGRAM : SOCK_STREAM, in php_tcp_sockop_connect()
815 static inline int php_tcp_sockop_accept(php_stream *stream, php_netstream_data_t *sock, in php_tcp_sockop_accept() argument
824 if ((NULL != PHP_STREAM_CONTEXT(stream)) && in php_tcp_sockop_accept()
825 …(tmpzval = php_stream_context_get_option(PHP_STREAM_CONTEXT(stream), "socket", "tcp_nodelay")) != … in php_tcp_sockop_accept()
849 xparam->outputs.client = php_stream_alloc_rel(stream->ops, clisockdata, NULL, "r+"); in php_tcp_sockop_accept()
851 xparam->outputs.client->ctx = stream->ctx; in php_tcp_sockop_accept()
852 if (stream->ctx) { in php_tcp_sockop_accept()
853 GC_ADDREF(stream->ctx); in php_tcp_sockop_accept()
861 static int php_tcp_sockop_set_option(php_stream *stream, int option, int value, void *ptrparam) in php_tcp_sockop_set_option() argument
863 php_netstream_data_t *sock = (php_netstream_data_t*)stream->abstract; in php_tcp_sockop_set_option()
873 xparam->outputs.returncode = php_tcp_sockop_connect(stream, sock, xparam); in php_tcp_sockop_set_option()
877 xparam->outputs.returncode = php_tcp_sockop_bind(stream, sock, xparam); in php_tcp_sockop_set_option()
882 xparam->outputs.returncode = php_tcp_sockop_accept(stream, sock, xparam STREAMS_CC); in php_tcp_sockop_set_option()
889 return php_sockop_set_option(stream, option, value, ptrparam); in php_tcp_sockop_set_option()
899 php_stream *stream = NULL; in php_stream_generic_socket_factory() local
932 stream = php_stream_alloc_rel(ops, sock, persistent_id, "r+"); in php_stream_generic_socket_factory()
934 if (stream == NULL) { in php_stream_generic_socket_factory()
940 return stream; in php_stream_generic_socket_factory()
943 return stream; in php_stream_generic_socket_factory()
