~drizzle-trunk/drizzle/development

void queueTempLogEvent(MSOpenTable *otab, int type, uint32_t tab_id, uint64_t blob_id, uint32_t auth_code, uint32_t *log_id, uint32_t *log_offset, uint32_t *q_time);

104

public:

105

#ifdef HAVE_ALIAS_SUPPORT

106

void queueForDeletion(MSOpenTable *otab, int type, uint32_t tab_id, uint64_t blob_id, uint32_t auth_code, uint32_t *log_id, uint32_t *log_offset, uint32_t *q_time, MSDiskAliasPtr aliasDiskRec);

107

#else

108

void queueForDeletion(MSOpenTable *otab, int type, uint32_t tab_id, uint64_t blob_id, uint32_t auth_code, uint32_t *log_id, uint32_t *log_offset, uint32_t *q_time)

109

{

110

queueTempLogEvent(otab, type, tab_id, blob_id, auth_code, log_id, log_offset, q_time);

111

}

112

#endif

113

MSTempLogFile *openTempLogFile(uint32_t log_id, size_t *log_rec_size, size_t *log_head_size);

114

uint32_t getTempLogCount();

115

void removeTempLog(uint32_t log_id);

116

117

/* Make this object sortable: */

118

virtual CSObject *getKey();

119

virtual int compareKey(CSObject *);

120

121

MSCompactorThread *getCompactorThread();

122

CSSyncVector *getRepositoryList();

123

124

#ifdef HAVE_ALIAS_SUPPORT

125

bool findBlobWithAlias(const char *alias, uint32_t *repo_id = NULL, uint64_t *repo_offset = NULL)

126

{

127

bool found;

128

uint32_t x_repo_id;

129

uint64_t x_repo_offset;

130

bool referenced; // The BLOB can be referenced or non referenced.

131

132

enter_();

133

if (!repo_id) repo_id = &x_repo_id;

134

if (!repo_offset) repo_offset = &x_repo_offset;

135

136

lock_(&iBlobAliaseLock);

137

found = iBlobAliases->findBlobByAlias(alias, &referenced, repo_id, repo_offset);

138

unlock_(&iBlobAliaseLock);

139

return_(found);

140

}

141

uint32_t registerBlobAlias(uint32_t repo_id, uint64_t repo_offset, const char *alias);

142

uint32_t updateBlobAlias(uint32_t repo_id, uint64_t repo_offset, uint32_t old_alias_hash, const char *alias);

143

void deleteBlobAlias(MSDiskAliasPtr diskRec);

144

void deleteBlobAlias(uint32_t repo_id, uint64_t repo_offset, uint32_t alias_hash);

145

void moveBlobAlias(uint32_t old_repo_id, uint64_t old_repo_offset, uint32_t alias_hash, uint32_t new_repo_id, uint64_t new_repo_offset);

146

#endif

147

148

bool isValidHeaderField(const char *name);

149

150

bool isRecovering() { return iRecovering;} // Indicates the database is being recovered from a dump.

151

void setRecovering(bool recovering) { // Indicate if the database is being recovered from a dump.

152

if (iRecovering == recovering)

153

return;

154

iRecovering = recovering;

155

if (iRecovering) {

156

myCompactorThread->suspend();

157

myTempLogThread->suspend();

158

} else {

159

myCompactorThread->resume();

160

myTempLogThread->resume();

161

}

162

}

163

164

bool isBackup;

165

void setBackupDatabase(); // Signals the database that it is the destination for a backup process.

166

void releaseBackupDatabase();

167

168

void startBackup(MSBackupInfo *backup_info);

169

void terminateBackup();

170

bool backupStatus(uint64_t *total, uint64_t *completed, bool *completed_ok);

171

uint32_t backupID();

172

173

private:

174

MSBackup *iBackupThread;

175

uint32_t iBackupTime; // The time at which the backup was started.

176

bool iRecovering;

177

#ifdef HAVE_ALIAS_SUPPORT

178

MSAlias *iBlobAliases;

179

CSLock iBlobAliaseLock; // Write lock for the BLOB aliases index. This is required because of the .

180

#endif

181

bool iClosing;

182

183

CSSyncSortedList *iTableList;

184

CSSparseArray *iTableArray;

185

uint32_t iMaxTableID;

186

187

MSTempLog *iWriteTempLog;

188

bool iDropping;

189

void dropDatabase();

190

void startThreads();

191

192

CSLock iBlobRefIdLock; // Lock for the BLOB ref counter.

193

uint64_t iNextBlobRefId;

194

195

public:

196

197

CSSyncSortedList iHTTPMetaDataHeaders;

198

static void startUp(const char *default_http_headers);

199

static void stopThreads();

200

static void shutDown();

201

202

static MSDatabase *getBackupDatabase(CSString *db_location, CSString *db_name, uint32_t db_id, bool create);

203

204

static MSDatabase *getDatabase(CSString *db_name, bool create);

205

static MSDatabase *getDatabase(const char *db_name, bool create);

206

static MSDatabase *getDatabase(uint32_t db_id);

207

static uint32_t getDatabaseID(CSString *db_name, bool create);

208

static uint32_t getDatabaseID(const char *db_name, bool create);

209

210

static void wakeTempLogThreads();

211

static void dropDatabase(MSDatabase *doomedDatabase, const char *db_name = NULL);

212

static void dropDatabase(const char *db_name);

213

214

static bool convertTablePathToIDs(const char *path, uint32_t *db_id, uint32_t *tab_id, bool create);

215

static bool convertTableAndDatabaseToIDs(const char *db_name, const char *tab_name, uint32_t *db_id, uint32_t *tab_id, bool create);

216

217

218

private:

219

static CSSyncSortedList *gDatabaseList;

220

static CSSparseArray *gDatabaseArray;

221

222

223

static void removeDatabasePath(CSString *doomedDatabasePath);

224

225

static uint32_t getDBID(CSPath *path, CSString *db_name);

226

static CSPath *createDatabasePath(const char *location, CSString *db_name, uint32_t *db_id_ptr, bool *create, bool is_pbms = false);

227

static MSDatabase *newDatabase(const char *db_location, CSString *db_name, uint32_t db_id, bool create);

228

static MSDatabase *loadDatabase(CSString *db_name, bool create);

229

static uint32_t fileToTableId(const char *file_name, const char *name_part = NULL);

230

const char *fileToTableName(size_t size, char *tab_name, const char *file_name);

231

232

};

233

234

#endif

Older »