(key, value []byte)
| 234 | } |
| 235 | |
| 236 | func (db *DB) SyncPut(key, value []byte) error { |
| 237 | db.mu.Lock() |
| 238 | defer db.mu.Unlock() |
| 239 | |
| 240 | if db.closed { |
| 241 | return fmt.Errorf("database is closed") |
| 242 | } |
| 243 | |
| 244 | if err := db.validateKeyValue(key, value); err != nil { |
| 245 | db.stats.Errors++ |
| 246 | return err |
| 247 | } |
| 248 | |
| 249 | db.stats.WriteOps++ |
| 250 | db.stats.BytesWritten += int64(len(key) + len(value)) |
| 251 | |
| 252 | return db.db.Put(key, value, db.syncOpts) |
| 253 | } |
| 254 | |
| 255 | func (db *DB) SyncDelete(key []byte) error { |
| 256 | db.mu.Lock() |