WONDERFUL PROJECT OF MULTIPLE DATA COMPRESSION USING SOCKET-WITH SERVER ,CLIENT,PROCESS

anubala331

**/A NICE IMPLEMENTATION OF MULTIPLE DATA COMPRESSION USING SOCKET/**

//WE KNOW SOCKETS..//

//SOCKETS ARE USED TO COMMUNICATE BETWEEN THE TWO SYSTEMS ON THE NET.

//IN THIS PROJECT ...I HAD DEMANDED FOR A COMRESSED FILE FOR ORIGINAL FILE BY CLIENT.IN THE SITUATION ..I HAD LESS MEMORY IN DEVICE ...& NO PACKAGE TO TRANSFER THE FILE ..& DUE TO LESS MEMORY ...I GET NEED TO COMPRESS THE FILE ..SO I MADE THE PROJECT IN WHICH CLIENT IS ALWAYS DEMANDING FOR ..DIFFRENT-DIFFRENT COMPRESSIONS OF DIFFRENT FILES...& SERVER IS CONNECTED THROUGH THE SOCKET..& SERVER AGAIN CONNECTED TO THE PERTICULAR PROCESS IN WHICH UNIVERSAL CODE OF COMPRESSION IS WRITTEN..ALL THE COMPRESSIONS OF DIFFRRENT FILE ARE DONE ACCORDING TO SIZE & NO. OF DISTINCT CHARACTERS OF THAT FILE ..//& COMPRESSED FILE IS AGAIN ..GIVEN BACK TO CLIENT BY PROCESS THROUGH SERVER//

#include<stdio.h>

#include<stdlib.h>

#include<unistd.h>

#include<string.h>

#include<sys/socket.h>

#include<linux/in.h>

#include<fcntl.h>

struct sockaddr_in client_add,client_add1;//VARIABLES OF STRUCTURE ARE DECLARED TO USE IT FURTHER..//

int main()

{

//char opr='+';

socklen_t len;

**char *buff;**

buff=malloc(1000);

**char *buf;**

buf=malloc(1000);

int i=0,wfd,ret=0,count=1,rfd,ffd,fd,num1=5,num2=3;

len=sizeof(struct sockaddr_in);

client_add.sin_family=AF_INET;

client_add.sin_port=htons(4444);//IP ADDRESS IS NECCESARY TO FIND OTHER SYSTEM ON NET..& PORT NO. TO ENTER INTO THTV SYSTEM....& OFFCOURSE FAMILY OF ADDRESS IS ALSO GIVEN INTO ELEMENTS OF STRUCTURE sockaddr_in DEFINED IN SYS/SOCKET.H

client_add.sin_addr.s_addr=inet_addr("127.0.0.1");

fd=socket(AF_INET,SOCK_STREAM,0);//SOCKET CALL IS MADE TO CREATE THE SOCKET

printf("fd=%d\n",fd);

ret=connect(fd,(struct sockaddr*)&client_add,len);//CONNECT CALL IS TO CONNECT THE SOCKET TO SERVER ...THERE WILL BE TWO DIFFRENT SOCKETS CREATED AT TWO SYSTEMS .../BOTH THE SOCKETS WILL COMMUNICATE EACH OTHER THROUGH NET..BUT HOW?

//ACTUALLY SERVER SOCKE THAT IS CREATED ON SERVER SIDE WILL CREATE COPY OF CLIENT SOCKET ...USING ACCEPT CALL CORESSPONDING TO CONNECT CALL...FD OF THAT COPY OF CLIENT SOCKET WILL BE TREATED SAME AS THAT COMING OF CLIENT SOCKET..MEANS IN CLIENT SOCKET SOME FILE TO BE COMPRESSED IS WRITTEN & READ ON THE SERVER SIDE FROM THE COPY OF CLIENT SOCKET...//

if(ret==0)

printf("connected\n");

else

printf("not connected\n");

ffd=socket(AF_INET,SOCK_STREAM,0);//ONE ANOTHER SOCKET IS CREATED ..TO GET THE RESULT OF ..MEANS TO GET THE COMPRESSED FILE ..//

printf("ffd=%d\n",ffd);

ret=connect(ffd,(struct sockaddr*)&client_add,len);//AT SAME TIME ..WE CAN CONNECT TWO OR MORE SOCKETS TO THE SAME SERVER...THROUGH SAME PROGRAM ..OR DIFFRENT APPLICATION...BUT THE ONE SERVER WILL ALWAYS REMAIN A SINGLE UNIQUE PORT TO COMMUNICATE TO ANY OF THE CLIENT...MEANS FOR A PERTICULAR SERVER ...NONE OF THE PORT NO. & IP ADDRESS | ADDRESSS FAMILY IS GOING TO BE CHANGED..//

if(ret==0)

printf("connected\n");

else

printf("not connected\n");

anubala331

count=1;

rfd=open("source4",O_RDONLY);//OPEN THE FILE IN O_RDONLY MODE WHICH IS TO BE COMPRESSED//

while(count)

{

//printf("set set set c1\n");

//sleep(1)

count=read(rfd,(buff+i),1);//READ
THE FILE INTO A POINTER BUFFER..TO SEND IT TO SERVER 1 BY 1 CHARACTER
..ACCORDING TO COUNT ...BCZ WE DONT NOW ALREADY...WHAT COULD BE SIZE OF
FILE WHICH IS TO BE COMPRESSED

//ALTHOUGH IT IS NOT VERY GOOD ..TO READ
THE FILE IN A POINTER ..BCZ FILE COULD IN SOME KB..BUT THIS TIME IT IS
OK..//U MAY READ IT AS IT IS..& SEND TO SERVER CHARACTER BY
CHARACTER..//

if(count==0)

break;

**//printf("buff=%c\tcount=%d\n",*(buff+i),count);**

