Add resource for Persistent Prepare Statement

Author: codespill

ext/php_driver.c

@@ -39,6 +39,7 @@
 /* Resources */
 #define PHP_DRIVER_CLUSTER_RES_NAME PHP_DRIVER_NAMESPACE " Cluster"
 #define PHP_DRIVER_SESSION_RES_NAME PHP_DRIVER_NAMESPACE " Session"
+#define PHP_DRIVER_PREPARED_STATEMENT_RES_NAME PHP_DRIVER_NAMESPACE " PreparedStatement"
 
 static uv_once_t log_once = UV_ONCE_INIT;
 static char *log_location = NULL;
@@ -134,6 +135,26 @@ php_driver_session_dtor(php5to7_zend_resource rsrc TSRMLS_DC)
   }
 }
 
+static int le_php_driver_prepared_statement_res;
+int
+php_le_php_driver_prepared_statement()
+{
+  return le_php_driver_prepared_statement_res;
+}
+static void
+php_driver_prepared_statement_dtor(php5to7_zend_resource rsrc TSRMLS_DC)
+{
+  php_driver_pprepared_statement *preparedStmt = (php_driver_pprepared_statement*) rsrc->ptr;
+
+  if (preparedStmt) {
+    cass_future_free(preparedStmt->future);
+    php_driver_del_peref(&preparedStmt->ref, 1);
+    pefree(preparedStmt, 1);
+    PHP_DRIVER_G(persistent_prepared_statements)--;
+    rsrc->ptr = NULL;
+  }
+}
+
 static void
 php_driver_log(const CassLogMessage *message, void *data);
 
@@ -414,6 +435,7 @@ static PHP_GINIT_FUNCTION(php_driver)
   php_driver_globals->uuid_gen_pid        = 0;
   php_driver_globals->persistent_clusters = 0;
   php_driver_globals->persistent_sessions = 0;
+  php_driver_globals->persistent_prepared_statements = 0;
   PHP5TO7_ZVAL_UNDEF(php_driver_globals->type_varchar);
   PHP5TO7_ZVAL_UNDEF(php_driver_globals->type_text);
   PHP5TO7_ZVAL_UNDEF(php_driver_globals->type_blob);
@@ -454,6 +476,11 @@ PHP_MINIT_FUNCTION(php_driver)
                                     PHP_DRIVER_SESSION_RES_NAME,
                                     module_number);
 
+  le_php_driver_prepared_statement_res =
+  zend_register_list_destructors_ex(NULL, php_driver_prepared_statement_dtor,
+                                    PHP_DRIVER_PREPARED_STATEMENT_RES_NAME,
+                                    module_number);
+
   php_driver_define_Exception(TSRMLS_C);
   php_driver_define_InvalidArgumentException(TSRMLS_C);
   php_driver_define_DomainException(TSRMLS_C);