raft constructor

assignment2/replic_kvstore.go

@@ -2,9 +2,9 @@ package main
 
 import (
 	//"log"
-	//"net"
-	//"net/rpc"
 	"fmt"
+	"net"
+	"net/rpc"
 	"os"
 	"reflect"
 	"strconv"
@@ -48,15 +48,22 @@ type SharedLog interface {
 }
 
 type Raft struct {
-	//some good stuff needs to go here
+	log_array      []LogEntryData
 	commitCh       chan *LogEntryData
-	cluster  *ClusterConfig //cluster
-	id       uint64         //leader
-	commitCh chan LogEntry
+	cluster_config *ClusterConfig //cluster
+	id             uint64         //this server
 }
 
 var cluster_config *ClusterConfig
 
+func NewRaft(config *ClusterConfig, thisServerId int, commitCh chan *LogEntry) (*Raft, error) {
+	rft := new(Raft)
+	rft.commitCh = commitCh
+	rft.cluster_config = config
+	rft.id = thisServerId
+	return rft, nil
+}
+
 //goroutine that monitors channel for commiting log entry
 func monitor_commitCh(c <-chan *LogEntryData) { //unidirectional -- can only read from the channel
 	for {
@@ -87,13 +94,20 @@ func (raft *Raft) Append(data []byte) (LogEntry, error) {
 		return nil, raft.Id
 	}
 	temp := LogEntry{1, data, false}
+	raft.log_array = append(raft.log_array, temp)
 	//broadcast to other servers
 	//wait for acks
 	//send commit on channel
 	raft.commitCh <- temp
 }
 
-func AppendEntriesRPC()
+type RPChandle struct {
+}
+
+func (r *RPChandle) AppendEntriesRPC(log_entry LogEntryData) bool {
+
+	return true
+}
 
 func NewServerConfig(server_id int) (*ServerConfig, error) {
 	server := new(ServerConfig)
@@ -121,6 +135,10 @@ func (e ErrRedirect) Error() string {
 	return "Redirect to server " + strconv.Itoa(cluster_config.Servers[0].Id)
 }
 
+func start_rpc(this_server *ServerConfig) {
+	rpc.Register()
+}
+
 func main() {
 	server_id, err := strconv.Atoi(os.Args[1])
 	if err != nil {
@@ -136,4 +154,9 @@ func main() {
 
 	fmt.Println(reflect.TypeOf(this_server))
 	fmt.Println(reflect.TypeOf(cluster_config))
+
+	go start_rpc(this_server)
+
+	var dummy_input string
+	fmt.Scanln(&dummy_input)
 }