addresses #861

now DB's are removed with db->remove and unlink

git-svn-id: file:///svn/mysql/tokudb-engine/src@4252 c7de825b-a66e-492c-adef-691d508d4ae1

storage/tokudb/ha_tokudb.cc

@@ -2856,24 +2856,55 @@ static int rmall(const char *dname) {
             sprintf(fname, "%s/%s", dname, dirent->d_name);
             if (dirent->d_type == DT_DIR) {
                 error = rmall(fname);
-            } else {
-                if (tokudb_debug & TOKUDB_DEBUG_OPEN)
-                    TOKUDB_TRACE("unlink:%s\n", fname);
-                error = unlink(fname);
             } 
+            else {
+                if (tokudb_debug & TOKUDB_DEBUG_OPEN) {
+                    TOKUDB_TRACE("removing:%s\n", fname);
+                }
+                //
+                // if clause checks if the file is a .tokudb file
+                //
+                if (strlen(fname) >= strlen (ha_tokudb_ext) &&
+                    strcmp(fname + (strlen(fname) - strlen(ha_tokudb_ext)), ha_tokudb_ext) == 0) 
+                {
+                    //
+                    // if this fails under low memory conditions, gracefully exit and return error
+                    // user will be notified that something went wrong, and he will
+                    // have to deal with it
+                    //
+                    DB* db = NULL;
+                    error = db_create(&db, db_env, 0);
+                    if (error) {
+                        break;
+                    }
+                    //
+                    // it is ok to do db->remove on any .tokudb file, because any such
+                    // file was created with db->open
+                    //
+                    db->remove(db, fname, NULL, 0);
+                }
+                else {
+                    //
+                    // in case we have some file that is not .tokudb, we just delete it
+                    //
+                    error = unlink(fname);
                     if (error != 0) {
                         error = errno;
                         break;
                     }
                 }
+            }
+        }
         closedir(d);
         if (error == 0) {
             error = rmdir(dname);
             if (error != 0)
                 error = errno;
         }
-    } else
+    } 
+    else {
         error = errno;
+    }
     return error;
 }