refactor MYSQLND_NET, split it two parts for easy resharing

diff --git a/ext/mysqlnd/mysqlnd.c b/ext/mysqlnd/mysqlnd.c
index 797cadd62420dccaf7dc59c6a7541274d64d5c42..300a7eea56dccd2e5375659bff8dae8ae0ce8aa6 100644 (file)
--- a/ext/mysqlnd/mysqlnd.c
+++ b/ext/mysqlnd/mysqlnd.c
@@ -114,7 +114,7 @@ MYSQLND_METHOD(mysqlnd_conn_data, free_contents)(MYSQLND_CONN_DATA * conn TSRMLS
        }
 
        if (conn->net) {
-               conn->net->m.free_contents(conn->net TSRMLS_CC);
+               conn->net->data->m.free_contents(conn->net TSRMLS_CC);
        }
 
        DBG_INF("Freeing memory of members");
@@ -457,9 +457,9 @@ mysqlnd_switch_to_ssl_if_needed(
                        goto end;
                }
 
-               conn->net->m.set_client_option(conn->net, MYSQL_OPT_SSL_VERIFY_SERVER_CERT, (const char *) &verify TSRMLS_CC);
+               conn->net->data->m.set_client_option(conn->net, MYSQL_OPT_SSL_VERIFY_SERVER_CERT, (const char *) &verify TSRMLS_CC);
 
-               if (FAIL == conn->net->m.enable_ssl(conn->net TSRMLS_CC)) {
+               if (FAIL == conn->net->data->m.enable_ssl(conn->net TSRMLS_CC)) {
                        goto end;
                }
        }
