Lines Matching refs:stream
58 static int php_tcp_sockop_set_option(php_stream *stream, int option, int value, void *ptrparam);
61 static size_t php_sockop_write(php_stream *stream, const char *buf, size_t count) in php_sockop_write() argument
63 php_netstream_data_t *sock = (php_netstream_data_t*)stream->abstract; in php_sockop_write()
111 php_stream_notify_progress_increment(PHP_STREAM_CONTEXT(stream), didwrite, 0); in php_sockop_write()
121 static void php_sock_stream_wait_for_data(php_stream *stream, php_netstream_data_t *sock) in php_sock_stream_wait_for_data() argument
151 static size_t php_sockop_read(php_stream *stream, char *buf, size_t count) in php_sockop_read() argument
153 php_netstream_data_t *sock = (php_netstream_data_t*)stream->abstract; in php_sockop_read()
162 php_sock_stream_wait_for_data(stream, sock); in php_sockop_read()
170 stream->eof = (nr_bytes == 0 || (nr_bytes == -1 && err != EWOULDBLOCK && err != EAGAIN)); in php_sockop_read()
173 php_stream_notify_progress_increment(PHP_STREAM_CONTEXT(stream), nr_bytes, 0); in php_sockop_read()
184 static int php_sockop_close(php_stream *stream, int close_handle) in php_sockop_close() argument
186 php_netstream_data_t *sock = (php_netstream_data_t*)stream->abstract; in php_sockop_close()
222 pefree(sock, php_stream_is_persistent(stream)); in php_sockop_close()
227 static int php_sockop_flush(php_stream *stream) in php_sockop_flush() argument
230 php_netstream_data_t *sock = (php_netstream_data_t*)stream->abstract; in php_sockop_flush()
236 static int php_sockop_stat(php_stream *stream, php_stream_statbuf *ssb) in php_sockop_stat() argument
241 php_netstream_data_t *sock = (php_netstream_data_t*)stream->abstract; in php_sockop_stat()
297 static int php_sockop_set_option(php_stream *stream, int option, int value, void *ptrparam) in php_sockop_set_option() argument
300 php_netstream_data_t *sock = (php_netstream_data_t*)stream->abstract; in php_sockop_set_option()
362 add_assoc_bool((zval *)ptrparam, "eof", stream->eof); in php_sockop_set_option()
452 static int php_sockop_cast(php_stream *stream, int castas, void **ret) in php_sockop_cast() argument
454 php_netstream_data_t *sock = (php_netstream_data_t*)stream->abstract; in php_sockop_cast()
463 *(FILE**)ret = fdopen(sock->socket, stream->mode); in php_sockop_cast()
612 static inline int php_tcp_sockop_bind(php_stream *stream, php_netstream_data_t *sock, in php_tcp_sockop_bind() argument
621 if (stream->ops == &php_stream_unix_socket_ops || stream->ops == &php_stream_unixdg_socket_ops) { in php_tcp_sockop_bind()
624 …sock->socket = socket(PF_UNIX, stream->ops == &php_stream_unix_socket_ops ? SOCK_STREAM : SOCK_DGR… in php_tcp_sockop_bind()
629 stream->ops == &php_stream_unix_socket_ops ? "" : "datagram", in php_tcp_sockop_bind()
649 if (PHP_STREAM_CONTEXT(stream) in php_tcp_sockop_bind()
650 …&& (tmpzval = php_stream_context_get_option(PHP_STREAM_CONTEXT(stream), "socket", "ipv6_v6only")) … in php_tcp_sockop_bind()
659 if (PHP_STREAM_CONTEXT(stream) in php_tcp_sockop_bind()
660 …&& (tmpzval = php_stream_context_get_option(PHP_STREAM_CONTEXT(stream), "socket", "so_reuseport"))… in php_tcp_sockop_bind()
668 if (stream->ops == &php_stream_udp_socket_ops /* SO_BROADCAST is only applicable for UDP */ in php_tcp_sockop_bind()
669 && PHP_STREAM_CONTEXT(stream) in php_tcp_sockop_bind()
670 …&& (tmpzval = php_stream_context_get_option(PHP_STREAM_CONTEXT(stream), "socket", "so_broadcast"))… in php_tcp_sockop_bind()
678 stream->ops == &php_stream_udp_socket_ops ? SOCK_DGRAM : SOCK_STREAM, in php_tcp_sockop_bind()
691 static inline int php_tcp_sockop_connect(php_stream *stream, php_netstream_data_t *sock, in php_tcp_sockop_connect() argument
702 if (stream->ops == &php_stream_unix_socket_ops || stream->ops == &php_stream_unixdg_socket_ops) { in php_tcp_sockop_connect()
705 …sock->socket = socket(PF_UNIX, stream->ops == &php_stream_unix_socket_ops ? SOCK_STREAM : SOCK_DGR… in php_tcp_sockop_connect()
734 …if (PHP_STREAM_CONTEXT(stream) && (tmpzval = php_stream_context_get_option(PHP_STREAM_CONTEXT(stre… in php_tcp_sockop_connect()
746 if (stream->ops == &php_stream_udp_socket_ops /* SO_BROADCAST is only applicable for UDP */ in php_tcp_sockop_connect()
747 && PHP_STREAM_CONTEXT(stream) in php_tcp_sockop_connect()
748 …&& (tmpzval = php_stream_context_get_option(PHP_STREAM_CONTEXT(stream), "socket", "so_broadcast"))… in php_tcp_sockop_connect()
760 stream->ops == &php_stream_udp_socket_ops ? SOCK_DGRAM : SOCK_STREAM, in php_tcp_sockop_connect()
792 static inline int php_tcp_sockop_accept(php_stream *stream, php_netstream_data_t *sock, in php_tcp_sockop_accept() argument
820 xparam->outputs.client = php_stream_alloc_rel(stream->ops, clisockdata, NULL, "r+"); in php_tcp_sockop_accept()
822 xparam->outputs.client->ctx = stream->ctx; in php_tcp_sockop_accept()
823 if (stream->ctx) { in php_tcp_sockop_accept()
824 GC_REFCOUNT(stream->ctx)++; in php_tcp_sockop_accept()
833 static int php_tcp_sockop_set_option(php_stream *stream, int option, int value, void *ptrparam) in php_tcp_sockop_set_option() argument
835 php_netstream_data_t *sock = (php_netstream_data_t*)stream->abstract; in php_tcp_sockop_set_option()
845 xparam->outputs.returncode = php_tcp_sockop_connect(stream, sock, xparam); in php_tcp_sockop_set_option()
849 xparam->outputs.returncode = php_tcp_sockop_bind(stream, sock, xparam); in php_tcp_sockop_set_option()
854 xparam->outputs.returncode = php_tcp_sockop_accept(stream, sock, xparam STREAMS_CC); in php_tcp_sockop_set_option()
861 return php_sockop_set_option(stream, option, value, ptrparam); in php_tcp_sockop_set_option()
871 php_stream *stream = NULL; in php_stream_generic_socket_factory() local
904 stream = php_stream_alloc_rel(ops, sock, persistent_id, "r+"); in php_stream_generic_socket_factory()
906 if (stream == NULL) { in php_stream_generic_socket_factory()
912 return stream; in php_stream_generic_socket_factory()
915 return stream; in php_stream_generic_socket_factory()