i++;

}

count=write(fd,buff,strlen(buff));//NOW ACCORDING TO LENGTH OF BUFFER ...U MAY WRITE THE FILE TO SERVER TO GET ..THE OUPUT BACK..//

printf("buff=%s count=%d\n",buff,count);

//close(fd);

count=1;i=0;

while(count)

{

printf("give give give compressed\n");

count=read(ffd,(buf+i),1);//THROUGH OTHER SOCKET & INTO ANOTHER BUFFER ..RESULTING COMPRESSED FILE IS REad

**if(count==0 || *(buf+i) == '\0')**

break;

**printf("buf=%c_________________count=%d\n",*(buf+i),count);**

i++;

}

wfd=open("cldest",O_WRONLY|O_CREAT);//CREATE & OPEN A FILE INTO CLIENT'S SYSTEM TO ENTER COMPRESSED FILE INTO IT..//

write(wfd,buf,strlen(buf));//WRITE THE COMPRESSED FILE INTO CLIENT'S SYSTEM..//

close(wfd);close(ffd);//CLOSE THE FD'S//

return 0;

}

count=1;i=0;

while(count)

{

printf("give give give compressed\n");

count=read(ffd,(buf+i),1);//THROUGH OTHER SOCKET & INTO ANOTHER BUFFER ..RESULTING COMPRESSED FILE IS REad

**if(count==0 || *(buf+i) == '\0')**

break;

**printf("buf=%c_________________count=%d\n",*(buf+i),count);**

i++;

}

wfd=open("cldest",O_WRONLY|O_CREAT);//CREATE & OPEN A FILE INTO CLIENT'S SYSTEM TO ENTER COMPRESSED FILE INTO IT..//

write(wfd,buf,strlen(buf));//WRITE THE COMPRESSED FILE INTO CLIENT'S SYSTEM..//

close(wfd);close(ffd);//CLOSE THE FD'S//

return 0;

}

anubala331

//THIS IS SERVER//

//KEY POINT:DO NOT USE ^Z TO KILL THE PROCESS ..BCZ IS NOT ACTUALLY FINISHES USING ^Z..PORT REMAIN BUSY//ONLY USE ^C TO KILL THE PROCESS ..IT WILL TEND FREE UR PORT...//

#include<stdio.h>

#include<stdlib.h>

#include<unistd.h>

#include<string.h>

#include<sys/socket.h>

#include<linux/in.h>

struct sockaddr_in ser_add,client_addr,client_addr1,pro_add,pro_add1;

int main()

