File tree Expand file tree Collapse file tree 12 files changed +24
-25
lines changed Expand file tree Collapse file tree 12 files changed +24
-25
lines changed Original file line number Diff line number Diff line change @@ -199,14 +199,14 @@ func (c *Cassandra) Close() error {
199199}
200200
201201func (c * Cassandra ) Lock () error {
202- if ! c .isLocked .CAS (false , true ) {
202+ if ! c .isLocked .CompareAndSwap (false , true ) {
203203 return database .ErrLocked
204204 }
205205 return nil
206206}
207207
208208func (c * Cassandra ) Unlock () error {
209- if ! c .isLocked .CAS (true , false ) {
209+ if ! c .isLocked .CompareAndSwap (true , false ) {
210210 return database .ErrNotLocked
211211 }
212212 return nil
Original file line number Diff line number Diff line change @@ -293,14 +293,14 @@ func (ch *ClickHouse) Drop() (err error) {
293293}
294294
295295func (ch * ClickHouse ) Lock () error {
296- if ! ch .isLocked .CAS (false , true ) {
296+ if ! ch .isLocked .CompareAndSwap (false , true ) {
297297 return database .ErrLocked
298298 }
299299
300300 return nil
301301}
302302func (ch * ClickHouse ) Unlock () error {
303- if ! ch .isLocked .CAS (true , false ) {
303+ if ! ch .isLocked .CompareAndSwap (true , false ) {
304304 return database .ErrNotLocked
305305 }
306306
Original file line number Diff line number Diff line change @@ -108,14 +108,14 @@ func (f *Firebird) Close() error {
108108}
109109
110110func (f * Firebird ) Lock () error {
111- if ! f .isLocked .CAS (false , true ) {
111+ if ! f .isLocked .CompareAndSwap (false , true ) {
112112 return database .ErrLocked
113113 }
114114 return nil
115115}
116116
117117func (f * Firebird ) Unlock () error {
118- if ! f .isLocked .CAS (true , false ) {
118+ if ! f .isLocked .CompareAndSwap (true , false ) {
119119 return database .ErrNotLocked
120120 }
121121 return nil
Original file line number Diff line number Diff line change @@ -166,13 +166,13 @@ func (m *Ql) Drop() (err error) {
166166 return nil
167167}
168168func (m * Ql ) Lock () error {
169- if ! m .isLocked .CAS (false , true ) {
169+ if ! m .isLocked .CompareAndSwap (false , true ) {
170170 return database .ErrLocked
171171 }
172172 return nil
173173}
174174func (m * Ql ) Unlock () error {
175- if ! m .isLocked .CAS (true , false ) {
175+ if ! m .isLocked .CompareAndSwap (true , false ) {
176176 return database .ErrNotLocked
177177 }
178178 return nil
Original file line number Diff line number Diff line change @@ -128,14 +128,14 @@ func (p *Redshift) Close() error {
128128
129129// Redshift does not support advisory lock functions: https://docs.aws.amazon.com/redshift/latest/dg/c_unsupported-postgresql-functions.html
130130func (p * Redshift ) Lock () error {
131- if ! p .isLocked .CAS (false , true ) {
131+ if ! p .isLocked .CompareAndSwap (false , true ) {
132132 return database .ErrLocked
133133 }
134134 return nil
135135}
136136
137137func (p * Redshift ) Unlock () error {
138- if ! p .isLocked .CAS (true , false ) {
138+ if ! p .isLocked .CompareAndSwap (true , false ) {
139139 return database .ErrNotLocked
140140 }
141141 return nil
Original file line number Diff line number Diff line change @@ -143,7 +143,7 @@ func (r *Rqlite) Close() error {
143143// If the implementation can't provide this functionality, return nil.
144144// Return database.ErrLocked if database is already locked.
145145func (r * Rqlite ) Lock () error {
146- if ! r .isLocked .CAS (false , true ) {
146+ if ! r .isLocked .CompareAndSwap (false , true ) {
147147 return database .ErrLocked
148148 }
149149 return nil
@@ -152,7 +152,7 @@ func (r *Rqlite) Lock() error {
152152// Unlock should release the lock. Migrate will call this function after
153153// all migrations have been run.
154154func (r * Rqlite ) Unlock () error {
155- if ! r .isLocked .CAS (true , false ) {
155+ if ! r .isLocked .CompareAndSwap (true , false ) {
156156 return database .ErrNotLocked
157157 }
158158 return nil
Original file line number Diff line number Diff line change @@ -159,14 +159,14 @@ func (p *Snowflake) Close() error {
159159}
160160
161161func (p * Snowflake ) Lock () error {
162- if ! p .isLocked .CAS (false , true ) {
162+ if ! p .isLocked .CompareAndSwap (false , true ) {
163163 return database .ErrLocked
164164 }
165165 return nil
166166}
167167
168168func (p * Snowflake ) Unlock () error {
169- if ! p .isLocked .CAS (true , false ) {
169+ if ! p .isLocked .CompareAndSwap (true , false ) {
170170 return database .ErrNotLocked
171171 }
172172 return nil
Original file line number Diff line number Diff line change @@ -178,14 +178,14 @@ func (m *Sqlite) Drop() (err error) {
178178}
179179
180180func (m * Sqlite ) Lock () error {
181- if ! m .isLocked .CAS (false , true ) {
181+ if ! m .isLocked .CompareAndSwap (false , true ) {
182182 return database .ErrLocked
183183 }
184184 return nil
185185}
186186
187187func (m * Sqlite ) Unlock () error {
188- if ! m .isLocked .CAS (true , false ) {
188+ if ! m .isLocked .CompareAndSwap (true , false ) {
189189 return database .ErrNotLocked
190190 }
191191 return nil
Original file line number Diff line number Diff line change @@ -178,14 +178,14 @@ func (m *Sqlite) Drop() (err error) {
178178}
179179
180180func (m * Sqlite ) Lock () error {
181- if ! m .isLocked .CAS (false , true ) {
181+ if ! m .isLocked .CompareAndSwap (false , true ) {
182182 return database .ErrLocked
183183 }
184184 return nil
185185}
186186
187187func (m * Sqlite ) Unlock () error {
188- if ! m .isLocked .CAS (true , false ) {
188+ if ! m .isLocked .CompareAndSwap (true , false ) {
189189 return database .ErrNotLocked
190190 }
191191 return nil
Original file line number Diff line number Diff line change @@ -178,14 +178,14 @@ func (m *Sqlite) Drop() (err error) {
178178}
179179
180180func (m * Sqlite ) Lock () error {
181- if ! m .isLocked .CAS (false , true ) {
181+ if ! m .isLocked .CompareAndSwap (false , true ) {
182182 return database .ErrLocked
183183 }
184184 return nil
185185}
186186
187187func (m * Sqlite ) Unlock () error {
188- if ! m .isLocked .CAS (true , false ) {
188+ if ! m .isLocked .CompareAndSwap (true , false ) {
189189 return database .ErrNotLocked
190190 }
191191 return nil
You can’t perform that action at this time.
0 commit comments