From df6e89407ea4a7f9cf65d333ae11d8ee047e766b Mon Sep 17 00:00:00 2001
From: Harshavardhana <harsha@harshavardhana.net>
Date: Tue, 23 Dec 2014 23:34:50 -0800
Subject: [PATCH] Implement sysctl map

---
 pkgs/sysctl/sysctl_linux.go | 52 +++++++++++++++++++++++++++++++++++++
 pkgs/sysctl/sysctl_test.go  | 22 ++++++++++++++++
 2 files changed, 74 insertions(+)
 create mode 100644 pkgs/sysctl/sysctl_linux.go
 create mode 100644 pkgs/sysctl/sysctl_test.go

diff --git a/pkgs/sysctl/sysctl_linux.go b/pkgs/sysctl/sysctl_linux.go
new file mode 100644
index 000000000..f8eb3cca3
--- /dev/null
+++ b/pkgs/sysctl/sysctl_linux.go
@@ -0,0 +1,52 @@
+// !build linux,amd64
+
+package sysctl
+
+import (
+	"bufio"
+	"os/exec"
+	"strings"
+
+	"github.com/minio-io/minio/pkgs/utils"
+)
+
+type Sysctl struct {
+	Sysattrmap map[string][]byte
+}
+
+func (s *Sysctl) Get() error {
+	attrMap := make(map[string][]byte)
+
+	// Get full system level list
+	sysctl_cmd := exec.Command("sysctl", "-a")
+	// Sort the output and throw away duplicate keys
+	sort_cmd := exec.Command("sort", "-u")
+	// Ignore permission denied errors from sysctl output
+	grep_cmd := exec.Command("grep", "-v", "permission")
+
+	output, err := utils.ExecPipe(sysctl_cmd, sort_cmd, grep_cmd)
+	if err != nil {
+		return err
+	}
+
+	scanner := bufio.NewScanner(output)
+	split := func(data []byte, atEOF bool) (advance int, token []byte, err error) {
+		advance, token, err = bufio.ScanLines(data, atEOF)
+		return
+	}
+
+	scanner.Split(split)
+
+	for scanner.Scan() {
+		split := strings.Split(scanner.Text(), "=")
+		if len(split) < 1 {
+			println("Invalid token skip..")
+			continue
+		}
+		k, v := strings.TrimSpace(split[0]), strings.TrimSpace(split[1])
+		attrMap[k] = []byte(v)
+	}
+
+	s.Sysattrmap = attrMap
+	return nil
+}
diff --git a/pkgs/sysctl/sysctl_test.go b/pkgs/sysctl/sysctl_test.go
new file mode 100644
index 000000000..fdfc6aa2a
--- /dev/null
+++ b/pkgs/sysctl/sysctl_test.go
@@ -0,0 +1,22 @@
+// !build linux,amd64
+
+package sysctl
+
+import (
+	"testing"
+
+	. "gopkg.in/check.v1"
+)
+
+type MySuite struct{}
+
+var _ = Suite(&MySuite{})
+
+func Test(t *testing.T) { TestingT(t) }
+
+func (s *MySuite) TestSysctl(c *C) {
+	sysctl := Sysctl{}
+	err := sysctl.Get()
+	c.Assert(err, IsNil)
+	c.Assert(sysctl.Sysattrmap, Not(Equals), 0)
+}