Lines Matching refs:net_stream
89 php_stream * net_stream = net->data->m.get_stream(net); in MYSQLND_METHOD() local
90 size_t old_chunk_size = net_stream->chunk_size; in MYSQLND_METHOD()
97 net_stream->chunk_size = MIN(to_read, net->data->options.net_read_buffer_size); in MYSQLND_METHOD()
99 if (!(ret = php_stream_read(net_stream, (char *) p, to_read))) { in MYSQLND_METHOD()
108 net_stream->chunk_size = old_chunk_size; in MYSQLND_METHOD()
136 php_stream * net_stream = NULL; in MYSQLND_METHOD() local
143 …net_stream = php_stream_open_wrapper((char*) scheme + sizeof("pipe://") - 1, "r+", streams_options… in MYSQLND_METHOD()
144 if (!net_stream) { in MYSQLND_METHOD()
155 …zend_hash_index_del(&EG(regular_list), net_stream->res->handle); /* ToDO: should it be res->handle… in MYSQLND_METHOD()
157 net_stream->res = NULL; in MYSQLND_METHOD()
159 DBG_RETURN(net_stream); in MYSQLND_METHOD()
178 php_stream * net_stream = NULL; in MYSQLND_METHOD() local
195 net_stream = php_stream_xport_create(scheme, scheme_len, streams_options, streams_flags, in MYSQLND_METHOD()
198 if (errstr || !net_stream) { in MYSQLND_METHOD()
235 net_stream->__exposed = 1; in MYSQLND_METHOD()
247 …zend_hash_index_del(&EG(regular_list), net_stream->res->handle); /* ToDO: should it be res->handle… in MYSQLND_METHOD()
248 efree(net_stream->res); in MYSQLND_METHOD()
249 net_stream->res = NULL; in MYSQLND_METHOD()
251 DBG_RETURN(net_stream); in MYSQLND_METHOD()
262 php_stream * net_stream = net->data->m.get_stream(net); in MYSQLND_METHOD() local
264 if (net_stream) { in MYSQLND_METHOD()
270 php_stream_set_option(net_stream, PHP_STREAM_OPTION_READ_TIMEOUT, 0, &tv); in MYSQLND_METHOD()
275 mysqlnd_set_sock_no_delay(net_stream); in MYSQLND_METHOD()
277 mysqlnd_set_sock_keepalive(net_stream); in MYSQLND_METHOD()
327 …php_stream * net_stream = open_stream(net, scheme, scheme_len, persistent, conn_stats, error_info); in MYSQLND_METHOD() local
328 if (net_stream) { in MYSQLND_METHOD()
329 (void) net->data->m.set_stream(net, net_stream); in MYSQLND_METHOD()
862 php_stream * net_stream = net->data->get_stream(net); in MYSQLND_METHOD() local
863 int was_blocked = net_stream->ops->set_option(net_stream, opt, 0, NULL); in MYSQLND_METHOD()
872 skipped_bytes += (bytes_consumed = php_stream_read(net_stream, tmp_buf, sizeof(tmp_buf))); in MYSQLND_METHOD()
876 net_stream->ops->set_option(net_stream, opt, 1, NULL); in MYSQLND_METHOD()
905 php_stream * net_stream = net->data->m.get_stream(net); in MYSQLND_METHOD() local
976 php_stream_context_set(net_stream, context); in MYSQLND_METHOD()
977 if (php_stream_xport_crypto_setup(net_stream, STREAM_CRYPTO_METHOD_TLS_CLIENT, NULL) < 0 || in MYSQLND_METHOD()
978 php_stream_xport_crypto_enable(net_stream, 1) < 0) in MYSQLND_METHOD()
992 php_stream_context_set(net_stream, NULL); in MYSQLND_METHOD()
999 php_stream_set_option(net_stream, PHP_STREAM_OPTION_READ_TIMEOUT, 0, &tv); in MYSQLND_METHOD()
1068 php_stream * net_stream; in MYSQLND_METHOD() local
1070 if (net && (net_stream = net->data->m.get_stream(net))) { in MYSQLND_METHOD()
1072 DBG_INF_FMT("Freeing stream. abstract=%p", net_stream->abstract); in MYSQLND_METHOD()
1075 php_stream_free(net_stream, PHP_STREAM_FREE_CLOSE_PERSISTENT | PHP_STREAM_FREE_RSRC_DTOR); in MYSQLND_METHOD()
1081 php_stream_free(net_stream, PHP_STREAM_FREE_CLOSE | PHP_STREAM_FREE_RSRC_DTOR); in MYSQLND_METHOD()
1084 php_stream_free(net_stream, PHP_STREAM_FREE_CLOSE); in MYSQLND_METHOD()
1151 MYSQLND_METHOD(mysqlnd_net, set_stream)(MYSQLND_NET * const net, php_stream * net_stream) in MYSQLND_METHOD()
1156 net->data->stream = net_stream; in MYSQLND_METHOD()
