net_stream 1906 ext/mysqlnd/mysqlnd.c php_stream * net_stream = net->data->m.get_stream(net TSRMLS_CC); net_stream 1910 ext/mysqlnd/mysqlnd.c DBG_INF_FMT("conn=%llu net->data->stream->abstract=%p", conn->thread_id, net_stream? net_stream->abstract:NULL); net_stream 1923 ext/mysqlnd/mysqlnd.c if (net_stream) { net_stream 91 ext/mysqlnd/mysqlnd_net.c php_stream * net_stream = net->data->m.get_stream(net TSRMLS_CC); net_stream 92 ext/mysqlnd/mysqlnd_net.c size_t old_chunk_size = net_stream->chunk_size; net_stream 99 ext/mysqlnd/mysqlnd_net.c net_stream->chunk_size = MIN(to_read, net->data->options.net_read_buffer_size); net_stream 101 ext/mysqlnd/mysqlnd_net.c if (!(ret = php_stream_read(net_stream, (char *) p, to_read))) { net_stream 110 ext/mysqlnd/mysqlnd_net.c net_stream->chunk_size = old_chunk_size; net_stream 140 ext/mysqlnd/mysqlnd_net.c php_stream * net_stream = NULL; net_stream 147 ext/mysqlnd/mysqlnd_net.c net_stream = php_stream_open_wrapper((char*) scheme + sizeof("pipe://") - 1, "r+", streams_options, NULL); net_stream 148 ext/mysqlnd/mysqlnd_net.c if (!net_stream) { net_stream 157 ext/mysqlnd/mysqlnd_net.c net_stream->in_free = 1; net_stream 158 ext/mysqlnd/mysqlnd_net.c zend_hash_index_del(&EG(regular_list), net_stream->rsrc_id); net_stream 159 ext/mysqlnd/mysqlnd_net.c net_stream->in_free = 0; net_stream 162 ext/mysqlnd/mysqlnd_net.c DBG_RETURN(net_stream); net_stream 184 ext/mysqlnd/mysqlnd_net.c php_stream * net_stream = NULL; net_stream 201 ext/mysqlnd/mysqlnd_net.c net_stream = php_stream_xport_create(scheme, scheme_len, streams_options, streams_flags, net_stream 204 ext/mysqlnd/mysqlnd_net.c if (errstr || !net_stream) { net_stream 233 ext/mysqlnd/mysqlnd_net.c net_stream->in_free = 1; net_stream 235 ext/mysqlnd/mysqlnd_net.c net_stream->in_free = 0; net_stream 239 ext/mysqlnd/mysqlnd_net.c net_stream->__exposed = 1; net_stream 249 ext/mysqlnd/mysqlnd_net.c net_stream->in_free = 1; net_stream 250 ext/mysqlnd/mysqlnd_net.c zend_hash_index_del(&EG(regular_list), net_stream->rsrc_id); net_stream 251 ext/mysqlnd/mysqlnd_net.c net_stream->in_free = 0; net_stream 253 ext/mysqlnd/mysqlnd_net.c DBG_RETURN(net_stream); net_stream 264 ext/mysqlnd/mysqlnd_net.c php_stream * net_stream = net->data->m.get_stream(net TSRMLS_CC); net_stream 266 ext/mysqlnd/mysqlnd_net.c if (net_stream) { net_stream 272 ext/mysqlnd/mysqlnd_net.c php_stream_set_option(net_stream, PHP_STREAM_OPTION_READ_TIMEOUT, 0, &tv); net_stream 277 ext/mysqlnd/mysqlnd_net.c mysqlnd_set_sock_no_delay(net_stream TSRMLS_CC); net_stream 279 ext/mysqlnd/mysqlnd_net.c mysqlnd_set_sock_keepalive(net_stream TSRMLS_CC); net_stream 329 ext/mysqlnd/mysqlnd_net.c php_stream * net_stream = open_stream(net, scheme, scheme_len, persistent, conn_stats, error_info TSRMLS_CC); net_stream 330 ext/mysqlnd/mysqlnd_net.c if (net_stream) { net_stream 331 ext/mysqlnd/mysqlnd_net.c (void) net->data->m.set_stream(net, net_stream TSRMLS_CC); net_stream 864 ext/mysqlnd/mysqlnd_net.c php_stream * net_stream = net->data->get_stream(net TSRMLS_CC); net_stream 865 ext/mysqlnd/mysqlnd_net.c int was_blocked = net_stream->ops->set_option(net_stream, opt, 0, NULL TSRMLS_CC); net_stream 874 ext/mysqlnd/mysqlnd_net.c skipped_bytes += (bytes_consumed = php_stream_read(net_stream, tmp_buf, sizeof(tmp_buf))); net_stream 878 ext/mysqlnd/mysqlnd_net.c net_stream->ops->set_option(net_stream, opt, 1, NULL TSRMLS_CC); net_stream 907 ext/mysqlnd/mysqlnd_net.c php_stream * net_stream = net->data->m.get_stream(net TSRMLS_CC); net_stream 974 ext/mysqlnd/mysqlnd_net.c php_stream_context_set(net_stream, context); net_stream 975 ext/mysqlnd/mysqlnd_net.c if (php_stream_xport_crypto_setup(net_stream, STREAM_CRYPTO_METHOD_TLS_CLIENT, NULL TSRMLS_CC) < 0 || net_stream 976 ext/mysqlnd/mysqlnd_net.c php_stream_xport_crypto_enable(net_stream, 1 TSRMLS_CC) < 0) net_stream 990 ext/mysqlnd/mysqlnd_net.c php_stream_context_set(net_stream, NULL); net_stream 997 ext/mysqlnd/mysqlnd_net.c php_stream_set_option(net_stream, PHP_STREAM_OPTION_READ_TIMEOUT, 0, &tv); net_stream 1066 ext/mysqlnd/mysqlnd_net.c php_stream * net_stream; net_stream 1068 ext/mysqlnd/mysqlnd_net.c if (net && (net_stream = net->data->m.get_stream(net TSRMLS_CC))) { net_stream 1070 ext/mysqlnd/mysqlnd_net.c DBG_INF_FMT("Freeing stream. abstract=%p", net_stream->abstract); net_stream 1073 ext/mysqlnd/mysqlnd_net.c php_stream_free(net_stream, PHP_STREAM_FREE_CLOSE_PERSISTENT | PHP_STREAM_FREE_RSRC_DTOR); net_stream 1079 ext/mysqlnd/mysqlnd_net.c php_stream_free(net_stream, PHP_STREAM_FREE_CLOSE | PHP_STREAM_FREE_RSRC_DTOR); net_stream 1082 ext/mysqlnd/mysqlnd_net.c php_stream_free(net_stream, PHP_STREAM_FREE_CLOSE); net_stream 1149 ext/mysqlnd/mysqlnd_net.c MYSQLND_METHOD(mysqlnd_net, set_stream)(MYSQLND_NET * const net, php_stream * net_stream TSRMLS_DC) net_stream 1154 ext/mysqlnd/mysqlnd_net.c net->data->stream = net_stream; net_stream 307 ext/mysqlnd/mysqlnd_structs.h typedef php_stream * (*func_mysqlnd_net__set_stream)(MYSQLND_NET * const net, php_stream * net_stream TSRMLS_DC);