@@ -623,6 +623,7 @@ MYSQLND_METHOD(mysqlnd_conn_data, connect)(MYSQLND_CONN_DATA * conn,
        zend_bool reconnect = FALSE;
        zend_bool saved_compression = FALSE;
        zend_bool local_tx_started = FALSE;
+       MYSQLND_NET * net = conn->net;
 
        MYSQLND_PACKET_GREET * greet_packet = NULL;
 
@@ -655,14 +656,14 @@ MYSQLND_METHOD(mysqlnd_conn_data, connect)(MYSQLND_CONN_DATA * conn,
                        MYSQLND_DEC_CONN_STATISTIC(conn->stats, STAT_OPENED_PERSISTENT_CONNECTIONS);
                }
                /* Now reconnect using the same handle */
-               if (conn->net->compressed) {
+               if (net->data->compressed) {
                        /*
                          we need to save the state. As we will re-connect, net->compressed should be off, or
                          we will look for a compression header as part of the greet message, but there will
                          be none.
                        */
                        saved_compression = TRUE;
-                       conn->net->compressed = FALSE;
+                       net->data->compressed = FALSE;
                }
        } else {
                unsigned int max_allowed_size = MYSQLND_ASSEMBLED_PACKET_MAX_SIZE;
@@ -734,13 +735,13 @@ MYSQLND_METHOD(mysqlnd_conn_data, connect)(MYSQLND_CONN_DATA * conn,
                goto err; /* OOM */
        }
 
-       if (FAIL == conn->net->m.connect_ex(conn->net, conn->scheme, conn->scheme_len, conn->persistent,
+       if (FAIL == net->data->m.connect_ex(conn->net, conn->scheme, conn->scheme_len, conn->persistent,
                                                                                conn->stats, conn->error_info TSRMLS_CC))
        {
                goto err;
        }
 
-       DBG_INF_FMT("stream=%p", conn->net->stream);
+       DBG_INF_FMT("stream=%p", net->data->m.get_stream(net TSRMLS_CC));
 
        if (FAIL == PACKET_READ(greet_packet, conn)) {
                DBG_ERR("Error while reading greeting packet");
@@ -780,7 +781,7 @@ MYSQLND_METHOD(mysqlnd_conn_data, connect)(MYSQLND_CONN_DATA * conn,
                mysql_flags &= ~CLIENT_COMPRESS;
        }
 #else
-       if (conn->net->options.flags & MYSQLND_NET_FLAG_USE_COMPRESSION) {
+       if (net->data->options.flags & MYSQLND_NET_FLAG_USE_COMPRESSION) {
                mysql_flags |= CLIENT_COMPRESS;
        }
 #endif
@@ -789,8 +790,8 @@ MYSQLND_METHOD(mysqlnd_conn_data, connect)(MYSQLND_CONN_DATA * conn,
                mysql_flags &= ~CLIENT_SSL;
        }
 #else
-       if (conn->net->options.ssl_key || conn->net->options.ssl_cert ||
-               conn->net->options.ssl_ca || conn->net->options.ssl_capath || conn->net->options.ssl_cipher)
+       if (net->data->options.ssl_key || net->data->options.ssl_cert ||
+               net->data->options.ssl_ca || net->data->options.ssl_capath || net->data->options.ssl_cipher)
        {
                mysql_flags |= CLIENT_SSL;
        }
@@ -806,14 +807,14 @@ MYSQLND_METHOD(mysqlnd_conn_data, connect)(MYSQLND_CONN_DATA * conn,
                CONN_SET_STATE(conn, CONN_READY);
 
                if (saved_compression) {
-                       conn->net->compressed = TRUE;
+                       net->data->compressed = TRUE;
                }
                /*
                  If a connect on a existing handle is performed and mysql_flags is
                  passed which doesn't CLIENT_COMPRESS, then we need to overwrite the value
                  which we set based on saved_compression.
                */
-               conn->net->compressed = mysql_flags & CLIENT_COMPRESS? TRUE:FALSE;
+               net->data->compressed = mysql_flags & CLIENT_COMPRESS? TRUE:FALSE;
 
                conn->user                              = mnd_pestrdup(user, conn->persistent);
                conn->user_len                  = strlen(conn->user);
@@ -1142,7 +1143,7 @@ static int mysqlnd_stream_array_to_fd_set(MYSQLND ** conn_array, fd_set * fds, p
                 * when casting.  It is only used here so that the buffered data warning
                 * is not displayed.
                 * */
-               if (SUCCESS == php_stream_cast((*p)->data->net->stream, PHP_STREAM_AS_FD_FOR_SELECT | PHP_STREAM_CAST_INTERNAL,
+               if (SUCCESS == php_stream_cast((*p)->data->net->data->m.get_stream((*p)->data->net TSRMLS_CC), PHP_STREAM_AS_FD_FOR_SELECT | PHP_STREAM_CAST_INTERNAL,
                                                                                (void*)&this_fd, 1) && this_fd >= 0) {
 
                        PHP_SAFE_FD_SET(this_fd, fds);
@@ -1167,7 +1168,7 @@ static int mysqlnd_stream_array_from_fd_set(MYSQLND ** conn_array, fd_set * fds
        MYSQLND **fwd = conn_array, **bckwd = conn_array;
 
        while (*fwd) {
-               if (SUCCESS == php_stream_cast((*fwd)->data->net->stream, PHP_STREAM_AS_FD_FOR_SELECT | PHP_STREAM_CAST_INTERNAL,
+               if (SUCCESS == php_stream_cast((*fwd)->data->net->data->m.get_stream((*fwd)->data->net TSRMLS_CC), PHP_STREAM_AS_FD_FOR_SELECT | PHP_STREAM_CAST_INTERNAL,
                                                                                (void*)&this_fd, 1) && this_fd >= 0) {
                        if (PHP_SAFE_FD_ISSET(this_fd, fds)) {
                                if (disproportion) {
@@ -1438,14 +1439,15 @@ MYSQLND_METHOD(mysqlnd_conn_data, ssl_set)(MYSQLND_CONN_DATA * const conn, const
 {
        size_t this_func = STRUCT_OFFSET(struct st_mysqlnd_conn_data_methods, ssl_set);
        enum_func_status ret = FAIL;
+       MYSQLND_NET * net = conn->net;
        DBG_ENTER("mysqlnd_conn_data::ssl_set");
 
        if (PASS == conn->m->local_tx_start(conn, this_func TSRMLS_CC)) {
-               ret = (PASS == conn->net->m.set_client_option(conn->net, MYSQLND_OPT_SSL_KEY, key TSRMLS_CC) &&
-                       PASS == conn->net->m.set_client_option(conn->net, MYSQLND_OPT_SSL_CERT, cert TSRMLS_CC) &&
-                       PASS == conn->net->m.set_client_option(conn->net, MYSQLND_OPT_SSL_CA, ca TSRMLS_CC) &&
-                       PASS == conn->net->m.set_client_option(conn->net, MYSQLND_OPT_SSL_CAPATH, capath TSRMLS_CC) &&
-                       PASS == conn->net->m.set_client_option(conn->net, MYSQLND_OPT_SSL_CIPHER, cipher TSRMLS_CC)) ? PASS : FAIL;
+               ret = (PASS == net->data->m.set_client_option(net, MYSQLND_OPT_SSL_KEY, key TSRMLS_CC) &&
+                       PASS == net->data->m.set_client_option(net, MYSQLND_OPT_SSL_CERT, cert TSRMLS_CC) &&
+                       PASS == net->data->m.set_client_option(net, MYSQLND_OPT_SSL_CA, ca TSRMLS_CC) &&
+                       PASS == net->data->m.set_client_option(net, MYSQLND_OPT_SSL_CAPATH, capath TSRMLS_CC) &&
+                       PASS == net->data->m.set_client_option(net, MYSQLND_OPT_SSL_CIPHER, cipher TSRMLS_CC)) ? PASS : FAIL;
 
                conn->m->local_tx_end(conn, this_func, ret TSRMLS_CC);
        }
@@ -1717,10 +1719,11 @@ static enum_func_status
 MYSQLND_METHOD(mysqlnd_conn_data, send_close)(MYSQLND_CONN_DATA * const conn TSRMLS_DC)
 {
        enum_func_status ret = PASS;
+       MYSQLND_NET * net = conn->net;
+       php_stream * net_stream = net->data->m.get_stream(net TSRMLS_CC);
 
        DBG_ENTER("mysqlnd_send_close");
-       DBG_INF_FMT("conn=%llu conn->net->stream->abstract=%p",
-                               conn->thread_id, conn->net->stream? conn->net->stream->abstract:NULL);
+       DBG_INF_FMT("conn=%llu net->data->stream->abstract=%p", conn->thread_id, net_stream? net_stream->abstract:NULL);
 
        if (CONN_GET_STATE(conn) >= CONN_READY) {
                MYSQLND_DEC_CONN_STATISTIC(conn->stats, STAT_OPENED_CONNECTIONS);
@@ -1731,7 +1734,7 @@ MYSQLND_METHOD(mysqlnd_conn_data, send_close)(MYSQLND_CONN_DATA * const conn TSR
        switch (CONN_GET_STATE(conn)) {
                case CONN_READY:
                        DBG_INF("Connection clean, sending COM_QUIT");
-                       if (conn->net->stream) {
+                       if (net_stream) {
                                ret = conn->m->simple_command(conn, COM_QUIT, NULL, 0, PROT_LAST, TRUE, TRUE TSRMLS_CC);
                        }
                        /* Do nothing */
@@ -2264,7 +2267,7 @@ MYSQLND_METHOD(mysqlnd_conn_data, set_client_option)(MYSQLND_CONN_DATA * const c
                case MYSQL_OPT_CONNECT_TIMEOUT:
                case MYSQLND_OPT_NET_CMD_BUFFER_SIZE:
                case MYSQLND_OPT_NET_READ_BUFFER_SIZE:
-                       ret = conn->net->m.set_client_option(conn->net, option, value TSRMLS_CC);
+                       ret = conn->net->data->m.set_client_option(conn->net, option, value TSRMLS_CC);
                        break;
 #if MYSQLND_UNICODE
                case MYSQLND_OPT_NUMERIC_AND_DATETIME_AS_UNICODE:

diff --git a/ext/mysqlnd/mysqlnd_driver.c b/ext/mysqlnd/mysqlnd_driver.c
index e645b88935045413ba940af67c654539aa1fa7c8..e55a0bc2eea059090ca4e351a6a374d1266c9b59 100644 (file)
--- a/ext/mysqlnd/mysqlnd_driver.c
+++ b/ext/mysqlnd/mysqlnd_driver.c
@@ -249,17 +249,29 @@ MYSQLND_METHOD(mysqlnd_object_factory, get_prepared_statement)(MYSQLND_CONN_DATA
 PHPAPI MYSQLND_NET *
 MYSQLND_METHOD(mysqlnd_object_factory, get_io_channel)(zend_bool persistent, MYSQLND_STATS * stats, MYSQLND_ERROR_INFO * error_info TSRMLS_DC)
 {
-       size_t alloc_size = sizeof(MYSQLND_NET) + mysqlnd_plugin_count() * sizeof(void *);
-       MYSQLND_NET * net = mnd_pecalloc(1, alloc_size, persistent);
+       size_t net_alloc_size = sizeof(MYSQLND_NET) + mysqlnd_plugin_count() * sizeof(void *);
+       size_t net_data_alloc_size = sizeof(MYSQLND_NET_DATA) + mysqlnd_plugin_count() * sizeof(void *);
+       MYSQLND_NET * net = mnd_pecalloc(1, net_alloc_size, persistent);
+       MYSQLND_NET_DATA * net_data = mnd_pecalloc(1, net_data_alloc_size, persistent);
 
        DBG_ENTER("mysqlnd_object_factory::get_io_channel");
        DBG_INF_FMT("persistent=%u", persistent);
-       if (net) {
-               net->persistent = persistent;
-               net->m = *mysqlnd_net_get_methods();
+       if (net && net_data) {
+               net->data = net_data;
+               net->persistent = net->data->persistent = persistent;
+               net->data->m = *mysqlnd_net_get_methods();
 
-               if (PASS != net->m.init(net, stats, error_info TSRMLS_CC)) {
-                       net->m.dtor(net, stats, error_info TSRMLS_CC);
+               if (PASS != net->data->m.init(net, stats, error_info TSRMLS_CC)) {
+                       net->data->m.dtor(net, stats, error_info TSRMLS_CC);
+                       net = NULL;
+               }
+       } else {
+               if (net_data) {
+                       mnd_pefree(net_data, persistent);
+                       net_data = NULL;
+               }
+               if (net) {
+                       mnd_pefree(net, persistent);
                        net = NULL;
                }
        }

diff --git a/ext/mysqlnd/mysqlnd_loaddata.c b/ext/mysqlnd/mysqlnd_loaddata.c
index 8e8622e54045770d7dd6e7a724a5085ed2fe4815..61cf235988bb9636c3cbab5e1ba4122c16b8df23 100644 (file)
--- a/ext/mysqlnd/mysqlnd_loaddata.c
+++ b/ext/mysqlnd/mysqlnd_loaddata.c
@@ -172,7 +172,7 @@ mysqlnd_handle_local_infile(MYSQLND_CONN_DATA * conn, const char * filename, zen
        if (!(conn->options->flags & CLIENT_LOCAL_FILES)) {
                php_error_docref(NULL TSRMLS_CC, E_WARNING, "LOAD DATA LOCAL INFILE forbidden");
                /* write empty packet to server */
-               ret = net->m.send_ex(net, empty_packet, 0, conn->stats, conn->error_info TSRMLS_CC);
+               ret = net->data->m.send_ex(net, empty_packet, 0, conn->stats, conn->error_info TSRMLS_CC);
                *is_warning = TRUE;
                goto infile_error;
        }
@@ -192,13 +192,13 @@ mysqlnd_handle_local_infile(MYSQLND_CONN_DATA * conn, const char * filename, zen
                tmp_error_no = infile.local_infile_error(info, tmp_buf, sizeof(tmp_buf) TSRMLS_CC);
                SET_CLIENT_ERROR(*conn->error_info, tmp_error_no, UNKNOWN_SQLSTATE, tmp_buf);
                /* write empty packet to server */
-               ret = net->m.send_ex(net, empty_packet, 0, conn->stats, conn->error_info TSRMLS_CC);
+               ret = net->data->m.send_ex(net, empty_packet, 0, conn->stats, conn->error_info TSRMLS_CC);
                goto infile_error;
        }
 
        /* read data */
        while ((bufsize = infile.local_infile_read (info, buf + MYSQLND_HEADER_SIZE, buflen - MYSQLND_HEADER_SIZE TSRMLS_CC)) > 0) {
-               if ((ret = net->m.send_ex(net, buf, bufsize, conn->stats, conn->error_info TSRMLS_CC)) == 0) {
+               if ((ret = net->data->m.send_ex(net, buf, bufsize, conn->stats, conn->error_info TSRMLS_CC)) == 0) {
                        DBG_ERR_FMT("Error during read : %d %s %s", CR_SERVER_LOST, UNKNOWN_SQLSTATE, lost_conn);
                        SET_CLIENT_ERROR(*conn->error_info, CR_SERVER_LOST, UNKNOWN_SQLSTATE, lost_conn);
                        goto infile_error;
@@ -206,7 +206,7 @@ mysqlnd_handle_local_infile(MYSQLND_CONN_DATA * conn, const char * filename, zen
        }
 
        /* send empty packet for eof */
-       if ((ret = net->m.send_ex(net, empty_packet, 0, conn->stats, conn->error_info TSRMLS_CC)) == 0) {
+       if ((ret = net->data->m.send_ex(net, empty_packet, 0, conn->stats, conn->error_info TSRMLS_CC)) == 0) {
                SET_CLIENT_ERROR(*conn->error_info, CR_SERVER_LOST, UNKNOWN_SQLSTATE, lost_conn);
                goto infile_error;
        }

diff --git a/ext/mysqlnd/mysqlnd_net.c b/ext/mysqlnd/mysqlnd_net.c
index 800f577332e4052ca82dc0219ceb01d430c5c8f5..3f332aea0d512f96f290217058ccb5ff4ce134a0 100644 (file)
--- a/ext/mysqlnd/mysqlnd_net.c
+++ b/ext/mysqlnd/mysqlnd_net.c
@@ -67,16 +67,17 @@ MYSQLND_METHOD(mysqlnd_net, network_read_ex)(MYSQLND_NET * const net, zend_uchar
                                                                                         MYSQLND_STATS * const stats, MYSQLND_ERROR_INFO * const error_info TSRMLS_DC)
 {
        enum_func_status return_value = PASS;
+       php_stream * net_stream = net->data->m.get_stream(net TSRMLS_CC);
+       size_t old_chunk_size = net_stream->chunk_size;
        size_t to_read = count, ret;
-       size_t old_chunk_size = net->stream->chunk_size;
        zend_uchar * p = buffer;
 
        DBG_ENTER("mysqlnd_net::network_read_ex");
        DBG_INF_FMT("count="MYSQLND_SZ_T_SPEC, count);
 
-       net->stream->chunk_size = MIN(to_read, net->options.net_read_buffer_size);
+       net_stream->chunk_size = MIN(to_read, net->data->options.net_read_buffer_size);
        while (to_read) {
-               if (!(ret = php_stream_read(net->stream, (char *) p, to_read))) {
+               if (!(ret = php_stream_read(net_stream, (char *) p, to_read))) {
                        DBG_ERR_FMT("Error while reading header from socket");
                        return_value = FAIL;
                        break;
@@ -85,7 +86,7 @@ MYSQLND_METHOD(mysqlnd_net, network_read_ex)(MYSQLND_NET * const net, zend_uchar
                to_read -= ret;
        }
        MYSQLND_INC_CONN_STATISTIC_W_VALUE(stats, STAT_BYTES_RECEIVED, count - to_read);
-       net->stream->chunk_size = old_chunk_size;
+       net_stream->chunk_size = old_chunk_size;
        DBG_RETURN(return_value);
 }
 /* }}} */
@@ -98,7 +99,7 @@ MYSQLND_METHOD(mysqlnd_net, network_write_ex)(MYSQLND_NET * const net, const zen
 {
        size_t ret;
        DBG_ENTER("mysqlnd_net::network_write_ex");
-       ret = php_stream_write(net->stream, (char *)buffer, count);
+       ret = php_stream_write(net->data->m.get_stream(net TSRMLS_CC), (char *)buffer, count);
        DBG_RETURN(ret);
 }
 /* }}} */
@@ -114,13 +115,15 @@ MYSQLND_METHOD(mysqlnd_net, open_pipe)(MYSQLND_NET * const net, const char * con
 #else
        unsigned int streams_options = 0;
 #endif
+       php_stream * net_stream = NULL;
+
        DBG_ENTER("mysqlnd_net::open_pipe");
        if (persistent) {
                streams_options |= STREAM_OPEN_PERSISTENT;
        }
        streams_options |= IGNORE_URL;
-       net->stream = php_stream_open_wrapper((char*) scheme + sizeof("pipe://") - 1, "r+", streams_options, NULL);
-       if (!net->stream) {
+       net_stream = php_stream_open_wrapper((char*) scheme + sizeof("pipe://") - 1, "r+", streams_options, NULL);
+       if (!net_stream) {
                SET_CLIENT_ERROR(*error_info, CR_CONNECTION_ERROR, UNKNOWN_SQLSTATE, "Unknown errror while connecting");
                DBG_RETURN(FAIL);
        }
@@ -129,9 +132,11 @@ MYSQLND_METHOD(mysqlnd_net, open_pipe)(MYSQLND_NET * const net, const char * con
          be registered as resource (in EG(regular_list). So far, so good. However, it won't be
          unregistered yntil the script ends. So, we need to take care of that.
        */
-       net->stream->in_free = 1;
-       zend_hash_index_del(&EG(regular_list), net->stream->rsrc_id);
-       net->stream->in_free = 0;
+       net_stream->in_free = 1;
+       zend_hash_index_del(&EG(regular_list), net_stream->rsrc_id);
+       net_stream->in_free = 0;
+
+       (void) net->data->m.set_stream(net, net_stream TSRMLS_CC);
 
        DBG_RETURN(PASS);
 }
@@ -155,24 +160,27 @@ MYSQLND_METHOD(mysqlnd_net, open_tcp_or_unix)(MYSQLND_NET * const net, const cha
        char * errstr = NULL;
        int errcode = 0;
        struct timeval tv;
+       php_stream * net_stream = NULL;
 
        DBG_ENTER("mysqlnd_net::open_tcp_or_unix");
 
+       net->data->stream = NULL;
+
        if (persistent) {
                hashed_details_len = mnd_sprintf(&hashed_details, 0, "%p", net);
                DBG_INF_FMT("hashed_details=%s", hashed_details);
        }
 
-       if (net->options.timeout_connect) {
-               tv.tv_sec = net->options.timeout_connect;
+       if (net->data->options.timeout_connect) {
+               tv.tv_sec = net->data->options.timeout_connect;
                tv.tv_usec = 0;
        }
 
        DBG_INF_FMT("calling php_stream_xport_create");
-       net->stream = php_stream_xport_create(scheme, scheme_len, streams_options, streams_flags,
-                                                                                 hashed_details, (net->options.timeout_connect) ? &tv : NULL,
+       net_stream = php_stream_xport_create(scheme, scheme_len, streams_options, streams_flags,
+                                                                                 hashed_details, (net->data->options.timeout_connect) ? &tv : NULL,
                                                                                  NULL /*ctx*/, &errstr, &errcode);
-       if (errstr || !net->stream) {
+       if (errstr || !net_stream) {
                DBG_ERR("Error");
                if (hashed_details) {
                        mnd_sprintf_free(hashed_details);
@@ -199,13 +207,13 @@ MYSQLND_METHOD(mysqlnd_net, open_tcp_or_unix)(MYSQLND_NET * const net, const cha
                          but STREAMS suck big time regarding persistent streams.
                          Just not compatible for extensions that need persistency.
                        */
-                       net->stream->in_free = 1;
+                       net_stream->in_free = 1;
                        zend_hash_del(&EG(persistent_list), hashed_details, hashed_details_len + 1);
-                       net->stream->in_free = 0;
+                       net_stream->in_free = 0;
                }
 #if ZEND_DEBUG
                /* Shut-up the streams, they don't know what they are doing */
-               net->stream->__exposed = 1;
+               net_stream->__exposed = 1;
 #endif
                mnd_sprintf_free(hashed_details);
        }
@@ -215,33 +223,35 @@ MYSQLND_METHOD(mysqlnd_net, open_tcp_or_unix)(MYSQLND_NET * const net, const cha
          be registered as resource (in EG(regular_list). So far, so good. However, it won't be
          unregistered yntil the script ends. So, we need to take care of that.
        */
-       net->stream->in_free = 1;
-       zend_hash_index_del(&EG(regular_list), net->stream->rsrc_id);
-       net->stream->in_free = 0;
+       net_stream->in_free = 1;
+       zend_hash_index_del(&EG(regular_list), net_stream->rsrc_id);
+       net_stream->in_free = 0;
 
+       (void) net->data->m.set_stream(net, net_stream TSRMLS_CC);
        DBG_RETURN(PASS);
 }
 /* }}} */
 
 
-/* {{{ mysqlnd_net::connect_ex */
+/* {{{ mysqlnd_net::post_connect_set_opt */
 static void
 MYSQLND_METHOD(mysqlnd_net, post_connect_set_opt)(MYSQLND_NET * const net,
                                                                                                  const char * const scheme, const size_t scheme_len,
                                                                                                  MYSQLND_STATS * const conn_stats, MYSQLND_ERROR_INFO * const error_info TSRMLS_DC)
 {
+       php_stream * net_stream = net->data->m.get_stream(net TSRMLS_CC);
        DBG_ENTER("mysqlnd_net::post_connect_set_opt");
-       if (net->options.timeout_read) {
+       if (net->data->options.timeout_read) {
                struct timeval tv;
-               DBG_INF_FMT("setting %u as PHP_STREAM_OPTION_READ_TIMEOUT", net->options.timeout_read);
-               tv.tv_sec = net->options.timeout_read;
+               DBG_INF_FMT("setting %u as PHP_STREAM_OPTION_READ_TIMEOUT", net->data->options.timeout_read);
+               tv.tv_sec = net->data->options.timeout_read;
                tv.tv_usec = 0;
-               php_stream_set_option(net->stream, PHP_STREAM_OPTION_READ_TIMEOUT, 0, &tv);
+               php_stream_set_option(net_stream, PHP_STREAM_OPTION_READ_TIMEOUT, 0, &tv);
        }
 
        if (!memcmp(scheme, "tcp://", sizeof("tcp://") - 1)) {
                /* TCP -> Set TCP_NODELAY */
-               mysqlnd_set_sock_no_delay(net->stream TSRMLS_CC);
+               mysqlnd_set_sock_no_delay(net_stream TSRMLS_CC);
        }
 
        DBG_VOID_RETURN;
@@ -249,6 +259,24 @@ MYSQLND_METHOD(mysqlnd_net, post_connect_set_opt)(MYSQLND_NET * const net,
 /* }}} */
 
 
+/* {{{ mysqlnd_net::get_open_stream */
+static func_mysqlnd_net__open_stream
+MYSQLND_METHOD(mysqlnd_net, get_open_stream)(MYSQLND_NET * const net, const char * const scheme, const size_t scheme_len,
+                                                                                        MYSQLND_ERROR_INFO * const error_info TSRMLS_DC)
+{
+       func_mysqlnd_net__open_stream ret = NULL;
+       DBG_ENTER("mysqlnd_net::get_open_stream");
+       ret = (scheme_len > (sizeof("pipe://") - 1) && !memcmp(scheme, "pipe://", sizeof("pipe://") - 1))? net->data->m.open_pipe:
+                                                                                                                                                                                                          net->data->m.open_tcp_or_unix;
+       if (!ret) {
+               SET_CLIENT_ERROR(*error_info, CR_CONNECTION_ERROR, UNKNOWN_SQLSTATE, "No handler for this scheme");
+       }       
+       
+       DBG_RETURN(ret);
+}
+/* }}} */
+
+
 /* {{{ mysqlnd_net::connect_ex */
 static enum_func_status
 MYSQLND_METHOD(mysqlnd_net, connect_ex)(MYSQLND_NET * const net, const char * const scheme, const size_t scheme_len,
@@ -261,13 +289,13 @@ MYSQLND_METHOD(mysqlnd_net, connect_ex)(MYSQLND_NET * const net, const char * co
 
        net->packet_no = net->compressed_envelope_packet_no = 0;
 
-       net->m.close_stream(net, conn_stats, error_info TSRMLS_CC);
-
-       open_stream = (scheme_len > (sizeof("pipe://") - 1) && !memcmp(scheme, "pipe://", sizeof("pipe://") - 1))? net->m.open_pipe:
-                                                                                                                                                                                                                          net->m.open_tcp_or_unix;
+       net->data->m.close_stream(net, conn_stats, error_info TSRMLS_CC);
 
-       if (PASS == (ret = open_stream(net, scheme, scheme_len, persistent, conn_stats, error_info TSRMLS_CC))) {
-               net->m.post_connect_set_opt(net, scheme, scheme_len, conn_stats, error_info TSRMLS_CC);
+       open_stream = net->data->m.get_open_stream(net, scheme, scheme_len, error_info TSRMLS_CC);
+       if (open_stream) {
+               if (PASS == (ret = open_stream(net, scheme, scheme_len, persistent, conn_stats, error_info TSRMLS_CC))) {
+                       net->data->m.post_connect_set_opt(net, scheme, scheme_len, conn_stats, error_info TSRMLS_CC);
+               }
        }
 
        DBG_RETURN(ret);
@@ -309,9 +337,9 @@ MYSQLND_METHOD(mysqlnd_net, send_ex)(MYSQLND_NET * const net, zend_uchar * const
        size_t to_be_sent;
 
        DBG_ENTER("mysqlnd_net::send_ex");
-       DBG_INF_FMT("count=" MYSQLND_SZ_T_SPEC " compression=%u", count, net->compressed);
+       DBG_INF_FMT("count=" MYSQLND_SZ_T_SPEC " compression=%u", count, net->data->compressed);
 
-       if (net->compressed == TRUE) {
+       if (net->data->compressed == TRUE) {
                size_t comp_buf_size = MYSQLND_HEADER_SIZE + COMPRESSED_HEADER_SIZE + MYSQLND_HEADER_SIZE + MIN(left, MYSQLND_MAX_PACKET_SIZE);
                DBG_INF_FMT("compress_buf_size="MYSQLND_SZ_T_SPEC, comp_buf_size);
                compress_buf = mnd_emalloc(comp_buf_size);
@@ -320,7 +348,7 @@ MYSQLND_METHOD(mysqlnd_net, send_ex)(MYSQLND_NET * const net, zend_uchar * const
        do {
                to_be_sent = MIN(left, MYSQLND_MAX_PACKET_SIZE);
 #ifdef MYSQLND_COMPRESSION_ENABLED
-               if (net->compressed == TRUE) {
+               if (net->data->compressed == TRUE) {
                        /* here we need to compress the data and then write it, first comes the compressed header */
                        size_t tmp_complen = to_be_sent;
                        size_t payload_size;
@@ -329,7 +357,7 @@ MYSQLND_METHOD(mysqlnd_net, send_ex)(MYSQLND_NET * const net, zend_uchar * const
                        STORE_HEADER_SIZE(safe_storage, uncompressed_payload);
                        int3store(uncompressed_payload, to_be_sent);
                        int1store(uncompressed_payload + 3, net->packet_no);
-                       if (PASS == net->m.encode((compress_buf + COMPRESSED_HEADER_SIZE + MYSQLND_HEADER_SIZE), &tmp_complen,
+                       if (PASS == net->data->m.encode((compress_buf + COMPRESSED_HEADER_SIZE + MYSQLND_HEADER_SIZE), &tmp_complen,
                                                                           uncompressed_payload, to_be_sent + MYSQLND_HEADER_SIZE TSRMLS_CC))
                        {
                                int3store(compress_buf + MYSQLND_HEADER_SIZE, to_be_sent + MYSQLND_HEADER_SIZE);
@@ -344,14 +372,14 @@ MYSQLND_METHOD(mysqlnd_net, send_ex)(MYSQLND_NET * const net, zend_uchar * const
                        int3store(compress_buf, payload_size);
                        int1store(compress_buf + 3, net->packet_no);
                        DBG_INF_FMT("writing "MYSQLND_SZ_T_SPEC" bytes to the network", payload_size + MYSQLND_HEADER_SIZE + COMPRESSED_HEADER_SIZE);
-                       bytes_sent = net->m.network_write_ex(net, compress_buf, payload_size + MYSQLND_HEADER_SIZE + COMPRESSED_HEADER_SIZE,
+                       bytes_sent = net->data->m.network_write_ex(net, compress_buf, payload_size + MYSQLND_HEADER_SIZE + COMPRESSED_HEADER_SIZE,
                                                                                                 conn_stats, error_info TSRMLS_CC);
                        net->compressed_envelope_packet_no++;
   #if WHEN_WE_NEED_TO_CHECK_WHETHER_COMPRESSION_WORKS_CORRECTLY
                        if (res == Z_OK) {
                                size_t decompressed_size = left + MYSQLND_HEADER_SIZE;
                                zend_uchar * decompressed_data = mnd_malloc(decompressed_size);
-                               int error = net->m.decode(decompressed_data, decompressed_size,
+                               int error = net->data->m.decode(decompressed_data, decompressed_size,
                                                                                  compress_buf + MYSQLND_HEADER_SIZE + COMPRESSED_HEADER_SIZE, payload_size);
                                if (error == Z_OK) {
                                        int i;
@@ -376,7 +404,7 @@ MYSQLND_METHOD(mysqlnd_net, send_ex)(MYSQLND_NET * const net, zend_uchar * const
                        STORE_HEADER_SIZE(safe_storage, p);
                        int3store(p, to_be_sent);
                        int1store(p + 3, net->packet_no);
-                       bytes_sent = net->m.network_write_ex(net, p, to_be_sent + MYSQLND_HEADER_SIZE, conn_stats, error_info TSRMLS_CC);
+                       bytes_sent = net->data->m.network_write_ex(net, p, to_be_sent + MYSQLND_HEADER_SIZE, conn_stats, error_info TSRMLS_CC);
                        RESTORE_HEADER_SIZE(p, safe_storage);
                        net->compressed_envelope_packet_no++;
                }
@@ -492,7 +520,7 @@ MYSQLND_METHOD(mysqlnd_net, read_compressed_packet_from_stream_and_fill_read_buf
        DBG_ENTER("mysqlnd_net::read_compressed_packet_from_stream_and_fill_read_buffe");
 
        /* Read the compressed header */
-       if (FAIL == net->m.network_read_ex(net, comp_header, COMPRESSED_HEADER_SIZE, conn_stats, error_info TSRMLS_CC)) {
+       if (FAIL == net->data->m.network_read_ex(net, comp_header, COMPRESSED_HEADER_SIZE, conn_stats, error_info TSRMLS_CC)) {
                DBG_RETURN(FAIL);
        }
        decompressed_size = uint3korr(comp_header);
@@ -502,19 +530,19 @@ MYSQLND_METHOD(mysqlnd_net, read_compressed_packet_from_stream_and_fill_read_buf
 
        if (decompressed_size) {
                compressed_data = mnd_emalloc(net_payload_size);
-               if (FAIL == net->m.network_read_ex(net, compressed_data, net_payload_size, conn_stats, error_info TSRMLS_CC)) {
+               if (FAIL == net->data->m.network_read_ex(net, compressed_data, net_payload_size, conn_stats, error_info TSRMLS_CC)) {
                        ret = FAIL;
                        goto end;
                }
                net->uncompressed_data = mysqlnd_create_read_buffer(decompressed_size TSRMLS_CC);
-               ret = net->m.decode(net->uncompressed_data->data, decompressed_size, compressed_data, net_payload_size TSRMLS_CC);
+               ret = net->data->m.decode(net->uncompressed_data->data, decompressed_size, compressed_data, net_payload_size TSRMLS_CC);
                if (ret == FAIL) {
                        goto end;
                }
        } else {
                DBG_INF_FMT("The server decided not to compress the data. Our job is easy. Copying %u bytes", net_payload_size);
                net->uncompressed_data = mysqlnd_create_read_buffer(net_payload_size TSRMLS_CC);
-               if (FAIL == net->m.network_read_ex(net, net->uncompressed_data->data, net_payload_size, conn_stats, error_info TSRMLS_CC)) {
+               if (FAIL == net->data->m.network_read_ex(net, net->uncompressed_data->data, net_payload_size, conn_stats, error_info TSRMLS_CC)) {
                        ret = FAIL;
                        goto end;
                }
@@ -590,7 +618,7 @@ MYSQLND_METHOD(mysqlnd_net, receive_ex)(MYSQLND_NET * const net, zend_uchar * co
 
        DBG_ENTER("mysqlnd_net::receive_ex");
 #ifdef MYSQLND_COMPRESSION_ENABLED
-       if (net->compressed) {
+       if (net->data->compressed) {
                if (net->uncompressed_data) {
                        size_t to_read_from_buffer = MIN(net->uncompressed_data->bytes_left(net->uncompressed_data), to_read);
                        DBG_INF_FMT("reading %u from uncompressed_data buffer", to_read_from_buffer);
@@ -610,7 +638,7 @@ MYSQLND_METHOD(mysqlnd_net, receive_ex)(MYSQLND_NET * const net, zend_uchar * co
                        size_t net_payload_size;
                        zend_uchar packet_no;
 
-                       if (FAIL == net->m.network_read_ex(net, net_header, MYSQLND_HEADER_SIZE, conn_stats, error_info TSRMLS_CC)) {
+                       if (FAIL == net->data->m.network_read_ex(net, net_header, MYSQLND_HEADER_SIZE, conn_stats, error_info TSRMLS_CC)) {
                                DBG_RETURN(FAIL);
                        }
                        net_payload_size = uint3korr(net_header);
@@ -628,7 +656,7 @@ MYSQLND_METHOD(mysqlnd_net, receive_ex)(MYSQLND_NET * const net, zend_uchar * co
                        DBG_INF_FMT("HEADER: hwd_packet_no=%u size=%3u", packet_no, (unsigned long) net_payload_size);
 #endif
                        /* Now let's read from the wire, decompress it and fill the read buffer */
-                       net->m.read_compressed_packet_from_stream_and_fill_read_buffer(net, net_payload_size, conn_stats, error_info TSRMLS_CC);
+                       net->data->m.read_compressed_packet_from_stream_and_fill_read_buffer(net, net_payload_size, conn_stats, error_info TSRMLS_CC);
 
                        /*
                          Now a bit of recursion - read from the read buffer,
@@ -636,12 +664,12 @@ MYSQLND_METHOD(mysqlnd_net, receive_ex)(MYSQLND_NET * const net, zend_uchar * co
                          is not enough, then the recursive call will try to
                          satisfy it until it is satisfied.
                        */
-                       DBG_RETURN(net->m.receive_ex(net, p, to_read, conn_stats, error_info TSRMLS_CC));
+                       DBG_RETURN(net->data->m.receive_ex(net, p, to_read, conn_stats, error_info TSRMLS_CC));
                }
                DBG_RETURN(PASS);
        }
 #endif /* MYSQLND_COMPRESSION_ENABLED */
-       DBG_RETURN(net->m.network_read_ex(net, p, to_read, conn_stats, error_info TSRMLS_CC));
+       DBG_RETURN(net->data->m.network_read_ex(net, p, to_read, conn_stats, error_info TSRMLS_CC));
 }
 /* }}} */
 
@@ -668,80 +696,80 @@ MYSQLND_METHOD(mysqlnd_net, set_client_option)(MYSQLND_NET * const net, enum mys
                        break;
                case MYSQLND_OPT_NET_READ_BUFFER_SIZE:
                        DBG_INF("MYSQLND_OPT_NET_READ_BUFFER_SIZE");
-                       net->options.net_read_buffer_size = *(unsigned int*) value;
-                       DBG_INF_FMT("new_length=%u", net->options.net_read_buffer_size);
+                       net->data->options.net_read_buffer_size = *(unsigned int*) value;
+                       DBG_INF_FMT("new_length=%u", net->data->options.net_read_buffer_size);
                        break;
                case MYSQL_OPT_CONNECT_TIMEOUT:
                        DBG_INF("MYSQL_OPT_CONNECT_TIMEOUT");
-                       net->options.timeout_connect = *(unsigned int*) value;
+                       net->data->options.timeout_connect = *(unsigned int*) value;
                        break;
                case MYSQLND_OPT_SSL_KEY:
                        {
                                zend_bool pers = net->persistent;
-                               if (net->options.ssl_key) {
-                                       mnd_pefree(net->options.ssl_key, pers);
+                               if (net->data->options.ssl_key) {
+                                       mnd_pefree(net->data->options.ssl_key, pers);
                                }
-                               net->options.ssl_key = value? mnd_pestrdup(value, pers) : NULL;
+                               net->data->options.ssl_key = value? mnd_pestrdup(value, pers) : NULL;
                                break;
                        }
                case MYSQLND_OPT_SSL_CERT:
                        {
                                zend_bool pers = net->persistent;
-                               if (net->options.ssl_cert) {
-                                       mnd_pefree(net->options.ssl_cert, pers);
+                               if (net->data->options.ssl_cert) {
+                                       mnd_pefree(net->data->options.ssl_cert, pers);
                                }
-                               net->options.ssl_cert = value? mnd_pestrdup(value, pers) : NULL;
+                               net->data->options.ssl_cert = value? mnd_pestrdup(value, pers) : NULL;
                                break;
                        }
                case MYSQLND_OPT_SSL_CA:
                        {
                                zend_bool pers = net->persistent;
-                               if (net->options.ssl_ca) {
-                                       mnd_pefree(net->options.ssl_ca, pers);
+                               if (net->data->options.ssl_ca) {
+                                       mnd_pefree(net->data->options.ssl_ca, pers);
                                }
-                               net->options.ssl_ca = value? mnd_pestrdup(value, pers) : NULL;
+                               net->data->options.ssl_ca = value? mnd_pestrdup(value, pers) : NULL;
                                break;
                        }
                case MYSQLND_OPT_SSL_CAPATH:
                        {
                                zend_bool pers = net->persistent;
-                               if (net->options.ssl_capath) {
-                                       mnd_pefree(net->options.ssl_capath, pers);
+                               if (net->data->options.ssl_capath) {
+                                       mnd_pefree(net->data->options.ssl_capath, pers);
                                }
-                               net->options.ssl_capath = value? mnd_pestrdup(value, pers) : NULL;
+                               net->data->options.ssl_capath = value? mnd_pestrdup(value, pers) : NULL;
                                break;
                        }
                case MYSQLND_OPT_SSL_CIPHER:
                        {
                                zend_bool pers = net->persistent;
-                               if (net->options.ssl_cipher) {
-                                       mnd_pefree(net->options.ssl_cipher, pers);
+                               if (net->data->options.ssl_cipher) {
+                                       mnd_pefree(net->data->options.ssl_cipher, pers);
                                }
-                               net->options.ssl_cipher = value? mnd_pestrdup(value, pers) : NULL;
+                               net->data->options.ssl_cipher = value? mnd_pestrdup(value, pers) : NULL;
                                break;
                        }
                case MYSQLND_OPT_SSL_PASSPHRASE:
                        {
                                zend_bool pers = net->persistent;
-                               if (net->options.ssl_passphrase) {
-                                       mnd_pefree(net->options.ssl_passphrase, pers);
+                               if (net->data->options.ssl_passphrase) {
+                                       mnd_pefree(net->data->options.ssl_passphrase, pers);
                                }
-                               net->options.ssl_passphrase = value? mnd_pestrdup(value, pers) : NULL;
+                               net->data->options.ssl_passphrase = value? mnd_pestrdup(value, pers) : NULL;
                                break;
                        }
                case MYSQL_OPT_SSL_VERIFY_SERVER_CERT:
-                       net->options.ssl_verify_peer = value? ((*(zend_bool *)value)? TRUE:FALSE): FALSE;
+                       net->data->options.ssl_verify_peer = value? ((*(zend_bool *)value)? TRUE:FALSE): FALSE;
                        break;
                case MYSQL_OPT_READ_TIMEOUT:
-                       net->options.timeout_read = *(unsigned int*) value;
+                       net->data->options.timeout_read = *(unsigned int*) value;
                        break;
 #ifdef WHEN_SUPPORTED_BY_MYSQLI
                case MYSQL_OPT_WRITE_TIMEOUT:
-                       net->options.timeout_write = *(unsigned int*) value;
+                       net->data->options.timeout_write = *(unsigned int*) value;
                        break;
 #endif
                case MYSQL_OPT_COMPRESS:
-                       net->options.flags |= MYSQLND_NET_FLAG_USE_COMPRESSION;
+                       net->data->options.flags |= MYSQLND_NET_FLAG_USE_COMPRESSION;
                        break;
                default:
                        DBG_RETURN(FAIL);
@@ -765,7 +793,8 @@ MYSQLND_METHOD(mysqlnd_net, consume_uneaten_data)(MYSQLND_NET * const net, enum
        char tmp_buf[256];
        size_t skipped_bytes = 0;
        int opt = PHP_STREAM_OPTION_BLOCKING;
-       int was_blocked = net->stream->ops->set_option(net->stream, opt, 0, NULL TSRMLS_CC);
+       php_stream * net_stream = net->data->get_stream(net TSRMLS_CC);
+       int was_blocked = net_stream->ops->set_option(net_stream, opt, 0, NULL TSRMLS_CC);
 
        DBG_ENTER("mysqlnd_net::consume_uneaten_data");
 
@@ -774,11 +803,11 @@ MYSQLND_METHOD(mysqlnd_net, consume_uneaten_data)(MYSQLND_NET * const net, enum
                int bytes_consumed;
 
                do {
-                       skipped_bytes += (bytes_consumed = php_stream_read(net->stream, tmp_buf, sizeof(tmp_buf)));
+                       skipped_bytes += (bytes_consumed = php_stream_read(net_stream, tmp_buf, sizeof(tmp_buf)));
                } while (bytes_consumed == sizeof(tmp_buf));
 
                if (was_blocked) {
-                       net->stream->ops->set_option(net->stream, opt, 1, NULL TSRMLS_CC);
+                       net_stream->ops->set_option(net_stream, opt, 1, NULL TSRMLS_CC);
                }
 
                if (bytes_consumed) {
@@ -806,53 +835,55 @@ static enum_func_status
 MYSQLND_METHOD(mysqlnd_net, enable_ssl)(MYSQLND_NET * const net TSRMLS_DC)
 {
 #ifdef MYSQLND_SSL_SUPPORTED
-       php_stream_context *context = php_stream_context_alloc(TSRMLS_C);
+       php_stream_context * context = php_stream_context_alloc(TSRMLS_C);
+       php_stream * net_stream = net->data->m.get_stream(net TSRMLS_CC);
+
        DBG_ENTER("mysqlnd_net::enable_ssl");
        if (!context) {
                DBG_RETURN(FAIL);
        }
 
-       if (net->options.ssl_key) {
+       if (net->data->options.ssl_key) {
                zval key_zval;
-               ZVAL_STRING(&key_zval, net->options.ssl_key, 0);
+               ZVAL_STRING(&key_zval, net->data->options.ssl_key, 0);
                php_stream_context_set_option(context, "ssl", "local_pk", &key_zval);
        }
-       if (net->options.ssl_verify_peer) {
+       if (net->data->options.ssl_verify_peer) {
                zval verify_peer_zval;
                ZVAL_TRUE(&verify_peer_zval);
                php_stream_context_set_option(context, "ssl", "verify_peer", &verify_peer_zval);
        }
-       if (net->options.ssl_cert) {
+       if (net->data->options.ssl_cert) {
                zval cert_zval;
-               ZVAL_STRING(&cert_zval, net->options.ssl_cert, 0);
+               ZVAL_STRING(&cert_zval, net->data->options.ssl_cert, 0);
                php_stream_context_set_option(context, "ssl", "local_cert", &cert_zval);
-               if (!net->options.ssl_key) {
+               if (!net->data->options.ssl_key) {
                        php_stream_context_set_option(context, "ssl", "local_pk", &cert_zval);
                }
        }
-       if (net->options.ssl_ca) {
+       if (net->data->options.ssl_ca) {
                zval cafile_zval;
-               ZVAL_STRING(&cafile_zval, net->options.ssl_ca, 0);
+               ZVAL_STRING(&cafile_zval, net->data->options.ssl_ca, 0);
                php_stream_context_set_option(context, "ssl", "cafile", &cafile_zval);
        }
-       if (net->options.ssl_capath) {
+       if (net->data->options.ssl_capath) {
                zval capath_zval;
-               ZVAL_STRING(&capath_zval, net->options.ssl_capath, 0);
+               ZVAL_STRING(&capath_zval, net->data->options.ssl_capath, 0);
                php_stream_context_set_option(context, "ssl", "cafile", &capath_zval);
        }
-       if (net->options.ssl_passphrase) {
+       if (net->data->options.ssl_passphrase) {
                zval passphrase_zval;
-               ZVAL_STRING(&passphrase_zval, net->options.ssl_passphrase, 0);
+               ZVAL_STRING(&passphrase_zval, net->data->options.ssl_passphrase, 0);
                php_stream_context_set_option(context, "ssl", "passphrase", &passphrase_zval);
        }
-       if (net->options.ssl_cipher) {
+       if (net->data->options.ssl_cipher) {
                zval cipher_zval;
-               ZVAL_STRING(&cipher_zval, net->options.ssl_cipher, 0);
+               ZVAL_STRING(&cipher_zval, net->data->options.ssl_cipher, 0);
                php_stream_context_set_option(context, "ssl", "ciphers", &cipher_zval);
        }
-       php_stream_context_set(net->stream, context);
-       if (php_stream_xport_crypto_setup(net->stream, STREAM_CRYPTO_METHOD_TLS_CLIENT, NULL TSRMLS_CC) < 0 ||
-           php_stream_xport_crypto_enable(net->stream, 1 TSRMLS_CC) < 0)
+       php_stream_context_set(net_stream, context);
+       if (php_stream_xport_crypto_setup(net_stream, STREAM_CRYPTO_METHOD_TLS_CLIENT, NULL TSRMLS_CC) < 0 ||
+           php_stream_xport_crypto_enable(net_stream, 1 TSRMLS_CC) < 0)
        {
                DBG_ERR("Cannot connect to MySQL by using SSL");
                php_error_docref(NULL TSRMLS_CC, E_WARNING, "Cannot connect to MySQL by using SSL");
@@ -865,14 +896,14 @@ MYSQLND_METHOD(mysqlnd_net, enable_ssl)(MYSQLND_NET * const net TSRMLS_DC)
          of the context, which means usage of already freed memory, bad. Actually we don't need this
          context anymore after we have enabled SSL on the connection. Thus it is very simple, we remove it.
        */
-       php_stream_context_set(net->stream, NULL);
+       php_stream_context_set(net_stream, NULL);
 
-       if (net->options.timeout_read) {
+       if (net->data->options.timeout_read) {
                struct timeval tv;
-               DBG_INF_FMT("setting %u as PHP_STREAM_OPTION_READ_TIMEOUT", net->options.timeout_read);
-               tv.tv_sec = net->options.timeout_read;
+               DBG_INF_FMT("setting %u as PHP_STREAM_OPTION_READ_TIMEOUT", net->data->options.timeout_read);
+               tv.tv_sec = net->data->options.timeout_read;
                tv.tv_usec = 0;
-               php_stream_set_option(net->stream, PHP_STREAM_OPTION_READ_TIMEOUT, 0, &tv);
+               php_stream_set_option(net_stream, PHP_STREAM_OPTION_READ_TIMEOUT, 0, &tv);
        }
 
        DBG_RETURN(PASS);
@@ -906,25 +937,25 @@ MYSQLND_METHOD(mysqlnd_net, free_contents)(MYSQLND_NET * net TSRMLS_DC)
                net->uncompressed_data->free_buffer(&net->uncompressed_data TSRMLS_CC);
        }
 #endif
-       if (net->options.ssl_key) {
-               mnd_pefree(net->options.ssl_key, pers);
-               net->options.ssl_key = NULL;
+       if (net->data->options.ssl_key) {
+               mnd_pefree(net->data->options.ssl_key, pers);
+               net->data->options.ssl_key = NULL;
        }
-       if (net->options.ssl_cert) {
-               mnd_pefree(net->options.ssl_cert, pers);
-               net->options.ssl_cert = NULL;
+       if (net->data->options.ssl_cert) {
+               mnd_pefree(net->data->options.ssl_cert, pers);
+               net->data->options.ssl_cert = NULL;
        }
-       if (net->options.ssl_ca) {
-               mnd_pefree(net->options.ssl_ca, pers);
-               net->options.ssl_ca = NULL;
+       if (net->data->options.ssl_ca) {
+               mnd_pefree(net->data->options.ssl_ca, pers);
+               net->data->options.ssl_ca = NULL;
        }
-       if (net->options.ssl_capath) {
-               mnd_pefree(net->options.ssl_capath, pers);
-               net->options.ssl_capath = NULL;
+       if (net->data->options.ssl_capath) {
+               mnd_pefree(net->data->options.ssl_capath, pers);
+               net->data->options.ssl_capath = NULL;
        }
-       if (net->options.ssl_cipher) {
-               mnd_pefree(net->options.ssl_cipher, pers);
-               net->options.ssl_cipher = NULL;
+       if (net->data->options.ssl_cipher) {
+               mnd_pefree(net->data->options.ssl_cipher, pers);
+               net->data->options.ssl_cipher = NULL;
        }
 
        DBG_VOID_RETURN;
@@ -936,24 +967,25 @@ MYSQLND_METHOD(mysqlnd_net, free_contents)(MYSQLND_NET * net TSRMLS_DC)
 static void
 MYSQLND_METHOD(mysqlnd_net, close_stream)(MYSQLND_NET * const net, MYSQLND_STATS * const stats, MYSQLND_ERROR_INFO * const error_info TSRMLS_DC)
 {
+       php_stream * net_stream;
        DBG_ENTER("mysqlnd_net::close_stream");
-       if (net && net->stream) {
+       if (net && (net_stream = net->data->m.get_stream(net TSRMLS_CC))) {
                zend_bool pers = net->persistent;
-               DBG_INF_FMT("Freeing stream. abstract=%p", net->stream->abstract);
+               DBG_INF_FMT("Freeing stream. abstract=%p", net_stream->abstract);
                if (pers) {
                        if (EG(active)) {
-                               php_stream_free(net->stream, PHP_STREAM_FREE_CLOSE_PERSISTENT | PHP_STREAM_FREE_RSRC_DTOR);
+                               php_stream_free(net_stream, PHP_STREAM_FREE_CLOSE_PERSISTENT | PHP_STREAM_FREE_RSRC_DTOR);
                        } else {
                                /*
                                  otherwise we will crash because the EG(persistent_list) has been freed already,
                                  before the modules are shut down
                                */
-                               php_stream_free(net->stream, PHP_STREAM_FREE_CLOSE | PHP_STREAM_FREE_RSRC_DTOR);
+                               php_stream_free(net_stream, PHP_STREAM_FREE_CLOSE | PHP_STREAM_FREE_RSRC_DTOR);
                        }
                } else {
-                       php_stream_free(net->stream, PHP_STREAM_FREE_CLOSE);
+                       php_stream_free(net_stream, PHP_STREAM_FREE_CLOSE);
                }
-               net->stream = NULL;
+               (void) net->data->m.set_stream(net, NULL TSRMLS_CC);
        }
 
        DBG_VOID_RETURN;
@@ -969,13 +1001,13 @@ MYSQLND_METHOD(mysqlnd_net, init)(MYSQLND_NET * const net, MYSQLND_STATS * const
        DBG_ENTER("mysqlnd_net::init");
 
        buf_size = MYSQLND_G(net_cmd_buffer_size); /* this is long, cast to unsigned int*/
-       net->m.set_client_option(net, MYSQLND_OPT_NET_CMD_BUFFER_SIZE, (char *) &buf_size TSRMLS_CC);
+       net->data->m.set_client_option(net, MYSQLND_OPT_NET_CMD_BUFFER_SIZE, (char *) &buf_size TSRMLS_CC);
 
        buf_size = MYSQLND_G(net_read_buffer_size); /* this is long, cast to unsigned int*/
-       net->m.set_client_option(net, MYSQLND_OPT_NET_READ_BUFFER_SIZE, (char *)&buf_size TSRMLS_CC);
+       net->data->m.set_client_option(net, MYSQLND_OPT_NET_READ_BUFFER_SIZE, (char *)&buf_size TSRMLS_CC);
 
        buf_size = MYSQLND_G(net_read_timeout); /* this is long, cast to unsigned int*/
-       net->m.set_client_option(net, MYSQL_OPT_READ_TIMEOUT, (char *)&buf_size TSRMLS_CC);
+       net->data->m.set_client_option(net, MYSQL_OPT_READ_TIMEOUT, (char *)&buf_size TSRMLS_CC);
 
        DBG_RETURN(PASS);
 }
@@ -988,22 +1020,48 @@ MYSQLND_METHOD(mysqlnd_net, dtor)(MYSQLND_NET * const net, MYSQLND_STATS * const
 {
        DBG_ENTER("mysqlnd_net::dtor");
        if (net) {
-               zend_bool pers = net->persistent;
-       
-               net->m.free_contents(net TSRMLS_CC);
-               net->m.close_stream(net, stats, error_info TSRMLS_CC);
+               net->data->m.free_contents(net TSRMLS_CC);
+               net->data->m.close_stream(net, stats, error_info TSRMLS_CC);
+
                if (net->cmd_buffer.buffer) {
                        DBG_INF("Freeing cmd buffer");
-                       mnd_pefree(net->cmd_buffer.buffer, pers);
+                       mnd_pefree(net->cmd_buffer.buffer, net->persistent);
                        net->cmd_buffer.buffer = NULL;
                }
-               mnd_pefree(net, pers);
+
+               mnd_pefree(net->data, net->data->persistent);
+               mnd_pefree(net, net->persistent);
        }
        DBG_VOID_RETURN;
 }
 /* }}} */
 
 
+/* {{{ mysqlnd_net::get_stream */
+static php_stream *
+MYSQLND_METHOD(mysqlnd_net, get_stream)(const MYSQLND_NET * const net TSRMLS_DC)
+{
+       DBG_ENTER("mysqlnd_net::get_stream");
+       DBG_RETURN(net? net->data->stream:NULL);
+}
+/* }}} */
+
+
+/* {{{ mysqlnd_net::set_stream */
+static php_stream *
+MYSQLND_METHOD(mysqlnd_net, set_stream)(MYSQLND_NET * const net, php_stream * net_stream TSRMLS_DC)
+{
+       php_stream * ret = NULL;
+       DBG_ENTER("mysqlnd_net::set_stream");
+       if (net) {
+               net->data->stream = net_stream;
+               ret = net->data->stream;
+       }
+       DBG_RETURN(ret);
+}
+/* }}} */
+
+
 MYSQLND_CLASS_METHODS_START(mysqlnd_net)
        MYSQLND_METHOD(mysqlnd_net, init),
        MYSQLND_METHOD(mysqlnd_net, dtor),
@@ -1026,10 +1084,13 @@ MYSQLND_CLASS_METHODS_START(mysqlnd_net)
        MYSQLND_METHOD(mysqlnd_net, send_ex),
        MYSQLND_METHOD(mysqlnd_net, receive_ex),
 #ifdef MYSQLND_COMPRESSION_ENABLED
-       MYSQLND_METHOD(mysqlnd_net, read_compressed_packet_from_stream_and_fill_read_buffer)
+       MYSQLND_METHOD(mysqlnd_net, read_compressed_packet_from_stream_and_fill_read_buffer),
 #else
-       NULL
+       NULL,
 #endif
+       MYSQLND_METHOD(mysqlnd_net, get_stream),
+       MYSQLND_METHOD(mysqlnd_net, set_stream),
+       MYSQLND_METHOD(mysqlnd_net, get_open_stream)
 MYSQLND_CLASS_METHODS_END;
 
 
@@ -1051,7 +1112,7 @@ mysqlnd_net_free(MYSQLND_NET * const net, MYSQLND_STATS * stats, MYSQLND_ERROR_I
 {
        DBG_ENTER("mysqlnd_net_free");
        if (net) {
-               net->m.dtor(net, stats, error_info TSRMLS_CC);
+               net->data->m.dtor(net, stats, error_info TSRMLS_CC);
        }
        DBG_VOID_RETURN;
 }

diff --git a/ext/mysqlnd/mysqlnd_structs.h b/ext/mysqlnd/mysqlnd_structs.h
index 43eba40a2057714fce8d8c60b5661f7af4db30d6..7b8386a3f6596db49a5e2034598b1eb497e3f428 100644 (file)
--- a/ext/mysqlnd/mysqlnd_structs.h
+++ b/ext/mysqlnd/mysqlnd_structs.h
@@ -213,6 +213,7 @@ typedef struct st_mysqlnd_net_options
 typedef struct st_mysqlnd_connection MYSQLND;
 typedef struct st_mysqlnd_connection_data MYSQLND_CONN_DATA;
 typedef struct st_mysqlnd_net  MYSQLND_NET;
+typedef struct st_mysqlnd_net_data     MYSQLND_NET_DATA;
 typedef struct st_mysqlnd_protocol     MYSQLND_PROTOCOL;
 typedef struct st_mysqlnd_res  MYSQLND_RES;
 typedef char**                                         MYSQLND_ROW_C;          /* return data as array of strings */
@@ -285,6 +286,9 @@ typedef void                                (*func_mysqlnd_net__close_stream)(MYSQLND_NET * const net, MYSQL
 typedef enum_func_status       (*func_mysqlnd_net__open_stream)(MYSQLND_NET * const net, const char * const scheme, const size_t scheme_len, const zend_bool persistent, MYSQLND_STATS * const conn_stats, MYSQLND_ERROR_INFO * const error_info TSRMLS_DC);
 typedef void                           (*func_mysqlnd_net__post_connect_set_opt)(MYSQLND_NET * const net, const char * const scheme, const size_t scheme_len, MYSQLND_STATS * const conn_stats, MYSQLND_ERROR_INFO * const error_info TSRMLS_DC);
 typedef enum_func_status       (*func_mysqlnd_net__read_compressed_packet_from_stream_and_fill_read_buffer)(MYSQLND_NET * net, size_t net_payload_size, MYSQLND_STATS * conn_stats, MYSQLND_ERROR_INFO * error_info TSRMLS_DC);
+typedef php_stream *           (*func_mysqlnd_net__get_stream)(const MYSQLND_NET * const net TSRMLS_DC);
+typedef php_stream *           (*func_mysqlnd_net__set_stream)(MYSQLND_NET * const net, php_stream * net_stream TSRMLS_DC);
+typedef func_mysqlnd_net__open_stream (*func_mysqlnd_net__get_open_stream)(MYSQLND_NET * const net, const char * const scheme, const size_t scheme_len, MYSQLND_ERROR_INFO * const error_info TSRMLS_DC);
 
 struct st_mysqlnd_net_methods
 {
@@ -314,9 +318,9 @@ struct st_mysqlnd_net_methods
 
        func_mysqlnd_net__read_compressed_packet_from_stream_and_fill_read_buffer read_compressed_packet_from_stream_and_fill_read_buffer;
 
-       void * unused3;
-       void * unused4;
-       void * unused5;
+       func_mysqlnd_net__get_stream get_stream;
+       func_mysqlnd_net__set_stream set_stream;
+       func_mysqlnd_net__get_open_stream get_open_stream;
        void * unused6;
        void * unused7;
 };
@@ -768,31 +772,43 @@ struct st_mysqlnd_stmt_methods
 };
 
 
-struct st_mysqlnd_net
+struct st_mysqlnd_net_data
 {
        php_stream                      *stream;
+       zend_bool                       compressed;
+#ifdef MYSQLND_DO_WIRE_CHECK_BEFORE_COMMAND
+       zend_uchar                      last_command;
+#else
+       zend_uchar                      unused_pad1;
+#endif
+       MYSQLND_NET_OPTIONS     options;
+
+       unsigned int            refcount;
+
+       zend_bool                       persistent;
+
+       struct st_mysqlnd_net_methods m;
+};
+
+
+struct st_mysqlnd_net
+{
+       struct st_mysqlnd_net_data * data;
+
        /* sequence for simple checking of correct packets */
        zend_uchar                      packet_no;
-       zend_bool                       compressed;
        zend_uchar                      compressed_envelope_packet_no;
+
 #ifdef MYSQLND_COMPRESSION_ENABLED
        MYSQLND_READ_BUFFER     * uncompressed_data;
 #else
        void *                          unused_pad1;
 #endif
-#ifdef MYSQLND_DO_WIRE_CHECK_BEFORE_COMMAND
-       zend_uchar                      last_command;
-#else
-       zend_uchar                      unused_pad2;
-#endif
+
        /* cmd buffer */
        MYSQLND_CMD_BUFFER      cmd_buffer;
 
-       MYSQLND_NET_OPTIONS     options;
-
-       zend_bool                       persistent;
-
-       struct st_mysqlnd_net_methods m;
+       zend_bool persistent;
 };
 
 

diff --git a/ext/mysqlnd/mysqlnd_wireprotocol.c b/ext/mysqlnd/mysqlnd_wireprotocol.c
index ce94ad8d8eb45e76b66f126082ed0fa8bd9120e7..3551c027cdf9ea6859ed953a390d69cf02f26e71 100644 (file)
--- a/ext/mysqlnd/mysqlnd_wireprotocol.c
+++ b/ext/mysqlnd/mysqlnd_wireprotocol.c
@@ -47,7 +47,7 @@
                                                (buf_size), (packet)->header.size, (packet)->header.size - (buf_size)); \
                                                DBG_RETURN(FAIL); \
                }\
-               if (FAIL == conn->net->m.receive_ex((conn)->net, (buf), (packet)->header.size, (conn)->stats, ((conn)->error_info) TSRMLS_CC)) { \
+               if (FAIL == conn->net->data->m.receive_ex((conn)->net, (buf), (packet)->header.size, (conn)->stats, ((conn)->error_info) TSRMLS_CC)) { \
                        CONN_SET_STATE(conn, CONN_QUIT_SENT); \
                        SET_CLIENT_ERROR(*conn->error_info, CR_SERVER_GONE_ERROR, UNKNOWN_SQLSTATE, mysqlnd_server_gone);\
                        php_error_docref(NULL TSRMLS_CC, E_WARNING, "%s", mysqlnd_server_gone); \
@@ -264,8 +264,8 @@ mysqlnd_read_header(MYSQLND_NET * net, MYSQLND_PACKET_HEADER * header,
        zend_uchar buffer[MYSQLND_HEADER_SIZE];
 
        DBG_ENTER(mysqlnd_read_header_name);
-       DBG_INF_FMT("compressed=%u", net->compressed);
-       if (FAIL == net->m.receive_ex(net, buffer, MYSQLND_HEADER_SIZE, conn_stats, error_info TSRMLS_CC)) {
+       DBG_INF_FMT("compressed=%u", net->data->compressed);
+       if (FAIL == net->data->m.receive_ex(net, buffer, MYSQLND_HEADER_SIZE, conn_stats, error_info TSRMLS_CC)) {
                DBG_RETURN(FAIL);
        }
 
@@ -279,7 +279,7 @@ mysqlnd_read_header(MYSQLND_NET * net, MYSQLND_PACKET_HEADER * header,
                                                        STAT_PROTOCOL_OVERHEAD_IN, MYSQLND_HEADER_SIZE,
                                                        STAT_PACKETS_RECEIVED, 1);
 
-       if (net->compressed || net->packet_no == header->packet_no) {
+       if (net->data->compressed || net->packet_no == header->packet_no) {
                /*
                  Have to increase the number, so we can send correct number back. It will
                  round at 255 as this is unsigned char. The server needs this for simple
@@ -549,7 +549,7 @@ size_t php_mysqlnd_auth_write(void * _packet, MYSQLND_CONN_DATA * conn TSRMLS_DC
                }
                DBG_RETURN(p - buffer - MYSQLND_HEADER_SIZE);
        } else {
-               size_t sent = conn->net->m.send_ex(conn->net, buffer, p - buffer - MYSQLND_HEADER_SIZE, conn->stats, conn->error_info TSRMLS_CC);
+               size_t sent = conn->net->data->m.send_ex(conn->net, buffer, p - buffer - MYSQLND_HEADER_SIZE, conn->stats, conn->error_info TSRMLS_CC);
                if (!sent) {
                        CONN_SET_STATE(conn, CONN_QUIT_SENT);
                }
@@ -709,7 +709,7 @@ php_mysqlnd_change_auth_response_write(void * _packet, MYSQLND_CONN_DATA * conn
        }
 
        {
-               size_t sent = conn->net->m.send_ex(conn->net, buffer, p - buffer - MYSQLND_HEADER_SIZE, conn->stats, conn->error_info TSRMLS_CC);
+               size_t sent = conn->net->data->m.send_ex(conn->net, buffer, p - buffer - MYSQLND_HEADER_SIZE, conn->stats, conn->error_info TSRMLS_CC);
                if (buffer != conn->net->cmd_buffer.buffer) {
                        mnd_efree(buffer);
                }
@@ -923,14 +923,14 @@ size_t php_mysqlnd_cmd_write(void * _packet, MYSQLND_CONN_DATA * conn TSRMLS_DC)
        MYSQLND_INC_CONN_STATISTIC(conn->stats, STAT_PACKETS_SENT_CMD);
 
 #ifdef MYSQLND_DO_WIRE_CHECK_BEFORE_COMMAND
-       net->m.consume_uneaten_data(net, packet->command TSRMLS_CC);
+       net->data->m.consume_uneaten_data(net, packet->command TSRMLS_CC);
 #endif
 
        if (!packet->argument || !packet->arg_len) {
                zend_uchar buffer[MYSQLND_HEADER_SIZE + 1];
 
                int1store(buffer + MYSQLND_HEADER_SIZE, packet->command);
-               sent = net->m.send_ex(net, buffer, 1, conn->stats, conn->error_info TSRMLS_CC);
+               sent = net->data->m.send_ex(net, buffer, 1, conn->stats, conn->error_info TSRMLS_CC);
        } else {
                size_t tmp_len = packet->arg_len + 1 + MYSQLND_HEADER_SIZE;
                zend_uchar *tmp, *p;
@@ -945,7 +945,7 @@ size_t php_mysqlnd_cmd_write(void * _packet, MYSQLND_CONN_DATA * conn TSRMLS_DC)
 
                memcpy(p, packet->argument, packet->arg_len);
 
-               sent = net->m.send_ex(net, tmp, tmp_len - MYSQLND_HEADER_SIZE, conn->stats, conn->error_info TSRMLS_CC);
+               sent = net->data->m.send_ex(net, tmp, tmp_len - MYSQLND_HEADER_SIZE, conn->stats, conn->error_info TSRMLS_CC);
                if (tmp != net->cmd_buffer.buffer) {
                        MYSQLND_INC_CONN_STATISTIC(conn->stats, STAT_CMD_BUFFER_TOO_SMALL);
                        mnd_efree(tmp);
@@ -1388,7 +1388,7 @@ php_mysqlnd_read_row_ex(MYSQLND_CONN_DATA * conn, MYSQLND_MEMORY_POOL * result_s
                        p = (*buffer)->ptr + (*data_size - header.size);
                }
 
-               if (PASS != (ret = conn->net->m.receive_ex(conn->net, p, header.size, conn->stats, conn->error_info TSRMLS_CC))) {
+               if (PASS != (ret = conn->net->data->m.receive_ex(conn->net, p, header.size, conn->stats, conn->error_info TSRMLS_CC))) {
                        DBG_ERR("Empty row packet body");
                        php_error(E_WARNING, "Empty row packet body");
                        break;
@@ -1744,10 +1744,8 @@ php_mysqlnd_rowp_read_text_protocol(MYSQLND_MEMORY_POOL_CHUNK * row_buffer, zval
 static enum_func_status
 php_mysqlnd_rowp_read(void * _packet, MYSQLND_CONN_DATA * conn TSRMLS_DC)
 {
-       MYSQLND_NET * net = conn->net;
        zend_uchar *p;
        enum_func_status ret = PASS;
-       size_t old_chunk_size = net->stream->chunk_size;
        MYSQLND_PACKET_ROW *packet= (MYSQLND_PACKET_ROW *) _packet;
        size_t post_alloc_for_bit_fields = 0;
        size_t data_size = 0;
@@ -1829,7 +1827,6 @@ php_mysqlnd_rowp_read(void * _packet, MYSQLND_CONN_DATA * conn TSRMLS_DC)
        }
 
 end:
-       net->stream->chunk_size = old_chunk_size;
        DBG_RETURN(ret);
 }
 /* }}} */