franktank / raft Goto Github PK

Parsing messages between

• AppendEntries RPC Request / Response

• RequestVote RPC Request / Response

• Heartbeat / AppendEntries Request / RequestVote Request -> Multicast

• AppendEntries / RequestVote Response -> Unicast to leader, leader receives one at a time

• Conflicting tasks
  • Threads?
  • Dependency on timer -> mutex?

• Should I append the empty message to the log?
  • Future handle this, for now just append to make logic simpler

• currentTerm -> init at 1
• commitIndex
• log array of JSON?
• lastLogIndex
• lastLogTerm

• Is receiving message concurrent with CocoaAsyncSocket?

• Enumerate cluster and send unicast or multicast?

• nextIndex is dependent on which peer

• Use dispatch queue async for each peer in append entries?

• Delays could lead to timeout in certain nodes if method request takes too long

• Do I need mutex for variables since multithreaded?

• Something to try

  • Do I even need to use the "unicast" socket to send and receive or can I just use the "multicast" sockets I set up?

threads for receiving / sending unicast?

• Request Vote RPC
  • Request / Response
  • Read / look at pseudocode
  • Conditions to step down / grant vote
  • Track when each variable is supposed to be modified
• Follower, Candidate, Leader
  • In design process, think about how to separate each role

• Apply committed messages
  • Two TextViews
    • One with applied
    • One with all entries

• Will redirect message if getIfAddress does not equal to leaderIp
• Everyone starts off as a "LEADER"
• Role should change after first request

• Types

  • Redirect : Follower / Candidate receives message and redirect to leader
  • AppendEntries Request
  • AppendEntries Response
  • entry : store in log

• TBD:

  • RequestVote Request
  • RequestVote Response

• Use timer to set periodic intervals of calling
  • Delete timer and start new timer on reset
  • Read into election timeout more
  • Setup architecture for election -> placeholder for method calls
  • Read more about details

• Concurrent clients!

https://stackoverflow.com/questions/25626117/how-to-get-ip-address-in-swift

• Go through code and add commitIndex and update when possibly

• Create admin / server to handle cluster change
• AddServer / RemoveServer RPC
• Review notes / paper

Save JSON? etc