Skip to content

Commit

Permalink
style: fix fmt
Browse files Browse the repository at this point in the history
Signed-off-by: ekexium <eke@fastmail.com>
  • Loading branch information
ekexium committed Apr 8, 2024
1 parent 46365b0 commit d9dc938
Showing 1 changed file with 20 additions and 1 deletion.
21 changes: 20 additions & 1 deletion pkg/sessiontxn/isolation/base.go
Original file line number Diff line number Diff line change
Expand Up @@ -32,9 +32,13 @@ import (
"github.com/pingcap/tidb/pkg/sessiontxn"
"github.com/pingcap/tidb/pkg/sessiontxn/internal"
"github.com/pingcap/tidb/pkg/sessiontxn/staleread"
"github.com/pingcap/tidb/pkg/store/driver/txn"
"github.com/pingcap/tidb/pkg/table/temptable"
"github.com/pingcap/tidb/pkg/tablecodec"
"github.com/pingcap/tidb/pkg/util/tableutil"
"github.com/pingcap/tidb/pkg/util/tracing"
"github.com/pingcap/tipb/go-binlog"
tikvstore "github.com/tikv/client-go/v2/kv"
"github.com/tikv/client-go/v2/oracle"
)

Expand Down Expand Up @@ -588,7 +592,7 @@ func (p *baseTxnContextProvider) SetOptionsBeforeCommit(
}
info := &binloginfo.BinlogInfo{
Data: &binlog.Binlog{
Tp: binlog.BinlogType_Prewrite,
Tp: binlog.BinlogType_Prewrite,
PrewriteValue: prewriteData,
},
Client: sessVars.BinlogClient,
Expand Down Expand Up @@ -722,3 +726,18 @@ func (p *basePessimisticTxnContextProvider) cancelFairLockingIfNeeded(ctx contex
}
return nil
}

type temporaryTableKVFilter map[int64]tableutil.TempTable

func (m temporaryTableKVFilter) IsUnnecessaryKeyValue(
key, value []byte, flags tikvstore.KeyFlags,
) (bool, error) {
tid := tablecodec.DecodeTableID(key)
if _, ok := m[tid]; ok {
return true, nil
}

// This is the default filter for all tables.
defaultFilter := txn.TiDBKVFilter{}
return defaultFilter.IsUnnecessaryKeyValue(key, value, flags)
}

0 comments on commit d9dc938

Please sign in to comment.