{

**char *buff;**

buff=malloc(1000);

**char *bufff;**

bufff=malloc(1000);

printf("buff=%s\n",buff);

int ret=0,i=0,count=1,ffd,ppfd,fd,pfd,sock_fd,true=1;

socklen_t len;

len=sizeof(struct sockaddr_in);

ser_add.sin_family=AF_INET;

ser_add.sin_port=htons(4444);//CLIENT WILL SEARCH THE SERVER ON NET ..//USING ITS PUBLIC IP.& ENTER INTO SYSTEM USING PORT NO..

ser_add.sin_addr.s_addr=inet_addr("127.0.0.1");

sock_fd=socket(AF_INET,SOCK_STREAM,0);//SERVER SOCKET IS CREATED USING SOCKET SYSTEM CALL//

if(sock_fd>0)

printf("sock_fd is obtained\n");

printf("sock_fd=%d\n",sock_fd);

ret=setsockopt(sock_fd,SOL_SOCKET,SO_REUSEADDR,&true,sizeof(int));//USUALLY USED TO UNLINK THE PORT

if(ret==0)

printf("setsockopt is succesful..it will unlink\n");

else

printf("setsockopt is unsuccesful ..not be able to unlink\n");

ret=bind(sock_fd,(struct sockaddr*)&ser_add,len);//USED TO BIND THE SOCKET..//MEANS TO PROVIDE THE NAME TO SERVER SOCKET..//BIND CALL DO NOT MERE PROVIDE NAME TO SOCKET OF SERVER BUT ALSO PROVIDE ADDRESS TO THE SYSTEM..A SPECIAL ADDRESS WHERE CLIENT AFTER ENTERY TO THE PORT ..FINDS THE SERVER SOCKET...THROUGH THAT PERTICULAR PORT..//

//IT BINDS THE ADDRESS OF SOCKET TO ITS PORT NO..THAT IS WHY IT IS CALLED BIND SYSTEM CALL//

if(ret==0)

printf("bind is succesful...client system will be connected\n");

else

printf("bind is not succesful\n");

ret=listen(sock_fd,5);//USED TO MAKE THAT HOW MUCH MAX. NO. OF CLIENTS COULD WAIT?//

if(ret==0)

printf("listen succesful\n");

else

printf("listen is not succesful\n");

fd=accept(sock_fd,(struct sockaddr*)&client_addr,&len);//TO ACCEPT THE CONNECT CALL OF CLIENT..//HERE ARE 4 ACCEPT CALLS ...1ST CLIENT WILL BE OPERATED ...SO 2 FDS OF CLIENT 1 BY 1 ..WILL BE CREATED../

//THEN PROCESS WILL BE OPERATRED...THEN ONE 1 BY 1 ..2 FDS OF PROCESS SOCKET ARE ALSO CREATED..4TH CALL IS DOWN...WRITTEN..

printf("fd=_____________%d\n",fd);

**ffd=accept(sock_fd,(struct sockaddr*)&client_addr1,&len);//ALL THE 4 SOCKETS OF 2 OF CLIENT & 2 OF PROCESS ARE CONNECTED AT THE SAME TIME ..//**

printf("ffd=_____________%d\n",ffd);

**pfd=accept(sock_fd,(struct sockaddr*)&pro_add,&len);**

printf("pfd=_____________%d\n",pfd);

while(count)

{

//printf("set set set ser\n");

count=read(fd,(buff+i),1);//FILE TO BE COMPRRESSED THAT WAS WRITTEN BY CLIENT INTO 1 OF THE SOCKET ..IS READ BY COPY CREATED OF THAT SOCKET ..I.E. 1ST OF ALL CREATED..//

**if(*(buff+i)=='\n')**

break;

**//printf("buff=%c\tcount=%d\n",*(buff+i),count);**

i++;

}

close(fd);

anubala331

write(pfd,buff,strlen(buff));//WRITE THAT FILE TO BE COMPRESSED INTO PROCESS INTO COPY OF 1 OF THE PROCESS SOCKET

printf("buff=%s\n",buff);

count=1,i=0;

ppfd=accept(sock_fd,(struct sockaddr*)&pro_add1,&len);//I
WILL WAIT FOR THE ACCEPT OF 2ND CONNECT CALL OF PROCESS IN WHICH RESULT
I.E. COMPRESSED FILE IS GOING TO COME AFTER THE COMPRESSION ..//

printf("ppfd=_____________%d\n",ppfd);

      while(count ==1)
        {
        printf("GIVE ME GIVE ME COMPRESSED\n");
        count=read(ppfd,(bufff+i),1);//BY COPY OF 2ND SOCKET OF PROCESS..COMPRESSED FILE IS READ,,//
                if(count==0 || (bufff+i) == '\0')
                        break;
       printf("bufffff for desti=%c_________________count=%d\n",(bufff+i),count);
        i++;
        }
        close(ppfd);
        write(ffd,bufff,strlen(bufff));//WRITE THAT COMPRESSED FILE INTO COPY OF 2ND SOCKET OF CLIENT CREATED BY SERVER SOCKET..//

        return 0;

}

anubala331

