cleanup

Author: methane

compress.go

@@ -159,11 +159,10 @@ func (c *compressor) uncompressPacket() error {
 
 const maxPayloadLen = maxPacketSize - 4
 
-var blankHeader = make([]byte, 7)
-
 func (c *compressor) Write(data []byte) (int, error) {
 	totalBytes := len(data)
 	dataLen := len(data)
+	blankHeader := make([]byte, 7)
 	var buf bytes.Buffer
 
 	for dataLen > 0 {

compress_test.go

@@ -33,9 +33,7 @@ func compressHelper(t *testing.T, mc *mysqlConn, uncompressedPacket []byte) []by
 	cs := mc.compressionSequence
 
 	var b bytes.Buffer
-	connWriter := &b
-
-	cw := newCompressor(mc, connWriter)
+	cw := newCompressor(mc, &b)
 
 	n, err := cw.Write(uncompressedPacket)