Lines Matching refs:txw
43 func (txw *txWriteBuffer) put(bucket, k, v []byte) {
44 txw.seq = false
45 txw.putSeq(bucket, k, v)
48 func (txw *txWriteBuffer) putSeq(bucket, k, v []byte) {
49 b, ok := txw.buckets[string(bucket)]
52 txw.buckets[string(bucket)] = b
57 func (txw *txWriteBuffer) writeback(txr *txReadBuffer) {
58 for k, wb := range txw.buckets {
61 delete(txw.buckets, k)
65 if !txw.seq && wb.used > 1 {
71 txw.reset()