Method DB.writeLocked has a Cognitive Complexity of 42 (exceeds 20 allowed). Consider refactoring.

Open

func (db *DB) writeLocked(batch, ourBatch *Batch, merge, sync bool) error {
    // Try to flush memdb. This method would also trying to throttle writes
    // if it is too fast and compaction cannot catch-up.
    mdb, mdbFree, err := db.flush(batch.internalLen)
    if err != nil {

• Read up
  Read up

Method DB.writeLocked has 75 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (db *DB) writeLocked(batch, ourBatch *Batch, merge, sync bool) error {
    // Try to flush memdb. This method would also trying to throttle writes
    // if it is too fast and compaction cannot catch-up.
    mdb, mdbFree, err := db.flush(batch.internalLen)
    if err != nil {

Method DB.flush has 62 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (db *DB) flush(n int) (mdb *memDB, mdbFree int, err error) {
    delayed := false
    slowdownTrigger := db.s.o.GetWriteL0SlowdownTrigger()
    pauseTrigger := db.s.o.GetWriteL0PauseTrigger()
    // 请问您知道这里为什么要用匿名函数吗，我理解的是直接用循环就可以

Method DB.Write has 10 return statements (exceeds 4 allowed).

Open

func (db *DB) Write(batch *Batch, wo *opt.WriteOptions) error {
    if err := db.ok(); err != nil || batch == nil || batch.Len() == 0 {
        return err
    }

Method DB.flush has a Cognitive Complexity of 23 (exceeds 20 allowed). Consider refactoring.

Open

func (db *DB) flush(n int) (mdb *memDB, mdbFree int, err error) {
    delayed := false
    slowdownTrigger := db.s.o.GetWriteL0SlowdownTrigger()
    pauseTrigger := db.s.o.GetWriteL0PauseTrigger()
    // 请问您知道这里为什么要用匿名函数吗，我理解的是直接用循环就可以

• Read up
  Read up

Avoid deeply nested control flow statements.

Open

                    if ourBatch == nil {
                        ourBatch = db.batchPool.Get().(*Batch)
                        ourBatch.Reset()
                        batches = append(batches, ourBatch)
                    }

Method DB.putRec has 7 return statements (exceeds 4 allowed).

Open

func (db *DB) putRec(kt keyType, key, value []byte, wo *opt.WriteOptions) error {
    if err := db.ok(); err != nil {
        return err
    }

Method DB.CompactRange has 7 return statements (exceeds 4 allowed).

Open

func (db *DB) CompactRange(r util.Range) error {
    if err := db.ok(); err != nil {
        return err
    }

Avoid deeply nested control flow statements.

Open

                    if incoming.batch.internalLen > mergeLimit {
                        overflow = true
                        break merge
                    }

Avoid deeply nested control flow statements.

Open

                    if internalLen > mergeLimit {
                        overflow = true
                        break merge
                    }

Method DB.SetReadOnly has 6 return statements (exceeds 4 allowed).

Open

func (db *DB) SetReadOnly() error {
    if err := db.ok(); err != nil {
        return err
    }

Method DB.flush has 6 return statements (exceeds 4 allowed).

Open

func (db *DB) flush(n int) (mdb *memDB, mdbFree int, err error) {
    delayed := false
    slowdownTrigger := db.s.o.GetWriteL0SlowdownTrigger()
    pauseTrigger := db.s.o.GetWriteL0PauseTrigger()
    // 请问您知道这里为什么要用匿名函数吗，我理解的是直接用循环就可以

Method DB.writeJournal has 5 return statements (exceeds 4 allowed).

Open

func (db *DB) writeJournal(batches []*Batch, seq uint64, sync bool) error {
    wr, err := db.journal.Next()
    if err != nil {
        return err
    }