**/THIS IS PROCESS/**

#include<stdio.h>

#include<stdlib.h>

#include<unistd.h>

#include<fcntl.h>

#include<string.h>

#include<sys/socket.h>

#include<linux/in.h>

**char* masterarray;**

int ret=0,size=1,count=1,flag=0;

struct sockaddr_in pro_add,pro_add1;

unsigned char buff,ch=0,byt=byt^byt,in=in^in;

int indu(char buff)

{

int i=0;

**while(buff != *(masterarray+i))**

i++;

return i;

}

int compress1()

{

printf("IN COMPRESS 1\n");

int fd,wfd,i=0,ind;

//char ch;

fd=open("ssource",O_RDONLY);

printf("fd=%d\n",fd);

wfd=open("desti",O_WRONLY|O_CREAT);

printf("wfd=%d\n",wfd);

count=1;

while(count)

{

if(count==0)

break;

for(i=0;i<8;i++)

{

count=read(fd,&buff,1);

if(count==0 || buff == '\0')

break;

ind=indu(buff);

ch=ind;

ch=ch<<7;

ch=ch>>(i);

byt=byt|ch;

ch=0;

}

write(wfd,&byt,1);

byt=byt^byt;

}

close(fd);close(wfd);

return 0;

}

anubala331

int compress2()

{

printf("IN COMPRESS 2\n");

int fd,wfd,i=0,ind;

fd=open("ssource",O_RDONLY);

printf("fd=%d\n",fd);

wfd=open("desti",O_WRONLY|O_CREAT);

printf("wfd=%d\n",wfd);

count=1;

while(count)

{

if(count==0)

break;

for(i=0;i<4;i++)

{

count=read(fd,&buff,1);

if(count==0 || buff == '\0')

break;

ind=indu(buff);

ch=ind;

ch=ch<<6;

**ch=ch>>(2*i);**

byt=byt|ch;

ch=0;

}

write(wfd,&byt,1);

byt=byt^byt;

}

close(fd);close(wfd);

return 0;

}

int compress3()
{
        printf("IN COMPRESS 3\n");
        int fd,wfd,i=0,j=-1,ind,a=0;
        fd=open("ssource",O_RDONLY);
        printf("fd=%d\n",fd);
        wfd=open("desti",O_WRONLY|O_CREAT);
        printf("wfd=%d\n",wfd);
        count=1;j=-1;

anubala331

     while(j<2)

        {

                j++;

                //count=read(fd,&buff,1);

                for(i=0;i<3;i++)

                {

                        if(i==2 && j==2)

                        {

                                j=-1;

                                in=in^in;

                                break;

                        }

                        count=read(fd,&buff,1);

                        if(count==0 || buff == '\0')

                                break;

                        ind=indu(buff);

                        ch=ind;

if(i==2)

                        {

                                in=in^in;

                                in=ch;

                                in=in<<(7-j);

                        }

                        ch=ch<<5;

                        a=(3*i+j);

                        ch=ch>>(a);

                        byt=byt|ch;

                }

                write(wfd,&byt,1);

                byt=byt^byt;

                byt=byt|in;

                //in=in^in;

                //ch=0;

                if(count==0 || buff == '\0')

                        a:break;

        }

                close(fd);close(wfd);

        return 0;

}

int compress4()
{
        printf("IN COMPRESS 4\n");
        int fd,wfd,i=0,ind;
        //char ch;
        fd=open("ssource",O_RDONLY);
        printf("fd=%d\n",fd);
        wfd=open("desti",O_WRONLY|O_CREAT);
        printf("wfd=%d\n",wfd);
        count=1;
        while(count)
        {
                for(i=0;i<5;i=i+4)
                {
                        count=read(fd,&buff,1);
                        if(count==0 || buff == '\0')
                                break;
                        //printf("buff=%c\n",buff);

anubala331

                     ind=indu(buff);

                        ch=ind;

                        printf("i=^^^^^=%d\n",i);

                        ch=ch<<4;

                        ch=ch>>(i);

                        byt=byt|ch;

                }

                write(wfd,&byt,1);

                byt=byt^byt;

   }

                close(fd);close(wfd);

        return 0;

}

int compress5()
{
        printf("IN COMPRESS 5\n");
        int j,x=7,y=6,b=5,i=0,p=0;
        int ind,fd,wfd;
        fd=open("ssource",O_RDONLY);
        printf("fd=%d\n",fd);
        wfd=open("desti",O_WRONLY|O_CREAT);
        printf("wfd=%d\n",wfd);
        count=1;
        while(count)
        {
                if(count==0)
                        break;
                x=7,y=6,b=5,p=0,i=0,buff=0;
                for(j=0;j<8;j++)
                {
                        if(j==5)//j=1 5 j=3 7
                                b=1;

anubala331

                        count=read(fd,&buff,1);

                        if(count==0 || buff =='\0')

                                break;

                        //printf("buff=%c\n",buff);

                        ind=indu(buff);

                        ch=ind;

                        //printf("ch=%d\t",ch);

                        if((j%2) == 0)

       {

                                i=j;

                                if(j>2)//j=4 j=6

                                {

                                        p=x;

                                        x=x-2;

                                }

                        }

                        else if((j%2) != 0)

                        {

                                i=b;

                                b=b+2;

                                if(j<4)//1 3

                                {

                                        p=y;

                                        y=y-2;

                                }

                        }

                        if((j>2 && j%2==0) || (j<4 && j%2 != 0 ))

                        {

                                in=ch;

                                in=in<<(p);

                        }

                        ch=ch<<3;

                        ch=ch>>(i);

                        byt=byt|ch;

                        if(j !=0 && j != 2 && j != 5 )

{

                                write(wfd,&byt,1);

                                byt=byt^byt;

                        }

                        byt=byt|in;

                        in=in^in;

                        //ch=0;

                }

        }

                close(fd);close(wfd);

     return 0;

}

anubala331

int compress6()

{

        int fd,wfd,j=8,i=0,ind;

        printf("IN COMPRESS 6\n");

        fd=open("ssource",O_RDONLY);

        printf("fd=%d\n",fd);

     wfd=open("desti",O_WRONLY|O_CREAT);

        printf("wfd=%d\n",wfd);

        count=1;

        while(count)

        {

                if(count==0)

                        break;

                for(j=8;j>0;j=j-2)

                {

                        i=j;

                        if(j==6)

                                i=i-2;

                        else if(j==4)

                                i=i+2;

                        count=read(fd,&buff,1);

                        if(count==0 || buff =='\0')

                                break;

                        ind=indu(buff);

                        ch=ind;

      if((i*j) == 24)
                        {
                                in=ch;
                                in=in<<(i);
                        }
                        ch=ch<<2;
                        if(j != 8)
                                ch=ch>>(j);
                        byt=byt|ch;
                        if(j != 8)
                        {
                                write(wfd,&byt,1);
                                byt=byt^byt;
                                byt=byt|in;
                                in=in^in;
                        }
                }

        }
                close(fd);close(wfd);

        return 0;
}

int compress7()
{
        int fd,wfd,j=8,i=0,a=2,ind;
        printf("IN COMPRESS 7\n");
        fd=open("ssource",O_RDONLY);
        printf("fd=%d\n",fd);
        wfd=open("desti",O_WRONLY|O_CREAT);
        printf("wfd=%d\n",wfd);
        count=1;

   while(count)
        {
                a=2;
                if(count==0)
                        break;

anubala331

             for(j=8;j>0;j--)

                {

                        count=read(fd,&buff,1);

                        if(count==0 || buff =='\0')

                                break;

                        ind=indu(buff);

                        ch=ind;

                        if(j != 8 && j != 1)

                        {

                                in=in<<(a);

                                a++;

                        }

                        ch=ch<<1;

                        if(j!=8)

                                ch=ch>>j;

                        byt=byt|ch;

                        if(j!=8)

                        {

                                write(wfd,&byt,1);

                        byt=byt^byt;

                        byt=byt|in;

                        in=in^in;

   }

                }
        }
                close(fd);close(wfd);
        return 0;
}
int codelen(int ndc)
{
        int i,j=0;
        for(i=1;i<ndc;j++)
                i=i2;
        return j;
}
int check(char buff)
{
        int i=0;
        while(i<size)
        {
                if((masterarray+i)==buff)
                        goto OUT;
                else
                        i++;
        }
        (masterarray+i-1)=buff;
        printf("masterarray=%c\t",(masterarray+i-1));
return 0;
OUT:
        return -1;
}

anubala331

int create_masterarray(char buff)//distinct no. of characters are caculated..

{

if(flag==0)

{

**masterarray=malloc(sizeof(char)*size);//**

flag=1;

}

else

**masterarray=realloc(masterarray,sizeof(char)*size);**

if(buff != '\0')

ret=check(buff);

if(ret==0)

size++;

return size-2;

}

int main()

{

char sor;

**char buf;//sor;**

buf=malloc(1000);

//sor=malloc(500);

//set=0;

//memset(set,'\0',sizeof(set));

char buff;

int cfd,fd,bfd,wfd,pfd,ppfd,j=0,i=0,a=0;

socklen_t len;

len=sizeof(struct sockaddr_in);

pro_add.sin_family=AF_INET;

pro_add.sin_port=htons(4444);//PROCESS WILL ALSO SEARCH CLIENT BY THIS PUBLIC IP ADDRESS./& THIS PORT NO. TO ENTER INTO THE SYSTEM..//

pro_add.sin_addr.s_addr=inet_addr("127.0.0.1");

pfd=socket(AF_INET,SOCK_STREAM,0);

printf("pfd_________=%d\n",pfd);

**ret=connect(pfd,(struct sockaddr*)&pro_add,len);//CONNECT CALL TO CONNECT THE PROCESS TO SERVER..//**

if(ret==0)

printf("connected\n");

else

printf("not connected\n");

count=1;

while(count)

{

//printf("set set set p1\n");

count=read(pfd,(buf+i),1);//HERE FILE TO BE COMPRESSED IS READ..& ATTEMPT TO COMPRESS THE FILE IS DONE..//

**if(*(buf+i)=='\n' || count==0)**

break;

**//printf("count=%d (buff+i)=%c\n",count,*(buf+i));**

