From 3ed5310b05d02e8e8b41ab98a86c99fc1b5052c0 Mon Sep 17 00:00:00 2001
From: Manish R Jain <manishrjain@gmail.com>
Date: Wed, 10 Feb 2016 16:18:01 +1100
Subject: [PATCH] Fix lines longer than 80 chars
---
loader/loader.go | 11 ++++++++---
1 file changed, 8 insertions(+), 3 deletions(-)
diff --git a/loader/loader.go b/loader/loader.go
index a3953e11..305ce6e5 100644
--- a/loader/loader.go
+++ b/loader/loader.go
@@ -170,7 +170,8 @@ func (s *state) handleNQuadsWhileAssign(wg *sync.WaitGroup) {
s.getUidForString(nq.Subject)
}
- if len(nq.ObjectId) == 0 || farm.Fingerprint64([]byte(nq.ObjectId))%s.numInstances != s.instanceIdx {
+ if len(nq.ObjectId) == 0 ||
+ farm.Fingerprint64([]byte(nq.ObjectId))%s.numInstances != s.instanceIdx {
// This instance shouldnt or cant assign UID to this string
atomic.AddUint64(&s.ctr.ignored, 1)
} else {
@@ -182,7 +183,9 @@ func (s *state) handleNQuadsWhileAssign(wg *sync.WaitGroup) {
}
// Blocking function.
-func HandleRdfReader(reader io.Reader, instanceIdx uint64, numInstances uint64) (uint64, error) {
+func HandleRdfReader(reader io.Reader,
+ instanceIdx uint64, numInstances uint64) (uint64, error) {
+
s := new(state)
s.ctr = new(counters)
ticker := time.NewTicker(time.Second)
@@ -224,7 +227,9 @@ func HandleRdfReader(reader io.Reader, instanceIdx uint64, numInstances uint64)
}
// Blocking function.
-func HandleRdfReaderWhileAssign(reader io.Reader, instanceIdx uint64, numInstances uint64) (uint64, error) {
+func HandleRdfReaderWhileAssign(reader io.Reader,
+ instanceIdx uint64, numInstances uint64) (uint64, error) {
+
s := new(state)
s.ctr = new(counters)
ticker := time.NewTicker(time.Second)
--
GitLab