aboutsummaryrefslogtreecommitdiff
path: root/content/pipelines
diff options
context:
space:
mode:
Diffstat (limited to 'content/pipelines')
-rw-r--r--content/pipelines/bounded.go2
-rw-r--r--content/pipelines/parallel.go2
-rw-r--r--content/pipelines/serial.go2
3 files changed, 3 insertions, 3 deletions
diff --git a/content/pipelines/bounded.go b/content/pipelines/bounded.go
index 90eed08..3936a29 100644
--- a/content/pipelines/bounded.go
+++ b/content/pipelines/bounded.go
@@ -25,7 +25,7 @@ func walkFiles(done <-chan struct{}, root string) (<-chan string, <-chan error)
if err != nil {
return err
}
- if info.IsDir() {
+ if !info.Mode().IsRegular() {
return nil
}
select {
diff --git a/content/pipelines/parallel.go b/content/pipelines/parallel.go
index 7edee1d..e9ad43c 100644
--- a/content/pipelines/parallel.go
+++ b/content/pipelines/parallel.go
@@ -33,7 +33,7 @@ func sumFiles(done <-chan struct{}, root string) (<-chan result, <-chan error) {
if err != nil {
return err
}
- if info.IsDir() {
+ if !info.Mode().IsRegular() {
return nil
}
wg.Add(1)
diff --git a/content/pipelines/serial.go b/content/pipelines/serial.go
index 7a44ca1..3afda91 100644
--- a/content/pipelines/serial.go
+++ b/content/pipelines/serial.go
@@ -18,7 +18,7 @@ func MD5All(root string) (map[string][md5.Size]byte, error) {
if err != nil {
return err
}
- if info.IsDir() {
+ if !info.Mode().IsRegular() {
return nil
}
data, err := ioutil.ReadFile(path) // HL