i++;

}

wfd=open("ssource",O_WRONLY | O_CREAT);//1ST OF ALL SAVED THAT FILE TO BE COMPRESSED HERE .IN THE SYSTEM OF SERVER,,TEMPORARY UNTILL ,./COMPRESSION IS NOT DONE ||PERMANENTLY IF SYSTEM HAVE MUCH MEMORY TO HANDLE LAKHS OF CLIENTS..//

printf("buf=%s\n",buf);

write(wfd,buf,strlen(buf));//WRITE INTO FILE TO BE SAVED..//

close(pfd);

anubala331

count=1;

wfd=open("ssource",O_RDONLY);//NOW OPEN THIS FILE TO READ CHARACTERS 1 BY 1...TO PERFORM COMPRESSION//

while(count)

{

count=read(wfd,&buff,1);//READ CHARACTER INTO VARIABLE BUFF//

**if(*(buf+i)=='\0' || count==0)**

break;

//a++;

//printf("buff=%c\t a=%d\tcount=%d\n",buff,a,count);

ret=create_masterarray(buff);//SEND THIS CHARACTER TO CREATE_MASTER ARRAY TO FIND THE DISTINCT NO. OF CHARACTERS INTO MASTERARRAY ..BCZ...WE WILL FIND DISTINCT NO. OF CHARACTERS IN THE FILE & THEN WE WILL GIVE UNIQUE ID TO THAT UNIQUE NO. OF THOSE CHARACTERS ...& THAT UNIQUE ID WILL BE CALLED INDEX NO..//SO CONTINUE..FORWARD//

}

