X-Git-Url: http://www.git.cypherpunks.ru/?p=goircd.git;a=blobdiff_plain;f=goircd.go;h=9fdabc0357d1a7430a422aee6c919284b936ce28;hp=e1768048f5858ac01be79a9955b9b0f4544048af;hb=41f96494948d1f9f1e0c3066099e0bd9ad0ee8dd;hpb=c1d256aaa0af4e0cb3649552e5067a9ec3bc94d5 diff --git a/goircd.go b/goircd.go index e176804..9fdabc0 100644 --- a/goircd.go +++ b/goircd.go @@ -18,12 +18,11 @@ along with this program. If not, see . package main import ( - "bytes" "crypto/tls" "flag" + "io/ioutil" "log" "net" - "os" "path" "path/filepath" "strings" @@ -77,27 +76,24 @@ func Run() { if !path.IsAbs(*statedir) { log.Fatalln("Need absolute path for statedir") } - states, err := filepath.Glob(*statedir + "/#*") + states, err := filepath.Glob(path.Join(*statedir, "#*")) if err != nil { log.Fatalln("Can not read statedir", err) } for _, state := range states { - fd, err := os.Open(state) + buf, err := ioutil.ReadFile(state) if err != nil { - log.Fatalln("Can not open state", state, err) - } - buf := make([]byte, 1024) - _, err = fd.Read(buf) - fd.Close() - if err != nil { - log.Fatalln("Can not read state", state, err) + log.Fatalf("Can not read state %s: %v", state, err) } room, _ := daemon.RoomRegister(path.Base(state)) - buf = bytes.TrimRight(buf, "\x00") contents := strings.Split(string(buf), "\n") - room.topic = contents[0] - room.key = contents[1] - log.Println("Loaded state for room", room.name) + if len(contents) < 2 { + log.Printf("State corrupted for %s: %q", room.name, contents) + } else { + room.topic = contents[0] + room.key = contents[1] + log.Println("Loaded state for room", room.name) + } } go StateKeeper(*statedir, state_sink) log.Println(*statedir, "statekeeper initialized")