Skip to main content
1 de 2

BrokenPipeError: [Errno 32] Broken pipe socket python 3.7

buenas tardes, estoy haciendo un script en python para enviar archivos a un servidor en C++, con archivos pequeños, hasta los 50MB, pero cuando pruebo a pasar archivos de 3GB aproximadamente, me salta el error BrokenPipeError: [Errno 32] Broken pipe. Os adjunto el código del cliente:

import socket
import time as t
import math as m

class enviar():
    def __init__(self):
        #Creamos la conexión
        self.emisor=socket.socket(socket.AF_INET,socket.SOCK_STREAM)

        ip='localhost'
        puerto=9999
        #Conectamos
        self.emisor.connect((ip,int(puerto)))
        
        ls=[]
        
        #Enviamos archivo
        a='archivo.zip'
        archivo=open(a, "rb")
        contenido=archivo.read()
        archivo.close()        
        
        #Enviamos el nombre del archivo junto a la longitud del nombre
        self.emisor.send(str(len(a)).encode('UTF-8'))
        t.sleep(1)
        self.emisor.send(a.encode("UTF-8"))
        t.sleep(1)
        
        #Enviamos la longitud del archivo
        self.emisor.send(str(len(contenido)).encode('UTF-8'))
        t.sleep(1)
        
        #Enviamos el contenido del archivo
        for i in range(len(contenido)):
            ls.append(contenido[i*1:(i+1)])
            #Me salta el error cuando llega a esta parte
            self.emisor.send(ls[0])                
            del(ls[0])
        self.emisor.close()


if __name__ == '__main__':
    enviar()

Y aquí os adjunto el código del servidor en C++:

char* memoria;//Puntero donde almacenaremos el mensaje
    double* paquetes;//Creamos un puntero donde guardaremos el numero de paquetes que se reciben
    
    //Esperamos que se reciba datos desde el CLIENTE, en caso que se reciba 0 se producira un error, guardo lo recibido en BUFFER
    if(recv(this->CONEXION_CLIENTE,this->BUFFER,100,0)<0){cout<<"Se ha producido un error, se cierra la conexion"<<endl;close(this->CONEXION_SERVIDOR);}
    else{
        cout<<"Se ha recibido: "<<this->BUFFER<<endl;
        bzero((char*)&memoria,sizeof(memoria));//Llenamos de 0 todo el puntero memoria
        memoria=new char[atoi(this->BUFFER)];//Reservamos espacio en la memoria para recibir el mensaje
        recv(this->CONEXION_CLIENTE,memoria,atoi(this->BUFFER),0);//Recibimos el mensaje
        cout<<"El mensaje reicbido es: "<<memoria<<endl;
        close(this->CONEXION_SERVIDOR);
        
        //Creamos el archivo
        Arch=new Archivo(atoi(this->BUFFER));
        Arch->Crear(memoria);
        
        recv(this->CONEXION_CLIENTE,this->BUFFER,100,0);//Recibimos el numero de paquetes que se necesitan
        paquetes=new double(atoi(this->BUFFER));//Guardamos el numero de paquetes
        
        delete[] memoria;//Liberamos la memoria usada para el nombre    
        
        
        for(double i=0;i<*paquetes;i++){
            
            
            memoria=new char[LONGITUD];//Reservamos un nuevo espacio en la memoria
            recv(this->CONEXION_CLIENTE,memoria,LONGITUD,0);//Recibimos el paquete
            Arch->Contenido(memoria);//Vertimos el contenido del mensaje sobre el fichero
            delete[] memoria;//Liberamos la memoria
            
        }
        
        Arch->Cerrar();//Cerramos el archivo
        delete Arch;//Liberamos la memoria que usaba Arch

Y el código del método Contenido de la clase Archivo:

inline void Archivo::Contenido(char* contenido){
    
    /*
    
        Añadimos contenido al archivo que habiamos creado
    
    */
    
    cout<<++this->CONTADOR<<" Bytes"<<endl;
    
    fputc(*contenido,this->ARCHIVO);
};

Y os agradezco por adelantado su tiempo, un saludo.

PD: Dudo que sirva de algo, pero uso como sistema operativo Debian 10.