printf("ndc__=%d\n",ret);

j=codelen(ret);//TO FIND CODELENGTH OF FILE ..USING NO. OF UNIQUE CHARACTERS...THIS FUNCTION IS CALLED//CODELENGTH MEANS IN HOW MANY BITS THOSE UNIQUE NO. OF CHARACTERS COULD BE REPRESENTED ..//

//FOR E.G.WE HAVE 16 || <16 UNIQUE NO. OF CHARACTERS IN FILE ..IT CAN BE REPESENTED IN 4 BITS 0000...

//IF WE HAVE 32 || >16 |<32 UNIQUE CHARACTERS...THEN CAN BE REPRESENTED IN 5 BITS ..SO ON..MOVE//

printf("codelen=%d\n",j);

switch(j)//ACCORDING TO CODELENGTH TECHNIQUE OR ALGO FOR COMPRESSION WILL BE DECIDED ..//LESS NO. OF UNIQUE CHARACTRERS MORE WILL BE COMPRESSION//

{

anubala331

case 1:

ret=compress1();

if(ret==0)

printf("COMPRESSED1\n");

break;

case 2:

ret=compress2();

if(ret==0)

printf("COMPRESSED2\n");

break;

case 3:

ret=compress3();

if(ret==0)

printf("COMPRESSED3\n");

break;

case 4:

ret=compress4();

if(ret==0)

printf("COMPRESSED4\n");

break;

case 5:

ret=compress5();

if(ret==0)

printf("COMPRESSED5\n");

break;

case 6:

ret=compress6();

if(ret==0)

printf("COMPRESSED6\n");

break;

case 7:

ret=compress7();

if(ret==0)

printf("COMPRESSED7\n");

break;

}

count=1;

anubala331

