Browse Source

Handle binary serialization errors

Signed-off-by: Vadim Markovtsev <vadim@sourced.tech>
Vadim Markovtsev 6 years ago
parent
commit
aa0a41df0f
5 changed files with 10 additions and 10 deletions
  1. 2 2
      internal/plumbing/uast/uast.go
  2. 2 2
      leaves/burndown.go
  3. 2 2
      leaves/couples.go
  4. 2 2
      leaves/file_history.go
  5. 2 2
      leaves/shotness.go

+ 2 - 2
internal/plumbing/uast/uast.go

@@ -571,8 +571,8 @@ func (saver *ChangesSaver) serializeBinary(result []*pb.UASTChange, writer io.Wr
 	if err != nil {
 	if err != nil {
 		return err
 		return err
 	}
 	}
-	writer.Write(serialized)
-	return nil
+	_, err = writer.Write(serialized)
+	return err
 }
 }
 
 
 func init() {
 func init() {

+ 2 - 2
leaves/burndown.go

@@ -865,8 +865,8 @@ func (analyser *BurndownAnalysis) serializeBinary(result *BurndownResult, writer
 	if err != nil {
 	if err != nil {
 		return err
 		return err
 	}
 	}
-	writer.Write(serialized)
-	return nil
+	_, err = writer.Write(serialized)
+	return err
 }
 }
 
 
 func sortedKeys(m map[string]DenseHistory) []string {
 func sortedKeys(m map[string]DenseHistory) []string {

+ 2 - 2
leaves/couples.go

@@ -478,8 +478,8 @@ func (couples *CouplesAnalysis) serializeBinary(result *CouplesResult, writer io
 	if err != nil {
 	if err != nil {
 		return err
 		return err
 	}
 	}
-	writer.Write(serialized)
-	return nil
+	_, err = writer.Write(serialized)
+	return err
 }
 }
 
 
 // currentFiles return the list of files in the last consumed commit.
 // currentFiles return the list of files in the last consumed commit.

+ 2 - 2
leaves/file_history.go

@@ -163,8 +163,8 @@ func (history *FileHistory) serializeBinary(result *FileHistoryResult, writer io
 	if err != nil {
 	if err != nil {
 		return err
 		return err
 	}
 	}
-	writer.Write(serialized)
-	return nil
+	_, err = writer.Write(serialized)
+	return err
 }
 }
 
 
 func init() {
 func init() {

+ 2 - 2
leaves/shotness.go

@@ -437,8 +437,8 @@ func (shotness *ShotnessAnalysis) serializeBinary(result *ShotnessResult, writer
 	if err != nil {
 	if err != nil {
 		return err
 		return err
 	}
 	}
-	writer.Write(serialized)
-	return nil
+	_, err = writer.Write(serialized)
+	return err
 }
 }
 
 
 func (shotness *ShotnessAnalysis) extractNodes(root *uast.Node) (map[string]*uast.Node, error) {
 func (shotness *ShotnessAnalysis) extractNodes(root *uast.Node) (map[string]*uast.Node, error) {