wip

go.mod

@@ -56,7 +56,7 @@ require (
 	golang.org/x/sys v0.0.0-20210510120138-977fb7262007 // indirect
 	golang.org/x/text v0.3.5 // indirect
 	google.golang.org/grpc v1.28.0
-	gopkg.in/yaml.v2 v2.3.0 // indirect
+	gopkg.in/yaml.v2 v2.3.0
 	modernc.org/mathutil v1.0.0
 	modernc.org/strutil v1.0.0
 	sigs.k8s.io/yaml v1.2.0 // indirect

pg/protocol.go

@@ -331,7 +331,7 @@ func (p *Portal) Parse(data []byte) {
 	}
 
 	if len(queryStr) > 2 {
-
+		vprint.VV("SQL=[%v]", queryStr)
 		query, err := p.mapper.MapSQL(queryStr)
 		if err != nil {
 			return
@@ -574,6 +574,7 @@ func (p *Portal) Execute() (shouldTerminate bool, queryReady bool, err error) {
 	case pgBegin:
 		p.Name = "BEGIN"
 	case pgTypeLen:
+		vprint.VV("adding typelen message")
 		rowDescription, e := p.Encoder.EncodeColumn("typelen", int32(21), 2)
 		if e != nil {
 			err = e

rbf/cfg/cfg.go

@@ -56,7 +56,7 @@ func NewDefaultConfig() *Config {
 		MaxWALSize:           DefaultMaxWALSize,
 		MinWALCheckpointSize: DefaultMinWALCheckpointSize,
 		MaxWALCheckpointSize: DefaultMaxWALCheckpointSize,
-		FsyncEnabled:         true,
+		FsyncEnabled:         false,
 
 		// CI passed with 20. 50 was too big for CI, even on X-large instances.
 		// For now we default to 0, which means use sync.Pool.