Commit 4a1c56ee authored by Kirill Smelkov's avatar Kirill Smelkov

.

parent fb5d9b99
...@@ -380,7 +380,7 @@ Partition Table (general & current-py) ...@@ -380,7 +380,7 @@ Partition Table (general & current-py)
#Np (how-many partitions) #R (replication factor) #Np (how-many partitions) #R (replication factor)
Cell Cell
.node (-> .uuid, .addr) .node (-> .nodeid, .addr)
.state .state
.backup_tid # last tid this cell has all data for .backup_tid # last tid this cell has all data for
...@@ -667,7 +667,7 @@ VerificationManager < BaseServiceHandler ...@@ -667,7 +667,7 @@ VerificationManager < BaseServiceHandler
Node Node
.state .state
.address .address
.uuid .nodeid
.manager # -> NodeManager .manager # -> NodeManager
.connection .connection
...@@ -676,7 +676,7 @@ Node ...@@ -676,7 +676,7 @@ Node
NodeManager NodeManager
[]Node []Node
{} address -> Node {} address -> Node
{} uuid -> Node {} nodeid -> Node
{} type -> set<Node> {} type -> set<Node>
{} state -> set<Node> {} state -> set<Node>
...@@ -731,8 +731,8 @@ Protocol ...@@ -731,8 +731,8 @@ Protocol
Checksum Checksum
.checksum [20]u8 .checksum [20]u8
UUID NodeID // UUID
.uuid s32 // 0 <-> None .nodeid s32 // 0 <-> None
TID TID
.tid [8]byte // None <-> \xff*8 .tid [8]byte // None <-> \xff*8
...@@ -748,12 +748,12 @@ Float ...@@ -748,12 +748,12 @@ Float
NodeList [] NodeList []
type NodeType type NodeType
address Address address Address
uuid UUID nodeid NodeID
state NodeState state NodeState
id_timestamp Float id_timestamp Float
CellList [] CellList []
uuid UUID nodeid NodeID
state CellState state CellState
RowList [] RowList []
...@@ -765,7 +765,7 @@ HistoryList [] ...@@ -765,7 +765,7 @@ HistoryList []
size Number // u32 size Number // u32
UUIDList [] UUIDList []
uuid UUID nodeid NodeID
TidList [] TidList []
tid TID tid TID
...@@ -792,7 +792,7 @@ CloseClient ...@@ -792,7 +792,7 @@ CloseClient
RequestIdentification RequestIdentification
.protocol_version PProtocol .protocol_version PProtocol
.node_type NodeType .node_type NodeType
.uuid UUID .nodeid NodeID
.address Address .address Address
.name String .name String
.id_timestamp Float .id_timestamp Float
......
...@@ -57,6 +57,20 @@ func (m *Master) ServeClient(ctx context.Context, conn *Conn) { ...@@ -57,6 +57,20 @@ func (m *Master) ServeClient(ctx context.Context, conn *Conn) {
// XXX +error return? // XXX +error return?
func (m *Master) ServeStorage(ctx context.Context, conn *Conn) { func (m *Master) ServeStorage(ctx context.Context, conn *Conn) {
// TODO // TODO
// >Recovery
// <AnswerRecovery
// ? >UnfinishedTransactions
// ? <AnswerUnfinishedTransactions (none currently)
// <NotifyReady
// >StartOperation
// >StopOperation (on shutdown)
} }
func (m *Master) ServeAdmin(ctx context.Context, conn *Conn) { func (m *Master) ServeAdmin(ctx context.Context, conn *Conn) {
......
...@@ -676,7 +676,7 @@ type AnswerPartitionList struct { ...@@ -676,7 +676,7 @@ type AnswerPartitionList struct {
// Ask information about nodes // Ask information about nodes
// Answer information about nodes // Answer information about nodes
type X_NodeList struct { type NodeList struct {
NodeType NodeType
} }
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment