diff --git a/inc/MessageTypes.h b/inc/MessageTypes.h index bf49267557191c6bbb27b8a4267d3ea4da12659d..675bdf10460945dde316ee810a20de2e0ee77049 100644 --- a/inc/MessageTypes.h +++ b/inc/MessageTypes.h @@ -27,8 +27,6 @@ enum MessageType { JUICESTART, //send to master to initiate juice phase MAPLEACK, CHUNK, //send to nodes so they have information about what kind of get request to send - APPEND, //process get request and send an append request, need to add this to all replicas too. Check into blackout stuff - APPENDACK, CHUNKACK, //after append ack received, send this back to master to know when things are Done }; diff --git a/src/TcpSocket.cpp b/src/TcpSocket.cpp index 782ad3fcf7a8b0fdc77d8072155648c7f5f7f7dc..545d9109fee99c3a5c4361ab2c76bf38086803bd 100644 --- a/src/TcpSocket.cpp +++ b/src/TcpSocket.cpp @@ -285,6 +285,10 @@ int TcpSocket::messageHandler(int sockfd, string payloadMessage, string returnIP case DNSGET: case DELETE: case GETNULL: + case MAPLESTART: + case MAPLEACK: + case CHUNK: + case CHUNKACK: case DNS:{ cout << "Type: " << msg.type << " payloadMessage: " << payloadMessage << endl; regMessages.push(payloadMessage); //handle from queue