Lines Matching refs:net_stream
79 php_stream * net_stream = vio->data->m.get_stream(vio); in MYSQLND_METHOD() local
87 ssize_t ret = php_stream_read(net_stream, (char *) p, to_read); in MYSQLND_METHOD()
123 php_stream * net_stream = NULL; in MYSQLND_METHOD() local
130 …net_stream = php_stream_open_wrapper(scheme.s + sizeof("pipe://") - 1, "r+", streams_options, NULL… in MYSQLND_METHOD()
131 if (!net_stream) { in MYSQLND_METHOD()
142 …zend_hash_index_del(&EG(regular_list), net_stream->res->handle); /* ToDO: should it be res->handle… in MYSQLND_METHOD()
144 net_stream->res = NULL; in MYSQLND_METHOD()
146 DBG_RETURN(net_stream); in MYSQLND_METHOD()
164 php_stream * net_stream = NULL; in MYSQLND_METHOD() local
181 net_stream = php_stream_xport_create(scheme.s, scheme.l, streams_options, streams_flags, in MYSQLND_METHOD()
184 if (errstr || !net_stream) { in MYSQLND_METHOD()
221 net_stream->__exposed = 1; in MYSQLND_METHOD()
233 …zend_hash_index_del(&EG(regular_list), net_stream->res->handle); /* ToDO: should it be res->handle… in MYSQLND_METHOD()
234 efree(net_stream->res); in MYSQLND_METHOD()
235 net_stream->res = NULL; in MYSQLND_METHOD()
237 DBG_RETURN(net_stream); in MYSQLND_METHOD()
247 php_stream * net_stream = vio->data->m.get_stream(vio); in MYSQLND_METHOD() local
249 if (net_stream) { in MYSQLND_METHOD()
255 php_stream_set_option(net_stream, PHP_STREAM_OPTION_READ_TIMEOUT, 0, &tv); in MYSQLND_METHOD()
260 mysqlnd_set_sock_no_delay(net_stream); in MYSQLND_METHOD()
262 mysqlnd_set_sock_keepalive(net_stream); in MYSQLND_METHOD()
265 net_stream->chunk_size = vio->data->options.net_read_buffer_size; in MYSQLND_METHOD()
266 net_stream->flags |= PHP_STREAM_FLAG_SUPPRESS_ERRORS; in MYSQLND_METHOD()
312 php_stream * net_stream = open_stream(vio, scheme, persistent, conn_stats, error_info); in MYSQLND_METHOD() local
313 if (net_stream && PASS == vio->data->m.set_stream(vio, net_stream)) { in MYSQLND_METHOD()
447 php_stream * net_stream = net->data->get_stream(net); in MYSQLND_METHOD() local
448 int was_blocked = net_stream->ops->set_option(net_stream, opt, 0, NULL); in MYSQLND_METHOD()
457 bytes_consumed = php_stream_read(net_stream, tmp_buf, sizeof(tmp_buf)); in MYSQLND_METHOD()
465 net_stream->ops->set_option(net_stream, opt, 1, NULL); in MYSQLND_METHOD()
494 php_stream * net_stream = net->data->m.get_stream(net); in MYSQLND_METHOD() local
563 php_stream_context_set(net_stream, context); in MYSQLND_METHOD()
564 if (php_stream_xport_crypto_setup(net_stream, STREAM_CRYPTO_METHOD_TLS_CLIENT, NULL) < 0 || in MYSQLND_METHOD()
565 php_stream_xport_crypto_enable(net_stream, 1) < 0) in MYSQLND_METHOD()
579 php_stream_context_set(net_stream, NULL); in MYSQLND_METHOD()
586 php_stream_set_option(net_stream, PHP_STREAM_OPTION_READ_TIMEOUT, 0, &tv); in MYSQLND_METHOD()
646 php_stream * net_stream; in MYSQLND_METHOD() local
648 if (net && (net_stream = net->data->m.get_stream(net))) { in MYSQLND_METHOD()
650 DBG_INF_FMT("Freeing stream. abstract=%p", net_stream->abstract); in MYSQLND_METHOD()
655 php_stream_free(net_stream, PHP_STREAM_FREE_CLOSE_PERSISTENT | PHP_STREAM_FREE_RSRC_DTOR); in MYSQLND_METHOD()
661 php_stream_free(net_stream, PHP_STREAM_FREE_CLOSE | PHP_STREAM_FREE_RSRC_DTOR); in MYSQLND_METHOD()
718 MYSQLND_METHOD(mysqlnd_vio, set_stream)(MYSQLND_VIO * const vio, php_stream * net_stream) in MYSQLND_METHOD()
722 vio->data->stream = net_stream; in MYSQLND_METHOD()
