LinuxQuestions.org - can't send files with sockets

hi! I need to send files from a java client to a c++ server. What i do is: I divide the size of the files into blocks. For example if the client wants to send a file of 100 KB he to this:
1º que sends the size of the block (an int). For examplee 30 KB
2º que sends the amount of bloacks ( 3 )
3º the bytes that were not send ( 10 )
4º sends all blocks one each time
5º finish

The problem is this: the server receive the file, i mean, the size of the file is perfect but i can't open it. for exampleif its a JPG when you open it, it is all black. What can be happening ?? Please, i really need to solve this. I use kdevelop in suse 10.

This client code is this:

Code:

import java.io.*;

import java.net.*;

import java.lang.*;

import java.util.StringTokenizer;



public class ejemplo {







        public static void main (String[] args){



        Enviar_Archivo(Abrir_Archivo());



        }



        public static File Abrir_Archivo() {



                String cadena="",aux;



                File archivo = new File( "/home/mariano/000_2386.jpg" );



                if ( !archivo.exists() || !archivo.canRead()) {

                            System.out.println("Can't read " + archivo);



                }

                return archivo;







        }







          public static void Enviar_Archivo(File archivo){







        try {

                FileInputStream file = new FileInputStream(archivo);

                BufferedInputStream buffer = new BufferedInputStream (file);

                //DataInputStream input = new DataInputStream (buffer);

                //System.out.println(archivo.length());



                /*FileReader reader= new FileReader(archivo);

                BufferedReader buffer = new BufferedReader (input);



                while ((aux=buffer.readLine())!=null)

                        cadena=cadena+'\n'+aux;*/





                Sock socket = new Sock();

                socket.iniciar((short) 1400,"127.0.0.1");

                socket.CrearESSocket();



                int bloque=1024;

                int total = file.available( );

                int veces=total / bloque;

                int resto=total % bloque;

                byte  data [] = new byte [ bloque ];





                System.out.println("Quedan por enviar:");

                System.out.println(resto);

                System.out.println("tam bloque: ");

                System.out.println(bloque);

                System.out.println("cant bloques:");

                System.out.println(veces);

                //int got = input.available();

                //socket.enviar("hollaaado");

                /*socket.*/enviar(socket,bloque);

                /*socket.*/enviar(socket,veces);



                /*System.out.println("Quedan por enviar:");

                System.out.println(resto);

                resto = 9;*/

                        /*socket.*/enviar(socket,resto);



                int k=0;

                while ( total > bloque ) {

                        k=k+1;

                        //int leidos=buffer.read( data );

                          total=total-bloque;

                        socket.enviar(buffer.read(data));

                        //System.out.println(leidos);

                }

                System.out.println(k);

                if (total > 0){

                //for (long i=0;i<99999999;i++);

                System.out.println("sisis");

                        /*socket.*///enviar(socket,total);

                enviar(socket,1000);

                System.out.println("Quedan por enviar:");

                System.out.println(total);

                        socket.enviar(buffer.read(data));

                        /*int leidos=buffer.read(data);

                        System.out.println(leidos);*/

                        System.out.println("Se leyo todo el buffer");

                }







        }



        catch(FileNotFoundException excepcion){

                System.out.println("Archivo no encontrado"+excepcion);

                  //return null;

        }



        catch (IOException excepcion) {

                System.out.println("Error"+excepcion);

                //return null;





        }

  }





static public void enviar(Sock s, int b){

byte auxInt[]=new byte[4];

auxInt=toByteArray(b);

byte[] buff=new byte[4];

int i=0;

for(i=0;i<4;i++) buff[i]=auxInt[i];

s.enviar(buff); //Está en Sock.java

}

//////////////////////////////////////////////

static private byte[] toByteArray(int foo) {

byte array[]=new byte[4];

 for (int iInd = 0; iInd < 4; ++iInd) {

    array[iInd] = (byte) ((foo >> (iInd*8)) & 0xFF);  

}

  return darVuelta(array);}

////////////////////////////////

static private byte[] darVuelta(byte[] aux){

byte buff[]=new byte[4];

int i,j;

for(i=0,j=3;i<4;i++,j--) buff[i]=aux[j];

return buff;

}

////////////////////////////////





}

and the server:

int Transmisor::recibirArch(char* archNuevo,char* archTexto, int socket) {
/**Se encarga de recibir un archivo desde destinatario*/
int resp;

cout<<"archNUevo: "<<archNuevo<<endl;
cout<<"socket: "<<socket<<endl;

ofstream out(archNuevo, ios::out | ios::binary | ios::trunc);
int cant_bloques,tam_bloque,i,cant_restantes;

char buf[MAX_TAM_BUFFER];

bzero(buf,MAX_TAM_BUFFER);
if(Socket::recibir(socket,buf,4)==-1) perror("Error");
tam_bloque=0;
memcpy(&tam_bloque,buf,4);
tam_bloque=ntohl(tam_bloque);
cout <<"tam bloquue: "<<tam_bloque<<endl;

bzero(buf,MAX_TAM_BUFFER);
if(Socket::recibir(socket,buf,4)==-1) perror("Error");
cant_bloques=0;
memcpy(&cant_bloques,buf,4);
cant_bloques=ntohl(cant_bloques);
cout <<"cant_bloques: "<<cant_bloques<<endl;

bzero(buf,MAX_TAM_BUFFER);
if(Socket::recibir(socket,buf,4)==-1) perror("Error");
cant_restantes=0;
memcpy(&cant_restantes,buf,4);
cant_restantes=ntohl(cant_restantes);
cout <<"cant_restantes: "<<cant_restantes<<endl;

char buffer[tam_bloque];

for(i=0; i<cant_bloques; i++) {
bzero(buffer,tam_bloque);
Socket::recibir(socket,buffer,tam_bloque);
out.write(buffer,tam_bloque);
}
cout<<"okok,I: "<<i<<endl;

char buffer2[cant_restantes];
bzero(buffer2,cant_restantes);
Socket::recibir(socket,buffer2,cant_restantes);

out.write(buffer2,cant_restantes);
out.flush();
out.close();

/*una vez que recibi bien el arch llamo a un metodo para que me lop convuierta a
arch de texto plano*/
resp = this->convertirATexto(archNuevo,archTexto);
return resp;
}

lots of thanks