Lines Matching refs:stream

60 	php_stream *stream = NULL;  in _php_stream_xport_create()  local
75 switch(php_stream_from_persistent_id(persistent_id, &stream TSRMLS_CC)) { in _php_stream_xport_create()
79 …if (PHP_STREAM_OPTION_RETURN_OK == php_stream_set_option(stream, PHP_STREAM_OPTION_CHECK_LIVENESS,… in _php_stream_xport_create()
80 return stream; in _php_stream_xport_create()
83 php_stream_pclose(stream); in _php_stream_xport_create()
84 stream = NULL; in _php_stream_xport_create()
132 stream = (*factory)(protocol, n, in _php_stream_xport_create()
136 if (stream) { in _php_stream_xport_create()
137 php_stream_context_set(stream, context); in _php_stream_xport_create()
143 if (-1 == php_stream_xport_connect(stream, name, namelen, in _php_stream_xport_create()
156 if (0 != php_stream_xport_bind(stream, name, namelen, &error_text TSRMLS_CC)) { in _php_stream_xport_create()
163 …if (stream->context && php_stream_context_get_option(stream->context, "socket", "backlog", &zbackl… in _php_stream_xport_create()
173 if (0 != php_stream_xport_listen(stream, backlog, &error_text TSRMLS_CC)) { in _php_stream_xport_create()
185 php_stream_pclose(stream); in _php_stream_xport_create()
187 php_stream_close(stream); in _php_stream_xport_create()
189 stream = NULL; in _php_stream_xport_create()
192 return stream; in _php_stream_xport_create()
196 PHPAPI int php_stream_xport_bind(php_stream *stream, in php_stream_xport_bind() argument
210 ret = php_stream_set_option(stream, PHP_STREAM_OPTION_XPORT_API, 0, &param); in php_stream_xport_bind()
224 PHPAPI int php_stream_xport_connect(php_stream *stream, in php_stream_xport_connect() argument
243 ret = php_stream_set_option(stream, PHP_STREAM_OPTION_XPORT_API, 0, &param); in php_stream_xport_connect()
260 PHPAPI int php_stream_xport_listen(php_stream *stream, int backlog, char **error_text TSRMLS_DC) in php_stream_xport_listen() argument
270 ret = php_stream_set_option(stream, PHP_STREAM_OPTION_XPORT_API, 0, &param); in php_stream_xport_listen()
284 PHPAPI int php_stream_xport_accept(php_stream *stream, php_stream **client, in php_stream_xport_accept() argument
302 ret = php_stream_set_option(stream, PHP_STREAM_OPTION_XPORT_API, 0, &param); in php_stream_xport_accept()
323 PHPAPI int php_stream_xport_get_name(php_stream *stream, int want_peer, in php_stream_xport_get_name() argument
337 ret = php_stream_set_option(stream, PHP_STREAM_OPTION_XPORT_API, 0, &param); in php_stream_xport_get_name()
354 PHPAPI int php_stream_xport_crypto_setup(php_stream *stream, php_stream_xport_crypt_method_t crypto… in php_stream_xport_crypto_setup() argument
364 ret = php_stream_set_option(stream, PHP_STREAM_OPTION_CRYPTO_API, 0, &param); in php_stream_xport_crypto_setup()
375 PHPAPI int php_stream_xport_crypto_enable(php_stream *stream, int activate TSRMLS_DC) in php_stream_xport_crypto_enable() argument
384 ret = php_stream_set_option(stream, PHP_STREAM_OPTION_CRYPTO_API, 0, &param); in php_stream_xport_crypto_enable()
397 PHPAPI int php_stream_xport_recvfrom(php_stream *stream, char *buf, size_t buflen, in php_stream_xport_recvfrom() argument
408 return php_stream_read(stream, buf, buflen); in php_stream_xport_recvfrom()
411 if (stream->readfilters.head) { in php_stream_xport_recvfrom()
422 recvd_len = stream->writepos - stream->readpos; in php_stream_xport_recvfrom()
427 memcpy(buf, stream->readbuf, recvd_len); in php_stream_xport_recvfrom()
449 ret = php_stream_set_option(stream, PHP_STREAM_OPTION_XPORT_API, 0, &param); in php_stream_xport_recvfrom()
467 PHPAPI int php_stream_xport_sendto(php_stream *stream, const char *buf, size_t buflen, in php_stream_xport_sendto() argument
476 return php_stream_write(stream, buf, buflen); in php_stream_xport_sendto()
482 if ((oob || addr) && stream->writefilters.head) { in php_stream_xport_sendto()
497 ret = php_stream_set_option(stream, PHP_STREAM_OPTION_XPORT_API, 0, &param); in php_stream_xport_sendto()
507 PHPAPI int php_stream_xport_shutdown(php_stream *stream, stream_shutdown_t how TSRMLS_DC) in php_stream_xport_shutdown() argument
517 ret = php_stream_set_option(stream, PHP_STREAM_OPTION_XPORT_API, 0, &param); in php_stream_xport_shutdown()