etcd-io__etcd/server/util.go

package server

import (
    "fmt"
    "net/http"
    "github.com/coreos/etcd/log"
)

func decodeJsonRequest(req *http.Request, data interface{}) error {
    decoder := json.NewDecoder(req.Body)
    if err := decoder.Decode(&data); err != nil && err != io.EOF {
        log.Warnf("Malformed json request: %v", err)
        return fmt.Errorf("Malformed json request: %v", err)
    }
    return nil
}