Lines Matching refs:net_stream
81 php_stream * net_stream = vio->data->m.get_stream(vio); in MYSQLND_METHOD() local
82 size_t old_chunk_size = net_stream->chunk_size; in MYSQLND_METHOD()
89 net_stream->chunk_size = MIN(to_read, vio->data->options.net_read_buffer_size); in MYSQLND_METHOD()
91 if (!(ret = php_stream_read(net_stream, (char *) p, to_read))) { in MYSQLND_METHOD()
100 net_stream->chunk_size = old_chunk_size; in MYSQLND_METHOD()
127 php_stream * net_stream = NULL; in MYSQLND_METHOD() local
134 …net_stream = php_stream_open_wrapper(scheme.s + sizeof("pipe://") - 1, "r+", streams_options, NULL… in MYSQLND_METHOD()
135 if (!net_stream) { in MYSQLND_METHOD()
146 …zend_hash_index_del(&EG(regular_list), net_stream->res->handle); /* ToDO: should it be res->handle… in MYSQLND_METHOD()
148 net_stream->res = NULL; in MYSQLND_METHOD()
150 DBG_RETURN(net_stream); in MYSQLND_METHOD()
168 php_stream * net_stream = NULL; in MYSQLND_METHOD() local
185 net_stream = php_stream_xport_create(scheme.s, scheme.l, streams_options, streams_flags, in MYSQLND_METHOD()
188 if (errstr || !net_stream) { in MYSQLND_METHOD()
225 net_stream->__exposed = 1; in MYSQLND_METHOD()
237 …zend_hash_index_del(&EG(regular_list), net_stream->res->handle); /* ToDO: should it be res->handle… in MYSQLND_METHOD()
238 efree(net_stream->res); in MYSQLND_METHOD()
239 net_stream->res = NULL; in MYSQLND_METHOD()
241 DBG_RETURN(net_stream); in MYSQLND_METHOD()
251 php_stream * net_stream = vio->data->m.get_stream(vio); in MYSQLND_METHOD() local
253 if (net_stream) { in MYSQLND_METHOD()
259 php_stream_set_option(net_stream, PHP_STREAM_OPTION_READ_TIMEOUT, 0, &tv); in MYSQLND_METHOD()
264 mysqlnd_set_sock_no_delay(net_stream); in MYSQLND_METHOD()
266 mysqlnd_set_sock_keepalive(net_stream); 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 skipped_bytes += (bytes_consumed = php_stream_read(net_stream, tmp_buf, sizeof(tmp_buf))); in MYSQLND_METHOD()
462 net_stream->ops->set_option(net_stream, opt, 1, NULL); in MYSQLND_METHOD()
491 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()
653 php_stream_free(net_stream, PHP_STREAM_FREE_CLOSE_PERSISTENT | PHP_STREAM_FREE_RSRC_DTOR); in MYSQLND_METHOD()
659 php_stream_free(net_stream, PHP_STREAM_FREE_CLOSE | PHP_STREAM_FREE_RSRC_DTOR); in MYSQLND_METHOD()
662 php_stream_free(net_stream, PHP_STREAM_FREE_CLOSE); in MYSQLND_METHOD()
720 MYSQLND_METHOD(mysqlnd_vio, set_stream)(MYSQLND_VIO * const vio, php_stream * net_stream) in MYSQLND_METHOD()
724 vio->data->stream = net_stream; in MYSQLND_METHOD()
