Add close() call

[ftsbench.git] / ftsbench.c

diff --git a/ftsbench.c b/ftsbench.c
index f577336..da6a4b0 100644 (file)
--- a/ftsbench.c
+++ b/ftsbench.c
@@ -280,6 +280,7 @@ main(int argn, char *argv[]) {
                fflush(stdout);
                db->finishCreateScheme(db);
                printf("done\n");
+               db->Close(db);
        } else {
                ftsDB   **dbs = initConnections(rdbms, nclients, dbname);
                pthread_t       *tid = (pthread_t*)malloc( sizeof(pthread_t) * nclients);
@@ -345,8 +346,10 @@ main(int argn, char *argv[]) {
                elapsed = elapsedtime(&begin);
                pthread_mutex_unlock( &mutexFinish );
 
-               for(i=0;i<nclients;i++)
+               for(i=0;i<nclients;i++) {
                        pthread_join(tid[i], NULL);
+                       dbs[i]->Close(dbs[i]);
+               }
 
                printf("\r%d(%.02f%%) queries proceed\n", total, (100.0*(float)total)/(nclients * n));
                printf("Total time: %.02f sec, Queries per second: %.02f\n", elapsed, total/elapsed);