server_tcp.go

package main

import (
	"errors"
	"log"
	"net"
	"net/rpc"

	"shared"
)

type Arith int

func (t *Arith) Multiply(args *shared.Args, reply *int) error {
	*reply = args.A * args.B
	return nil
}

func (t *Arith) Divide(args *shared.Args, reply *shared.Quotient) error {
	if args.B == 0 {
		return errors.New("Divided by zero")
	}
	reply.Quo = args.A / args.B
	reply.Rem = args.A % args.B
	return nil
}

func main() {
	arith := new(Arith)
	server := rpc.NewServer()
	server.Register(shared.Arith(arith))

	l, e := net.Listen("tcp", "localhost:1234")
	if e != nil {
		log.Fatal("listen error", e)
	}

	server.Accept(l)
}