← Back to branch summary

~drizzle-trunk/drizzle/development

« back to all changes in this revision

Viewing changes to plugin/pbms/src/backup_ms.h

  • Committer: Brian Aker
  • Date: 2010-10-13 02:49:48 UTC
  • mto: This revision was merged to the branch mainline in revision 1853.
  • Revision ID: brian@tangent.org-20101013024948-xwel5qe6z7j21w73
Cleans up namespace for locks (now per user).

Show diffs side-by-side

added added

removed removed

Lines of Context:
plugin/pbms/src/backup_ms.h
1
 
/* Copyright (C) 2009 PrimeBase Technologies GmbH, Germany
 
1
/* Copyright (c) 2009 PrimeBase Technologies GmbH, Germany
2
2
 *
3
3
 * PrimeBase Media Stream for MySQL
4
4
 *
34
34
class MSDatabase;
35
35
 
36
36
class MSBackupInfo : public CSRefObject {
37
 
        friend class StartDumpCleanUp;
38
 
        friend class InsertRowCleanUp;
39
 
        
40
37
        private:
41
38
        static uint32_t gMaxInfoRef;
42
39
        static CSSyncSparseArray *gBackupInfo;
74
71
        }
75
72
 
76
73
 
77
 
        static MSBackupInfo *findBackupInfo(uint32_t in_backupRefId)
 
74
        static MSBackupInfo *findBackupInfo(uint32_t backupRefId)
78
75
        {
79
76
                MSBackupInfo *info;
80
77
                enter_();
81
78
                
82
79
                lock_(gBackupInfo);
83
80
                
84
 
                info = (MSBackupInfo *) gBackupInfo->get(in_backupRefId);
 
81
                info = (MSBackupInfo *) gBackupInfo->get(backupRefId);
85
82
                if (info) 
86
83
                        info->retain();
87
84
                unlock_(gBackupInfo);
88
85
                return_(info);
89
86
        }
90
87
        
91
 
        static MSBackupInfo *getBackupInfo(uint32_t in_backupRefId)
 
88
        static MSBackupInfo *getBackupInfo(uint32_t backupRefId)
92
89
        {
93
 
                MSBackupInfo *info = findBackupInfo(in_backupRefId);
 
90
                MSBackupInfo *info = findBackupInfo(backupRefId);
94
91
                if (!info) {
95
92
                        enter_();
96
93
                        char msg[80];
97
 
                        snprintf(msg, 80, "Backup info with reference ID %"PRIu32" not found", in_backupRefId);
 
94
                        snprintf(msg, 80, "Backup info with reference ID %"PRIu32" not found", backupRefId);
98
95
                        CSException::throwException(CS_CONTEXT, CS_ERR_GENERIC_ERROR, msg);
99
96
                        outer_();
100
97
                }
158
155
        
159
156
        static MSBackup* newMSBackup(MSBackupInfo *backup_info);
160
157
 
161
 
        friend class StartBackupCleanUp;
162
158
private:
163
159
        void completeBackup();
164
160