Lines Matching refs:net_stream
81 php_stream * net_stream = vio->data->m.get_stream(vio); in MYSQLND_METHOD() local
89 ssize_t ret = php_stream_read(net_stream, (char *) p, to_read); in MYSQLND_METHOD()
125 php_stream * net_stream = NULL; in MYSQLND_METHOD() local
132 …net_stream = php_stream_open_wrapper(scheme.s + sizeof("pipe://") - 1, "r+", streams_options, NULL… in MYSQLND_METHOD()
133 if (!net_stream) { in MYSQLND_METHOD()
144 …zend_hash_index_del(&EG(regular_list), net_stream->res->handle); /* ToDO: should it be res->handle… in MYSQLND_METHOD()
146 net_stream->res = NULL; in MYSQLND_METHOD()
148 DBG_RETURN(net_stream); in MYSQLND_METHOD()
166 php_stream * net_stream = NULL; in MYSQLND_METHOD() local
183 net_stream = php_stream_xport_create(scheme.s, scheme.l, streams_options, streams_flags, in MYSQLND_METHOD()
186 if (errstr || !net_stream) { in MYSQLND_METHOD()
223 net_stream->__exposed = 1; in MYSQLND_METHOD()
235 …zend_hash_index_del(&EG(regular_list), net_stream->res->handle); /* ToDO: should it be res->handle… in MYSQLND_METHOD()
236 efree(net_stream->res); in MYSQLND_METHOD()
237 net_stream->res = NULL; in MYSQLND_METHOD()
239 DBG_RETURN(net_stream); in MYSQLND_METHOD()
249 php_stream * net_stream = vio->data->m.get_stream(vio); in MYSQLND_METHOD() local
251 if (net_stream) { in MYSQLND_METHOD()
257 php_stream_set_option(net_stream, PHP_STREAM_OPTION_READ_TIMEOUT, 0, &tv); in MYSQLND_METHOD()
262 mysqlnd_set_sock_no_delay(net_stream); in MYSQLND_METHOD()
264 mysqlnd_set_sock_keepalive(net_stream); in MYSQLND_METHOD()
267 net_stream->chunk_size = vio->data->options.net_read_buffer_size; in MYSQLND_METHOD()
313 php_stream * net_stream = open_stream(vio, scheme, persistent, conn_stats, error_info); in MYSQLND_METHOD() local
314 if (net_stream && PASS == vio->data->m.set_stream(vio, net_stream)) { in MYSQLND_METHOD()
448 php_stream * net_stream = net->data->get_stream(net); in MYSQLND_METHOD() local
449 int was_blocked = net_stream->ops->set_option(net_stream, opt, 0, NULL); in MYSQLND_METHOD()
458 bytes_consumed = php_stream_read(net_stream, tmp_buf, sizeof(tmp_buf)); in MYSQLND_METHOD()
466 net_stream->ops->set_option(net_stream, opt, 1, NULL); in MYSQLND_METHOD()
495 php_stream * net_stream = net->data->m.get_stream(net); in MYSQLND_METHOD() local
564 php_stream_context_set(net_stream, context); in MYSQLND_METHOD()
565 if (php_stream_xport_crypto_setup(net_stream, STREAM_CRYPTO_METHOD_TLS_CLIENT, NULL) < 0 || in MYSQLND_METHOD()
566 php_stream_xport_crypto_enable(net_stream, 1) < 0) in MYSQLND_METHOD()
580 php_stream_context_set(net_stream, NULL); in MYSQLND_METHOD()
587 php_stream_set_option(net_stream, PHP_STREAM_OPTION_READ_TIMEOUT, 0, &tv); in MYSQLND_METHOD()
647 php_stream * net_stream; in MYSQLND_METHOD() local
649 if (net && (net_stream = net->data->m.get_stream(net))) { in MYSQLND_METHOD()
651 DBG_INF_FMT("Freeing stream. abstract=%p", net_stream->abstract); in MYSQLND_METHOD()
656 php_stream_free(net_stream, PHP_STREAM_FREE_CLOSE_PERSISTENT | PHP_STREAM_FREE_RSRC_DTOR); in MYSQLND_METHOD()
662 php_stream_free(net_stream, PHP_STREAM_FREE_CLOSE | PHP_STREAM_FREE_RSRC_DTOR); in MYSQLND_METHOD()
719 MYSQLND_METHOD(mysqlnd_vio, set_stream)(MYSQLND_VIO * const vio, php_stream * net_stream) in MYSQLND_METHOD()
723 vio->data->stream = net_stream; in MYSQLND_METHOD()
