opensource/kubo
1
0
Fork 0
mirror of https://github.com/ipfs/kubo.git synced 2025-06-29 17:36:38 +08:00
Code Issues Projects Releases Wiki Activity

fixed uppercase

Browse Source
This commit is contained in:
Siraj Ravel
2014-09-10 12:42:01 -07:00
parent 4f7856a414
commit 07bfa3baf2
1 changed files with 10 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
daemon/daemon.go
View File

@ -27,7 +27,7 @@ type Command struct {
Opts map[string]interface{} Opts map[string]interface{}
} }
func NewDaemonListener(Ipfsnode *core.IpfsNode, addr string) (*DaemonListener, error) { func NewDaemonListener(ipfsnode *core.IpfsNode, addr string) (*DaemonListener, error) {
list, err := net.Listen("tcp", addr) list, err := net.Listen("tcp", addr)
if err != nil { if err != nil {
return nil, err return nil, err
@ -35,7 +35,7 @@ func NewDaemonListener(Ipfsnode *core.IpfsNode, addr string) (*DaemonListener, e
fmt.Println("New daemon listener initialized.") fmt.Println("New daemon listener initialized.")
return &DaemonListener{ return &DaemonListener{
node: Ipfsnode, node: ipfsnode,
list: list, list: list,
}, nil }, nil
} }
@ -77,7 +77,7 @@ func (dl *DaemonListener) handleConnection(conn net.Conn) {
ExecuteCommand(&command, dl.node, conn) ExecuteCommand(&command, dl.node, conn)
} }
func ExecuteCommand(com *Command, Ipfsnode *core.IpfsNode, out io.Writer) { func ExecuteCommand(com *Command, ipfsnode *core.IpfsNode, out io.Writer) {
u.DOut("executing command: %s\n", com.Command) u.DOut("executing command: %s\n", com.Command)
switch com.Command { switch com.Command {
case "add": case "add":
@ -86,7 +86,7 @@ func ExecuteCommand(com *Command, Ipfsnode *core.IpfsNode, out io.Writer) {
depth = -1 depth = -1
} }
for _, path := range com.Args { for _, path := range com.Args {
_, err := commands.AddPath(Ipfsnode, path, depth) _, err := commands.AddPath(ipfsnode, path, depth)
if err != nil { if err != nil {
fmt.Fprintf(out, "addFile error: %v\n", err) fmt.Fprintf(out, "addFile error: %v\n", err)
continue continue
@ -94,13 +94,13 @@ func ExecuteCommand(com *Command, Ipfsnode *core.IpfsNode, out io.Writer) {
} }
case "cat": case "cat":
for _, fn := range com.Args { for _, fn := range com.Args {
DAGnode, err := Ipfsnode.Resolver.ResolvePath(fn) dagnode, err := ipfsnode.Resolver.ResolvePath(fn)
if err != nil { if err != nil {
fmt.Fprintf(out, "catFile error: %v\n", err) fmt.Fprintf(out, "catFile error: %v\n", err)
return return
} }
read, err := dag.NewDagReader(nd, Ipfsnode.DAG) read, err := dag.NewDagReader(dagnode, ipfsnode.DAG)
if err != nil { if err != nil {
fmt.Fprintln(out, err) fmt.Fprintln(out, err)
continue continue
@ -114,25 +114,25 @@ func ExecuteCommand(com *Command, Ipfsnode *core.IpfsNode, out io.Writer) {
} }
case "ls": case "ls":
for _, fn := range com.Args { for _, fn := range com.Args {
DAGnode, err := n.Resolver.ResolvePath(fn) dagnode, err := ipfsnode.Resolver.ResolvePath(fn)
if err != nil { if err != nil {
fmt.Fprintf(out, "ls error: %v\n", err) fmt.Fprintf(out, "ls error: %v\n", err)
return return
} }
for _, link := range nd.Links { for _, link := range dagnode.Links {
fmt.Fprintf(out, "%s %d %s\n", link.Hash.B58String(), link.Size, link.Name) fmt.Fprintf(out, "%s %d %s\n", link.Hash.B58String(), link.Size, link.Name)
} }
} }
case "pin": case "pin":
for _, fn := range com.Args { for _, fn := range com.Args {
DAGnode, err := Ipfsnode.Resolver.ResolvePath(fn) dagnode, err := ipfsnode.Resolver.ResolvePath(fn)
if err != nil { if err != nil {
fmt.Fprintf(out, "pin error: %v\n", err) fmt.Fprintf(out, "pin error: %v\n", err)
return return
} }
err = Ipfsnode.PinDagNode(nd) err = ipfsnode.PinDagNode(dagnode)
if err != nil { if err != nil {
fmt.Fprintf(out, "pin: %v\n", err) fmt.Fprintf(out, "pin: %v\n", err)
return return