fd=open("./desti",O_RDONLY);//FILE IS OPENED TO READ & WRITE INTO SOCKET BACK ..//

        printf("fd=%d\n",fd);

        //bfd=open("./checkis",O_WRONLY|O_CREAT);

        //printf("bfd=%d\n",bfd);

        ppfd=socket(AF_INET,SOCK_STREAM,0);//SOCKET IS CREATED & CONNECT ..BCZ IN SERVER ACCEPT WAS LEFT WAITING FOR THIS SOCKET CONNECT CALL..//

        printf("ppfd_________=%d\n",ppfd);

        ret=connect(ppfd,(struct sockaddr*)&pro_add,len);

        if(ret==0)

                printf("+++++++++++++++++++++++++++++++++++++++connected\n");

        else

                printf("not connected\n");

        while(count == 1)

        {

                count=read(fd,&sor,1);//COMPRESSED FILE IS READ FROM FILE

                printf("count=%d\n",count);

                //write(bfd,&sor,1);

                write(ppfd,&sor,1);//SEND THE
COMPRESSED FILE THROUGH SOCKET..//HERE IS SOME PROBLEM....SEEE ANY CODE
THAT IS COMPRESSED HERE ....THAT FILE IS OPENED & WRITTEN INTO THE
SOCKET..& WE KNOW SOCKET CAN HAVE ANY MUCH SIZE OF FILE WRITTEN INTO
IT..//BUT WITH THE SAME CODE IF I READ FILE UPTO 4 BIT CODE ..//IT
WORKS NICE ...IT WRITE BACK INTO FILE ..FOR ANY MUCH SIZE OF FILE ...IT
WILL WRITE BACK UPTO 4 BIT CODE...BUT WHEN TRY TO WRITE 5 || 6 ||7 BIT
CODE FILE BACK...IT WILL NOT WRITE..& AFTER READING SMALL NO. OF
CHARACTERS EITHER 2 ..EITHER 4 EITHER 7..IT ITSELF COME OUT OF
LOOP..& NOT WRITING INTO THE SOCKET ..ALTHOGH CONDITION WAS NOT MADE
FALSE //

//IF I REMOVE THIS COMMAND OF WRITING INTO SOCKET ..IT WILL READ ALL THE DATA PERFECTING ..& WRITE INTO ANY FILE WHOLE THE DATA OF COMPRESSED FILE WITHOUT ANY PROBLED..BUT WHEN I APPLY WRITE CALL TO WRITE INTO ANY OF THE SOCKET ..I WILL NOT ABLE TO WRITE ..INSTEAD OF THAT WITHOUT HAVING COUNT=0..WITHOUT MAKING CONDITION FALSE OF LOOP ..IT LET OUT OF LOOP//
//ALTHOUGH LOOP IS NOT APPLIED ...I DIRECTLY TRIED TO WRITE DATA INTO SOCKET ...THEN IT IS ALSO NOT ABLE TO WRITE DATA INTO SOCKET ...WHEN I DO 5 || 6 || 7 BIT COMPRESSION//
//WRITING FROM DESTI (COMPRESSED)FILE & WRITTING INTO SOCKET CODE IS SAME FOR ALL OF THE COMPRESSION ALGOS///1 2 3 4 5 6 7...THEN WHY? WHY IT IS NOT ABLE TO WRITE INTO SOCKET ..WHILE 5 6 7 BIT COMPRESSION IS DONE
//FORGET THERE IS NO FLOW IN COMPRESSION..BCZ..I HAD ALREADY TRIED DECOMPRESSION OF ALL THE COMPRESSED CODES..SO COMPRESSION CODES ARE PERFECT FOR ALL THE COMPRESSION ALGORITHEMS...
//??????????????????????????????????????????????????????????????????????PLEASE ANS ME . IF ANY ONE CAN?????ITS CHALLAGING QUES??????????????????????????????????????????????????????????????????????????????????????????????????????????????/???
                if(count == 0)
                        break;
        }
return 0;
}

anubala331

**/MODEL OF SMALL COMPRESSED FILE/**

^A#$Q#$gH@i<9a>Q#$gH@<8b>^A#$Q#$gH@i<94>Q#$gH@<8b>À^R2E^R4&t<84>^Hi<94>Q#$dt<84>^H¼Ð

WONDERFUL PROJECT OF MULTIPLE DATA COMPRESSION USING SOCKET-WITH SERVER ,CLIENT,PROCESS

/*A NICE IMPLEMENTATION OF MULTIPLE DATA COMPRESSION USING SOCKET*/

//WE KNOW SOCKETS..//

//SOCKETS ARE USED TO COMMUNICATE BETWEEN THE TWO SYSTEMS ON THE NET.

#include<stdio.h>

#include<stdlib.h>

#include<unistd.h>

#include<string.h>

#include<sys/socket.h>

#include<linux/in.h>

#include<fcntl.h>

struct sockaddr_in client_add,client_add1;//VARIABLES OF STRUCTURE ARE DECLARED TO USE IT FURTHER..//

int main()

