From 5798faab7c763189b99ac62f11e07374c46186f0 Mon Sep 17 00:00:00 2001
From: ale <ale@incal.net>
Date: Mon, 28 Jul 2014 10:39:42 +0100
Subject: [PATCH] remove some old useless code
---
util/mapreduce/mapreduce.go | 26 --------------------------
util/tempfile.go | 33 ---------------------------------
2 files changed, 59 deletions(-)
delete mode 100644 util/mapreduce/mapreduce.go
delete mode 100644 util/tempfile.go
diff --git a/util/mapreduce/mapreduce.go b/util/mapreduce/mapreduce.go
deleted file mode 100644
index 146e8ea..0000000
--- a/util/mapreduce/mapreduce.go
+++ /dev/null
@@ -1,26 +0,0 @@
-package mapreduce
-
-func MapReduce(mapper func(interface{}, chan interface{}),
- reducer func(chan interface{}, chan interface{}),
- input chan interface{},
- pool_size int) interface{} {
- reduce_input := make(chan interface{})
- reduce_output := make(chan interface{})
- worker_output := make(chan chan interface{}, pool_size)
- go reducer(reduce_input, reduce_output)
- go func() {
- for worker_chan := range worker_output {
- reduce_input <- <-worker_chan
- }
- close(reduce_input)
- }()
- go func() {
- for item := range input {
- my_chan := make(chan interface{})
- go mapper(item, my_chan)
- worker_output <- my_chan
- }
- close(worker_output)
- }()
- return <-reduce_output
-}
diff --git a/util/tempfile.go b/util/tempfile.go
deleted file mode 100644
index 8158582..0000000
--- a/util/tempfile.go
+++ /dev/null
@@ -1,33 +0,0 @@
-package util
-
-import (
- "crypto/rand"
- "encoding/hex"
- "fmt"
- "os"
- "path/filepath"
- "time"
-)
-
-var (
- tmpdir = os.TempDir()
-)
-
-func TempName(prefix, suffix string) string {
- buf := make([]byte, 4)
- rand.Read(buf)
- return filepath.Join(
- tmpdir,
- fmt.Sprintf(
- "%s%d.%d.%s%s",
- prefix,
- os.Getpid(),
- time.Now().Unix(),
- hex.EncodeToString(buf),
- suffix))
-
-}
-
-func TempFile(prefix, suffix string) (*os.File, error) {
- return os.Create(TempName(prefix, suffix))
-}
--
GitLab