CompressionSnappy removed until its working

examples/net/server.go

@@ -68,7 +68,6 @@ func serveClient(conn net.Conn) {
 	fw, err := goavro.NewWriter(
 		goavro.BlockSize(2),
 		goavro.Compression(goavro.CompressionDeflate),
-		// goavro.Compression(goavro.CompressionSnappy),
 		goavro.WriterSchema(recordSchema),
 		goavro.ToWriter(conn))
 	if err != nil {

ocf.go

@@ -27,7 +27,6 @@ const (
 const (
 	CompressionNull    = "null"
 	CompressionDeflate = "deflate"
-	CompressionSnappy  = "snappy"
 )
 
 var (
@@ -42,7 +41,7 @@ func init() {
 // string is supported by this library.
 func IsCompressionCodecSupported(someCodec string) bool {
 	switch someCodec {
-	case CompressionNull, CompressionDeflate, CompressionSnappy:
+	case CompressionNull, CompressionDeflate:
 		return true
 	default:
 		return false

ocf_reader.go

@@ -21,7 +21,6 @@ package goavro
 import (
 	"bufio"
 	"bytes"
-	"code.google.com/p/snappy-go/snappy"
 	"compress/flate"
 	"fmt"
 	"io"
@@ -264,24 +263,6 @@ func decompress(fr *Reader, toDecompress <-chan *readerBlock, toDecode chan<- *r
 		for block := range toDecompress {
 			toDecode <- block
 		}
-	case CompressionSnappy:
-		var src, dst []byte
-		for block := range toDecompress {
-			src, block.err = ioutil.ReadAll(block.r)
-			if block.err != nil {
-				block.err = fmt.Errorf("cannot read: %v", block.err)
-				toDecode <- block
-				continue
-			}
-			dst, block.err = snappy.Decode(dst, src)
-			if block.err != nil {
-				block.err = fmt.Errorf("cannot decompress: %v", block.err)
-				toDecode <- block
-				continue
-			}
-			block.r = bytes.NewReader(dst)
-			toDecode <- block
-		}
 	}
 	close(toDecode)
 }

ocf_reader_test.go

@@ -75,13 +75,13 @@ func TestFileRead(t *testing.T) {
 	}()
 	var count int
 	for fr.Scan() {
-		datum := fr.Read()
-		if datum.Err != nil {
-			t.Errorf("Actual: %#v; Expected: %#v", datum.Err, nil)
+		datum, err := fr.Read()
+		if err != nil {
+			t.Errorf("Actual: %#v; Expected: %#v", err, nil)
 		}
-		_, ok := datum.Value.(*Record)
+		_, ok := datum.(*Record)
 		if !ok {
-			t.Errorf("Actual: %T; Expected: *Record", datum.Value)
+			t.Errorf("Actual: %T; Expected: *Record", datum)
 		}
 		count++
 	}

ocf_writer.go

@@ -21,7 +21,6 @@ package goavro
 import (
 	"bufio"
 	"bytes"
-	"code.google.com/p/snappy-go/snappy"
 	"compress/flate"
 	"encoding/json"
 	"fmt"
@@ -291,16 +290,6 @@ func compressor(fw *Writer, toCompress <-chan *writerBlock, toWrite chan<- *writ
 			bb = new(bytes.Buffer)
 			comp.Reset(bb)
 		}
-	case CompressionSnappy:
-		bb := new(bytes.Buffer)
-		comp := snappy.NewWriter(bb)
-		for block := range toCompress {
-			_, block.err = comp.Write(block.encoded.Bytes())
-			block.compressed = bb.Bytes()
-			toWrite <- block
-			bb = new(bytes.Buffer)
-			comp.Reset(bb)
-		}
 	}
 	close(toWrite)
 }

ocf_writer_test.go

@@ -49,9 +49,6 @@ func TestNewWriterBailsMissingWriterSchema(t *testing.T) {
 
 	_, err = NewWriter(ToWriter(new(bytes.Buffer)), Compression(CompressionDeflate))
 	checkError(t, err, "missing schema")
-
-	_, err = NewWriter(ToWriter(new(bytes.Buffer)), Compression(CompressionSnappy))
-	checkError(t, err, "missing schema")
 }
 
 func TestNewWriterBailsInvalidWriterSchema(t *testing.T) {