{

//char opr='+';

socklen_t len;

char *buff;

buff=malloc(1000);

char *buf;

buf=malloc(1000);

int i=0,wfd,ret=0,count=1,rfd,ffd,fd,num1=5,num2=3;

len=sizeof(struct sockaddr_in);

client_add.sin_family=AF_INET;

client_add.sin_port=htons(4444);//IP ADDRESS IS NECCESARY TO FIND OTHER SYSTEM ON NET..& PORT NO. TO ENTER INTO THTV SYSTEM....& OFFCOURSE FAMILY OF ADDRESS IS ALSO GIVEN INTO ELEMENTS OF STRUCTURE sockaddr_in DEFINED IN SYS/SOCKET.H

client_add.sin_addr.s_addr=inet_addr("127.0.0.1");

fd=socket(AF_INET,SOCK_STREAM,0);//SOCKET CALL IS MADE TO CREATE THE SOCKET

printf("fd=%d\n",fd);

ret=connect(fd,(struct sockaddr*)&client_add,len);//CONNECT CALL IS TO CONNECT THE SOCKET TO SERVER ...THERE WILL BE TWO DIFFRENT SOCKETS CREATED AT TWO SYSTEMS .../BOTH THE SOCKETS WILL COMMUNICATE EACH OTHER THROUGH NET..BUT HOW?

if(ret==0)

printf("connected\n");

else

printf("not connected\n");

ffd=socket(AF_INET,SOCK_STREAM,0);//ONE ANOTHER SOCKET IS CREATED ..TO GET THE RESULT OF ..MEANS TO GET THE COMPRESSED FILE ..//

printf("ffd=%d\n",ffd);

if(ret==0)

printf("connected\n");

else

printf("not connected\n");

count=1;

rfd=open("source4",O_RDONLY);//OPEN THE FILE IN O_RDONLY MODE WHICH IS TO BE COMPRESSED//

while(count)

{

//printf("set set set c1\n");

//sleep(1)

count=read(rfd,(buff+i),1);//READ THE FILE INTO A POINTER BUFFER..TO SEND IT TO SERVER 1 BY 1 CHARACTER ..ACCORDING TO COUNT ...BCZ WE DONT NOW ALREADY...WHAT COULD BE SIZE OF FILE WHICH IS TO BE COMPRESSED

//ALTHOUGH IT IS NOT VERY GOOD ..TO READ THE FILE IN A POINTER ..BCZ FILE COULD IN SOME KB..BUT THIS TIME IT IS OK..//U MAY READ IT AS IT IS..& SEND TO SERVER CHARACTER BY CHARACTER..//

if(count==0)

break;

//printf("buff=%c\tcount=%d\n",*(buff+i),count);

i++;

}

count=write(fd,buff,strlen(buff));//NOW ACCORDING TO LENGTH OF BUFFER ...U MAY WRITE THE FILE TO SERVER TO GET ..THE OUPUT BACK..//

printf("buff=%s count=%d\n",buff,count);

//close(fd);

count=1;i=0;

while(count)

{

printf("give give give compressed\n");

count=read(ffd,(buf+i),1);//THROUGH OTHER SOCKET & INTO ANOTHER BUFFER ..RESULTING COMPRESSED FILE IS REad

if(count==0 || *(buf+i) == '\0')

break;

printf("buf=%c_________________count=%d\n",*(buf+i),count);

i++;

}

wfd=open("cldest",O_WRONLY|O_CREAT);//CREATE & OPEN A FILE INTO CLIENT'S SYSTEM TO ENTER COMPRESSED FILE INTO IT..//

write(wfd,buf,strlen(buf));//WRITE THE COMPRESSED FILE INTO CLIENT'S SYSTEM..//

close(wfd);close(ffd);//CLOSE THE FD'S//

return 0;

}

count=1;i=0;

while(count)

{

printf("give give give compressed\n");

count=read(ffd,(buf+i),1);//THROUGH OTHER SOCKET & INTO ANOTHER BUFFER ..RESULTING COMPRESSED FILE IS REad

if(count==0 || *(buf+i) == '\0')

break;

printf("buf=%c_________________count=%d\n",*(buf+i),count);

i++;

}

wfd=open("cldest",O_WRONLY|O_CREAT);//CREATE & OPEN A FILE INTO CLIENT'S SYSTEM TO ENTER COMPRESSED FILE INTO IT..//

**/A NICE IMPLEMENTATION OF MULTIPLE DATA COMPRESSION USING SOCKET/**

**char *buff;**

**char *buf;**

count=read(rfd,(buff+i),1);//READ
THE FILE INTO A POINTER BUFFER..TO SEND IT TO SERVER 1 BY 1 CHARACTER
..ACCORDING TO COUNT ...BCZ WE DONT NOW ALREADY...WHAT COULD BE SIZE OF
FILE WHICH IS TO BE COMPRESSED

//ALTHOUGH IT IS NOT VERY GOOD ..TO READ
THE FILE IN A POINTER ..BCZ FILE COULD IN SOME KB..BUT THIS TIME IT IS
OK..//U MAY READ IT AS IT IS..& SEND TO SERVER CHARACTER BY
CHARACTER..//

**//printf("buff=%c\tcount=%d\n",*(buff+i),count);**

**if(count==0 || *(buf+i) == '\0')**

**printf("buf=%c_________________count=%d\n",*(buf+i),count);**

**if(count==0 || *(buf+i) == '\0')**

**printf("buf=%c_________________count=%d\n",*(buf+i),count);**

**char *buff;**

**char *bufff;**

**ffd=accept(sock_fd,(struct sockaddr*)&client_addr1,&len);//ALL THE 4 SOCKETS OF 2 OF CLIENT & 2 OF PROCESS ARE CONNECTED AT THE SAME TIME ..//**

**pfd=accept(sock_fd,(struct sockaddr*)&pro_add,&len);**

**if(*(buff+i)=='\n')**

**//printf("buff=%c\tcount=%d\n",*(buff+i),count);**