mexendo no get

src/messages.cpp

@@ -335,6 +335,9 @@ int Message::sendGET(unsigned char* fileName, char* currentPath){
             }
           }
         }
+      }else{
+        cout << "Tempo limite de resposta excedido :c\n" << endl;
+        cout << "TIMEOUT ATINGIDO (messages.cpp::sendPUT)" << endl;
       }
     }
   }
@@ -537,9 +540,9 @@ int Message::receiveLS(unsigned char* options, char* currentPath){
 
 int Message::receiveGET(unsigned char* fileName){
   char* tam;
-  unsigned char* dados;
-  int fileSize, rv, i, success = 0;
-  ifstream file;
+  unsigned char *dados, *fileData;
+  int fileSize, rv, i, success = 0, length;
+  ifstream fileIn;
   string temp, data;
   SubMessage resposta, answer;
   struct pollfd ufds[1];
@@ -554,20 +557,35 @@ int Message::receiveGET(unsigned char* fileName){
     send(soquete,resposta.objToString(),68, 0);
   } else {
     // Calcula o tamanho do arquivo
-    file.seekg (0, ios::end);
-    fileSize = file.tellg();
-    file.seekg (0, ios::beg);
+    // file.seekg (0, ios::end);
+    // fileSize = file.tellg();
+    // file.seekg (0, ios::beg);
+    //
+    // while(getline(file, temp)) {
+    //   data += temp + "\n";
+    // }
+    // dados=(unsigned char*)malloc(sizeof(unsigned char)*data.size());
+    // for(i = 0; i < data.size(); ++i){
+    //   dados[i] = data[i];
+    // }
 
-    while(getline(file, temp)) {
-      data += temp + "\n";
-    }
-    dados=(unsigned char*)malloc(sizeof(unsigned char)*data.size());
-    for(i = 0; i < data.size(); ++i){
-      dados[i] = data[i];
+    fileIn.open((char*)fileName, ios::binary);
+
+    // Contagem do tamanho do arquivo.
+    fileIn.seekg (0, ios::end);
+    length = fileIn.tellg();
+    fileIn.seekg (0, ios::beg);
+
+    // Alocação do vetor para a leitura do arquivo.
+    fileData = new unsigned char[length];
+
+    // Leitura.
+    for (i = 0; i < length; ++i){
+      fileIn.read((char*)&fileData[i], sizeof(unsigned char));
     }
 
     // Manda o tamanho do arquivo
-    sprintf(tam, "%d", fileSize);
+    sprintf(tam, "%d", length);
     while(!success){ // Esse while está aqui pois a mensagem pode não chegar e precisar ser reenviada
       resposta.setData((unsigned char*)tam,9,0);
       send(soquete, resposta.objToString(), resposta.getSize()+4, 0);

src/submessages.cpp

@@ -13,8 +13,14 @@ void SubMessage::setParity(){
   int i, j, bitsParity[8];
 
   // Alocação da matriz de bits
-  bitsMessage = new int*[getSize()];
-  for(i = 0 ; i < getSize() ; i++){
+  bitsMessage = new int*[getSize()+2];
+  bitsMessage[0] = new int[8];
+  bitsMessage[1] = new int[8];
+  for(j = 0 ; j < 8 ; j++){
+    bitsMessage[0][j] = ((((sizSeqTyp >> 8) & 0x00FF) >> (7-j)) & 0x01);
+    bitsMessage[1][j] = ((((sizSeqTyp >> 0) & 0x00FF) >> (7-j)) & 0x01);
+  }
+  for(i = 2 ; i < getSize()+2 ; i++){
     bitsMessage[i] = new int[8];
     // Divide os dados em bits
     for(j = 0 ; j < 8 ; j++){
@@ -25,7 +31,7 @@ void SubMessage::setParity(){
   // Soma os bits verticalmente
   for(j = 0 ; j < 8 ; j++){
     bitsParity[j] = 0;
-    for(i = 0 ; i < getSize() ; i++){
+    for(i = 0 ; i < getSize()+2 ; i++){
       bitsParity[j] = bitsParity[j] + bitsMessage[i][j];
     }
     // Caso a soma vertical de uma coluna for par, bitsParity recebe 1,
@@ -38,7 +44,7 @@ void SubMessage::setParity(){
     // Atribui os bits para parity (variável de paridade do objeto)
     parity = (parity << 1) | bitsParity[j];
   }
-  for(i = 0 ; i < getSize() ; i++){
+  for(i = 0 ; i < getSize()+2 ; i++){
     if(bitsMessage[i]){
       delete(bitsMessage[i]);
     }
@@ -141,26 +147,26 @@ int SubMessage::checkParity(){
   int i, j, bitsParity[8];
   unsigned char parityTest;
 
-cout << "AQUI" << endl;
   // Alocação da matriz de bits
-cout << "this-getSize = " << getSize() << endl;
-// bitsMessage = (int**) malloc(sizeof(int*)*getSize());
-  bitsMessage = new int*[getSize()];
-  //bitsMessage = (int**) realloc(bitsMessage,sizeof(int*)*getSize());
-cout << "AQUI2" << endl;
-  for(i = 0 ; i < getSize() ; i++){
+  bitsMessage = new int*[getSize()+2];
+  bitsMessage[0] = new int[8];
+  bitsMessage[1] = new int[8];
+  for(j = 0 ; j < 8 ; j++){
+    bitsMessage[0][j] = ((((sizSeqTyp >> 8) & 0x00FF) >> (7-j)) & 0x01);
+    bitsMessage[1][j] = ((((sizSeqTyp >> 0) & 0x00FF) >> (7-j)) & 0x01);
+  }
+  for(i = 2 ; i < getSize()+2 ; i++){
     bitsMessage[i] = new int[8];
     // Divide os dados em bits
     for(j = 0 ; j < 8 ; j++){
       bitsMessage[i][j] = ((data[i] >> (7-j)) & 0x01);
     }
   }
-cout << "AQUI 3" << endl;
 
   // Soma os bits verticalmente
   for(j = 0 ; j < 8 ; j++){
     bitsParity[j] = 0;
-    for(i = 0 ; i < getSize() ; i++){
+    for(i = 0 ; i < getSize()+2 ; i++){
       bitsParity[j] = bitsParity[j] + bitsMessage[i][j];
     }
     // Caso a soma vertical de uma coluna for par, bitsParity recebe 1,
@@ -173,13 +179,11 @@ cout << "AQUI 3" << endl;
     // Atribui os bits para parity (variável de paridade do objeto)
     parityTest = (parityTest << 1) | bitsParity[j];
   }
-cout << "AQUI 4" << endl;
-  for(i = 0 ; i < getSize() ; i++){
+  for(i = 0 ; i < getSize()+2 ; i++){
     if(bitsMessage[i]){
       delete(bitsMessage[i]);
     }
   }
-cout << "AQUI 5" << endl;
   delete(bitsMessage);
 cout << "AQUI 6" << endl;
   if (parityTest == parity){