net_stream 1903 ext/mysqlnd/mysqlnd.c php_stream * net_stream = net->data->m.get_stream(net); net_stream 1907 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 1920 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); 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 142 ext/mysqlnd/mysqlnd_net.c php_stream * net_stream = NULL; net_stream 149 ext/mysqlnd/mysqlnd_net.c net_stream = php_stream_open_wrapper((char*) scheme + sizeof("pipe://") - 1, "r+", streams_options, NULL); net_stream 150 ext/mysqlnd/mysqlnd_net.c if (!net_stream) { net_stream 161 ext/mysqlnd/mysqlnd_net.c zend_hash_index_del(&EG(regular_list), net_stream->res->handle); /* ToDO: should it be res->handle, do streams register with addref ?*/ net_stream 163 ext/mysqlnd/mysqlnd_net.c net_stream->res = NULL; net_stream 165 ext/mysqlnd/mysqlnd_net.c DBG_RETURN(net_stream); net_stream 188 ext/mysqlnd/mysqlnd_net.c php_stream * net_stream = NULL; net_stream 205 ext/mysqlnd/mysqlnd_net.c net_stream = php_stream_xport_create(scheme, scheme_len, streams_options, streams_flags, net_stream 208 ext/mysqlnd/mysqlnd_net.c if (errstr || !net_stream) { net_stream 245 ext/mysqlnd/mysqlnd_net.c net_stream->__exposed = 1; net_stream 257 ext/mysqlnd/mysqlnd_net.c zend_hash_index_del(&EG(regular_list), net_stream->res->handle); /* ToDO: should it be res->handle, do streams register with addref ?*/ net_stream 258 ext/mysqlnd/mysqlnd_net.c efree(net_stream->res); net_stream 259 ext/mysqlnd/mysqlnd_net.c net_stream->res = NULL; net_stream 261 ext/mysqlnd/mysqlnd_net.c DBG_RETURN(net_stream); net_stream 272 ext/mysqlnd/mysqlnd_net.c php_stream * net_stream = net->data->m.get_stream(net); net_stream 274 ext/mysqlnd/mysqlnd_net.c if (net_stream) { net_stream 280 ext/mysqlnd/mysqlnd_net.c php_stream_set_option(net_stream, PHP_STREAM_OPTION_READ_TIMEOUT, 0, &tv); net_stream 285 ext/mysqlnd/mysqlnd_net.c mysqlnd_set_sock_no_delay(net_stream); net_stream 287 ext/mysqlnd/mysqlnd_net.c mysqlnd_set_sock_keepalive(net_stream); net_stream 337 ext/mysqlnd/mysqlnd_net.c php_stream * net_stream = open_stream(net, scheme, scheme_len, persistent, conn_stats, error_info); net_stream 338 ext/mysqlnd/mysqlnd_net.c if (net_stream) { net_stream 339 ext/mysqlnd/mysqlnd_net.c (void) net->data->m.set_stream(net, net_stream); net_stream 872 ext/mysqlnd/mysqlnd_net.c php_stream * net_stream = net->data->get_stream(net); net_stream 873 ext/mysqlnd/mysqlnd_net.c int was_blocked = net_stream->ops->set_option(net_stream, opt, 0, NULL); net_stream 882 ext/mysqlnd/mysqlnd_net.c skipped_bytes += (bytes_consumed = php_stream_read(net_stream, tmp_buf, sizeof(tmp_buf))); net_stream 886 ext/mysqlnd/mysqlnd_net.c net_stream->ops->set_option(net_stream, opt, 1, NULL); net_stream 915 ext/mysqlnd/mysqlnd_net.c php_stream * net_stream = net->data->m.get_stream(net); net_stream 987 ext/mysqlnd/mysqlnd_net.c php_stream_context_set(net_stream, context); net_stream 989 ext/mysqlnd/mysqlnd_net.c php_stream_context_set(net_stream, context); net_stream 991 ext/mysqlnd/mysqlnd_net.c if (php_stream_xport_crypto_setup(net_stream, STREAM_CRYPTO_METHOD_TLS_CLIENT, NULL) < 0 || net_stream 992 ext/mysqlnd/mysqlnd_net.c php_stream_xport_crypto_enable(net_stream, 1) < 0) net_stream 1007 ext/mysqlnd/mysqlnd_net.c php_stream_context_set(net_stream, NULL); net_stream 1009 ext/mysqlnd/mysqlnd_net.c php_stream_context_set(net_stream, NULL); net_stream 1017 ext/mysqlnd/mysqlnd_net.c php_stream_set_option(net_stream, PHP_STREAM_OPTION_READ_TIMEOUT, 0, &tv); net_stream 1086 ext/mysqlnd/mysqlnd_net.c php_stream * net_stream; net_stream 1088 ext/mysqlnd/mysqlnd_net.c if (net && (net_stream = net->data->m.get_stream(net))) { net_stream 1090 ext/mysqlnd/mysqlnd_net.c DBG_INF_FMT("Freeing stream. abstract=%p", net_stream->abstract); net_stream 1093 ext/mysqlnd/mysqlnd_net.c php_stream_free(net_stream, PHP_STREAM_FREE_CLOSE_PERSISTENT | PHP_STREAM_FREE_RSRC_DTOR); net_stream 1099 ext/mysqlnd/mysqlnd_net.c php_stream_free(net_stream, PHP_STREAM_FREE_CLOSE | PHP_STREAM_FREE_RSRC_DTOR); net_stream 1102 ext/mysqlnd/mysqlnd_net.c php_stream_free(net_stream, PHP_STREAM_FREE_CLOSE); net_stream 1169 ext/mysqlnd/mysqlnd_net.c MYSQLND_METHOD(mysqlnd_net, set_stream)(MYSQLND_NET * const net, php_stream * net_stream) net_stream 1174 ext/mysqlnd/mysqlnd_net.c net->data->stream = net_stream; net_stream 306 ext/mysqlnd/mysqlnd_structs.h typedef php_stream * (*func_mysqlnd_net__set_stream)(MYSQLND_NET * const net, php_stream * net_stream);