Lines Matching refs:stream
43 mysqlnd_set_sock_no_delay(php_stream * stream TSRMLS_DC) in mysqlnd_set_sock_no_delay()
46 int socketd = ((php_netstream_data_t*)stream->abstract)->socket; in mysqlnd_set_sock_no_delay()
68 size_t old_chunk_size = conn->net->stream->chunk_size; in MYSQLND_METHOD()
71 conn->net->stream->chunk_size = MIN(to_read, conn->net->options.net_read_buffer_size); in MYSQLND_METHOD()
73 if (!(ret = php_stream_read(conn->net->stream, (char *) buffer, to_read))) { in MYSQLND_METHOD()
82 conn->net->stream->chunk_size = old_chunk_size; in MYSQLND_METHOD()
94 ret = php_stream_write(conn->net->stream, (char *)buf, count); in MYSQLND_METHOD()
123 if (net->stream) { in MYSQLND_METHOD()
125 DBG_INF_FMT("Freeing stream. abstract=%p", net->stream->abstract); in MYSQLND_METHOD()
127 php_stream_free(net->stream, PHP_STREAM_FREE_CLOSE_PERSISTENT | PHP_STREAM_FREE_RSRC_DTOR); in MYSQLND_METHOD()
129 php_stream_free(net->stream, PHP_STREAM_FREE_CLOSE); in MYSQLND_METHOD()
131 net->stream = NULL; in MYSQLND_METHOD()
140 net->stream = php_stream_xport_create(scheme, scheme_len, streams_options, streams_flags, in MYSQLND_METHOD()
144 if (*errstr || !net->stream) { in MYSQLND_METHOD()
166 net->stream->in_free = 1; in MYSQLND_METHOD()
168 net->stream->in_free = 0; in MYSQLND_METHOD()
172 net->stream->__exposed = 1; in MYSQLND_METHOD()
181 net->stream->in_free = 1; in MYSQLND_METHOD()
182 zend_hash_index_del(&EG(regular_list), net->stream->rsrc_id); in MYSQLND_METHOD()
183 net->stream->in_free = 0; in MYSQLND_METHOD()
193 php_stream_set_option(net->stream, PHP_STREAM_OPTION_READ_TIMEOUT, 0, &tv); in MYSQLND_METHOD()
198 mysqlnd_set_sock_no_delay(net->stream TSRMLS_CC); in MYSQLND_METHOD()
238 size_t old_chunk_size = net->stream->chunk_size; in MYSQLND_METHOD()
248 net->stream->chunk_size = MYSQLND_MAX_PACKET_SIZE; in MYSQLND_METHOD()
345 net->stream->chunk_size = old_chunk_size; in MYSQLND_METHOD()
706 int was_blocked = net->stream->ops->set_option(net->stream, opt, 0, NULL TSRMLS_CC); in MYSQLND_METHOD()
715 skipped_bytes += (bytes_consumed = php_stream_read(net->stream, tmp_buf, sizeof(tmp_buf))); in MYSQLND_METHOD()
719 net->stream->ops->set_option(net->stream, opt, 1, NULL TSRMLS_CC); in MYSQLND_METHOD()
797 php_stream_context_set(net->stream, context); in MYSQLND_METHOD()
798 …if (php_stream_xport_crypto_setup(net->stream, STREAM_CRYPTO_METHOD_TLS_CLIENT, NULL TSRMLS_CC) < … in MYSQLND_METHOD()
799 php_stream_xport_crypto_enable(net->stream, 1 TSRMLS_CC) < 0) in MYSQLND_METHOD()
812 php_stream_context_set(net->stream, NULL); in MYSQLND_METHOD()
819 php_stream_set_option(net->stream, PHP_STREAM_OPTION_READ_TIMEOUT, 0, &tv); in MYSQLND_METHOD()
933 if (net->stream) { in mysqlnd_net_free()
934 DBG_INF_FMT("Freeing stream. abstract=%p", net->stream->abstract); in mysqlnd_net_free()
936 php_stream_free(net->stream, PHP_STREAM_FREE_CLOSE_PERSISTENT | PHP_STREAM_FREE_RSRC_DTOR); in mysqlnd_net_free()
938 php_stream_free(net->stream, PHP_STREAM_FREE_CLOSE); in mysqlnd_net_free()
940 net->stream = NULL; in mysqlnd_net_free()
