Projects on Online Transaction Programming

[vittal]

Hi,
I have to do a project on C program. I have to do 9 mini-projects. Please guide me through it.
1) Client-Server program using Semaphores, Message queues, Shared memory, Pipes, FIFO, Decentralized and Centralized OLTP, Channel of Communication and lastly
2) Using Network applications i.e Sockets on Decentralized and Centralized OLTP.
Please send me the source code as early as possible. Please give me a reply within 2 to 3 days.

[MMcCarthy]

The experts on this site are more than happy to help you with your problems but they cannot do your assignment for you. Attempt the assignment yourself first and post questions regarding any difficulties you have or about a particular function of the code that you don't know how to achieve.

ADMIN

[RedSon]

Hi,
I have to do a project on C program. I have to do 9 mini-projects. Please guide me through it.
1) Client-Server program using Semaphores, Message queues, Shared memory, Pipes, FIFO, Decentralized and Centralized OLTP, Channel of Communication and lastly
2) Using Network applications i.e Sockets on Decentralized and Centralized OLTP.
Please send me the source code as early as possible. Please give me a reply within 2 to 3 days.

Here you and I can finish your project in 4 easy steps. Here are the steps for you to follow:

1.) Write a server program.
2.) Write a client.
3.) Connect your client to your server.
4.) Test your server and client.

Done!

Easy right!?!

[ankit12399]

Hi,
I have to do a project on C program. I have to do 9 mini-projects. Please guide me through it.
1) Client-Server program using Semaphores, Message queues, Shared memory, Pipes, FIFO, Decentralized and Centralized OLTP, Channel of Communication and lastly
2) Using Network applications i.e Sockets on Decentralized and Centralized OLTP.
Please send me the source code as early as possible. Please give me a reply within 2 to 3 days.These projects should be written using Saving bank application.

hi i dont have any knowledge of this please tell me in detail what u want to do..

[RedSon]

First I want you to buy a computer. Then you have to install an operating system on it. I prefer Windows, but sometimes I dual boot my machine with a Linux partition. Linux has many distributions, you might want to consider one like Fedora. Its easy to use and comes with a bunch of packages. However I think that Windows is easier to use with Visual Stuido on it. So, assuming you have Windows and Visual Studio installed you can then create a new project. When you go through the create new project wizard select a c/c++ project. After you have done these steps you are then ready to start programming.

Let me know when you have completed these steps and then we can continue.

[vittal]

Atleast please send me a program on Client Server Saving bank application program using Pipes and FIFO.

[MMcCarthy]

Atleast please send me a program on Client Server Saving bank application program using Pipes and FIFO.

vittal

I say again. The experts will NOT write your program for you. If you make some attempt to write it yourself they will try to help.

ADMIN

[hirak1984]

Dear, dont take this site as your regular private tutor.
We dont do your homework or assignments.
But it is true,if you do one step,we will be happy to do the next 20 steps for you.
But you have to set the ball rolling first.
There are hundreds of books on networking,first know what a client server is.
decide what technology to use,vc++ or turbo c++(?),or linux etc...
post again when you have done all these.

Atleast please send me a program on Client Server Saving bank application program using Pipes and FIFO.

[RedSon]

I'm finished with this thread, unless and until there is major progress. Well, I take that back, Vittal, if you are interested in hiring my services then I will talk more, but I am a very expensive consultant.

[RedSon]

[font=Verdana][size=2]Dear, dont take this site as your regular private tutor.[/size][/font]
[font=Verdana][size=2]We dont do your homework or assignments.[/size][/font]
[font=Verdana][size=2]But it is true,if you do one step,we will be happy to do the next 20 steps for you.[/size][/font]
[font=Verdana][size=2]But you have to set the ball rolling first.[/size][/font]
[font=Verdana][size=2]There are hundreds of books on networking,first know what a client server is.[/size][/font]
[font=Verdana][size=2]decide what technology to use,vc++ or turbo c++(?),or linux etc...[/size][/font]
post again when you have done all these.

Hirak,

Whats up with all your font stuff? Did the "reply to" script put all that junk in your response?

[hirak1984]

Ya the problem is gone automatically.

when I directly post in the thread the "fonts" appear.But when I preview it beforehand,no fonts appear in the text,nor does they appear in the original text.Pretty enigmatic na?LOL

Hirak,

Whats up with all your font stuff? Did the "reply to" script put all that junk in your response?

[MMcCarthy]

Ya the problem is gone automatically.

when I directly post in the thread the "fonts" appear.But when I preview it beforehand,no fonts appear in the text,nor does they appear in the original text.Pretty enigmatic na?LOL

I removed them Hirak

We are having some problems with the parser. Bear with us as we try to fix it. If you need this kind of thing tidied up ask a moderator to remove them or send me a PM and I'll get to it when I can.

Mary

[hirak1984]

thanks mary,you are always so helpful.

I removed them Hirak

We are having some problems with the parser. Bear with us as we try to fix it. If you need this kind of thing tidied up ask a moderator to remove them or send me a PM and I'll get to it when I can.

Mary

[vittal]

This is a the source code of Centralized solution, Please tell me what changes I have to make for Decentralized solution.

#define LOG_MSG_LEN 100
void send_chan(int,OLTP_MSG_BUFF);
void send_reply(int,int,int,OLTP_MSG_BUFF );
int is_acc(int,int);
void start_logging(void);
int chan_gen(int);
void dump_log(int);
int nof_clints=0,dead_clint,log_d,clint_list[MAX_NO_CLINTS]={0};
char log_msg[LOG_MSG_LEN];
main(int argc,char *argv[]) {
    int i,j,semd,msgd,mdf_d,ret,off,server_pid;
    char def_choise[6],time_ch[30];
    time_t local_time;
    OLTP_MSG_BUFF msg_clint,msg_reply;
    SB_ACC sb_acc;
    struct msqid_ds msg_stat;
    if(argc == 1) {
        printf("USAGE: %s install | start | stop\n",argv[0]);
        exit(0);
    }
    if(strcmp(argv[1],"install")==0) {
        system("clear");
        printf("\n##### WELCOME TO OLTP SERVER INSTALLATION.........press[X] to EXIT:");
        i=getchar();
        if(i == 'X' || i == 'x') {
            printf("\n\t\t\tABORTED BY USER ! !\n");
            exit(0);
        }
        printf("\n\t\t\tCREATING Master Database File in ./MDF.dbase...");
        mdf_d=open("./MDF.dbase",O_WRONLY | O_CREAT | O_EXCL,0666);
        if(mdf_d < 0) {
            printf("\nMAY BE SERVER IS ALLREADY INSTALLED....remove MDF.dat then TRY AGAIN ! !\n");
            exit(0);
        }
        printf("\n\t\t\tCREATING ADMINSTRATOR ACCOUNT........");
        printf("\n\t\t\tadminstrator phone number:");
        scanf("%d",&sb_acc.acc_ph);
        off=sizeof(struct SB_ACC);
        sb_acc.acc_no=1;sb_acc.balence=1000;
        write(mdf_d,(char*)(&sb_acc),off);
        close(mdf_d);
        printf("\n\t\t\tSERVER INSTALLED SUSCCESSFULLY.......");
        printf("\n\t\t\tNow You can start the server....[OK]\n");
        getchar();
        exit(0);
    }
    if(strcmp(argv[1],"stop")==0) {
        if((semd=semget(OLTP_SEMID,1,IPC_CREAT)) < 0) {
            printf("\n\t\t\tsemget() error......Server stop failed ! !\n");
            exit(2);
        }
        semctl(semd,0,IPC_RMID,0);
        if((msgd=msgget(OLTP_MSGID,IPC_CREAT)) < 0) {
            printf("\n\t\t\tmsgget() error......Server stop failed ! !\n");
            exit(2);
        }
        msgctl(msgd,IPC_RMID,&msg_stat);
        exit(0);
    }
    if(strcmp(argv[1],"start")==0) {
        mdf_d=open("./MDF.dbase",O_RDWR);
        if(mdf_d < 0) {
            printf("\n\t\t\tFailed open Master Database File........Server start failed ! !\n");
            exit(2);
        }
        msgd=msgget(OLTP_MSGID,IPC_CREAT | IPC_EXCL);
        semd=semget(OLTP_SEMID,1,IPC_CREAT | IPC_EXCL | 0666);
        if(semd == 0 || msgd == 0) {
            printf("\n\t\t\tsemget() OR msgget() error.........Server start failed ! !\n");
        }
        if((j=semctl(semd,0,SETVAL,1)) < 0) {
            printf("\n\t\t\tsemctl() error......Server start failed ! !\n");
            exit(5);
        }
        j=semctl(semd,0,GETVAL,0);
 
    }
    else {
        printf("USAGE: %s install/start/stop\n",argv[0]);
        exit(1);
    }
 
    log_d=open("./OLTP_server.log",O_TRUNC | O_WRONLY | O_CREAT | O_SYNC);
    system("clear");
    sleep(1);
    server_pid=fork();
    if(server_pid < 0) {
        printf("\n\t\t\tfork() error.........Server start failed ! !\n");
        exit(7);
    }
    if(server_pid > 0) {
 
        printf("\n\t\t\tServer started successfully with PID [%d]......\n",server_pid);
        time(&local_time);
        ctime_r(&local_time,time_ch);
        printf("\n\t\t\tON:%s",time_ch);
        printf("\n\t\t\t............server logs in ./OLTP_server.log\n");
        printf("\n\t\t\t............USE $tail -f ./OLTP_server.log to see the logs [OK]\n");
        exit(0);
    }
    close(1);
    if(dup(log_d) < 0) {
        char err[44]="dup() error.........Server start failed ! !\n";
        write(2,(char*)(err),44);
        exit(9);
    }
    close(2);close(0);
    setpgrp();
    start_logging();
    while(1) {
        ret=msgrcv(msgd,(struct  msgbuf*)(&msg_clint),MSG_LEN,MASTER_CHAN ,IPC_NOWAIT);
        if(ret > 0)  {
            dump_log(sprintf(log_msg,"----->Got chan_req from %d\n",msg_clint.pid));
            send_chan(msgd,msg_clint);
        }
        for(i=0;i<=nof_clints;i++) {
            ret=msgrcv(msgd,(struct  msgbuf*)(&msg_clint),MSG_LEN,i+2,IPC_NOWAIT);
            if(ret >= 0) send_reply(semd,msgd,mdf_d,msg_clint);
        } } }
void send_chan(int msgd,OLTP_MSG_BUFF msg_clint)
{
    int chan_no;
    OLTP_MSG_BUFF msg_reply;
    chan_no=chan_gen(msg_clint.pid);
    if(chan_no > 0) nof_clints=nof_clints+1;
    msg_reply.req_rep_info=chan_no;
    msg_reply.mtype=msg_clint.pid;
    dump_log(sprintf(log_msg,"----->Sending chan %d to %d\n",msg_reply.req_rep_info,msg_clint.pid));
    msgsnd(msgd,(struct  msgbuf*)(&msg_reply),MSG_LEN,0);
    return;
}
void send_reply(int semd,int msgd,int mdf_d,OLTP_MSG_BUFF msg_clint)
{
    int i,off,new_acc_no,stat_mdf,how_many_acc;
    time_t local_time;
    char time_ch[30];
    OLTP_MSG_BUFF msg_reply;
    SB_ACC sb_acc;
    struct msqid_ds msg_stat;
    off=sizeof(struct SB_ACC);
    switch(msg_clint.req_type) {
        case 1:
            stat_mdf=lseek(mdf_d,0,SEEK_END);
            how_many_acc=stat_mdf/off;
            new_acc_no=how_many_acc+1;
            sb_acc.acc_ph=msg_clint.req_rep_info;
            sb_acc.acc_no=new_acc_no;
            sb_acc.balence=1000;
            dump_log(sprintf(log_msg,"TRANSACTION ON [%d]-->New acc[%d] is OPENED ! ! Whose Acc_ph[%d]\n",msg_clint.pid,sb_acc.acc_no,sb_acc.acc_ph));
            write(mdf_d,(char *)(&sb_acc),sizeof(struct SB_ACC));
            msg_reply.req_rep_info=sb_acc.acc_no;
            break;
        case 2:
            lseek(mdf_d,0,0);
            if(is_acc(mdf_d,msg_clint.acc_no) != 0)
            {
                msg_reply.req_rep_info=-2;
                break;
            }
            off=(msg_clint.acc_no-1)*off;
            lseek(mdf_d,off,0);
            read(mdf_d,(char*)(&sb_acc),sizeof(struct SB_ACC));
            sb_acc.acc_ph=msg_clint.req_rep_info;
            lseek(mdf_d,off,0);
            write(mdf_d,(char*)(&sb_acc),sizeof(struct SB_ACC));
            msg_reply.req_rep_info=sb_acc.acc_ph;
            dump_log(sprintf(log_msg,"TRANSACTION ON [%d]-->Acc no[%d] NOW have[%d] phone_no\n",msg_clint.pid,sb_acc.acc_no,sb_acc.acc_ph));
            break;
        case 3:
            lseek(mdf_d,0,0);
            if(is_acc(mdf_d,msg_clint.acc_no) != 0)
            {
                msg_reply.req_rep_info=-3;
                break;
            }
            off=(msg_clint.acc_no-1)*off;
            lseek(mdf_d,off,0);
            read(mdf_d,(char*)(&sb_acc),sizeof(struct SB_ACC));
            lseek(mdf_d,0,0);
            msg_reply.acc_no=sb_acc.acc_ph;
            msg_reply.req_rep_info=sb_acc.balence;
            dump_log(sprintf(log_msg,"ACCOUNT [%d] INFORMATION IS SENT TO [%d]\n",sb_acc.acc_no,msg_clint.pid));
            break;
        case 4:
            lseek(mdf_d,0,0);
            if(is_acc(mdf_d,msg_clint.acc_no) != 0)
            {
                msg_reply.req_rep_info=-4;
                break;
            }
            off=(msg_clint.acc_no-1)*off;
            lseek(mdf_d,off,0);
            read(mdf_d,(char*)(&sb_acc),sizeof(struct SB_ACC));
            sb_acc.balence=sb_acc.balence+msg_clint.req_rep_info;
            lseek(mdf_d,off,0);
            write(mdf_d,(char*)(&sb_acc),sizeof(struct SB_ACC));
            msg_reply.req_rep_info=sb_acc.balence;
            dump_log(sprintf(log_msg,"TRANSACTION ON [%d]-->After debiting acc no %d now have %d balence no\n",msg_clint.pid,sb_acc.acc_no,sb_acc.balence));
            break;
        case 5:
            lseek(mdf_d,0,0);
            if(is_acc(mdf_d,msg_clint.acc_no) != 0)
            {
                msg_reply.req_rep_info=-5;
                break;
            }
            off=(msg_clint.acc_no-1)*off;
            lseek(mdf_d,off,0);
            read(mdf_d,(char*)(&sb_acc),sizeof(struct SB_ACC));
            if((sb_acc.balence-msg_clint.req_rep_info) < 1000)
            {
                msg_reply.req_rep_info=-55;
                break;
            }
            sb_acc.balence=sb_acc.balence-msg_clint.req_rep_info;
            lseek(mdf_d,off,0);
            write(mdf_d,(char*)(&sb_acc),sizeof(struct SB_ACC));
            msg_reply.req_rep_info=sb_acc.balence;
            dump_log(sprintf(log_msg,"TRANSACTION ON [%d]-->After withdra acc no %d now have %d balence no\n",msg_clint.pid,sb_acc.acc_no,sb_acc.balence));
            break;
        case 6:
            clint_list[msg_clint.req_rep_info-2]=0;
            nof_clints=nof_clints-1;
            msg_reply.req_rep_info=BYE;
            dump_log(sprintf(log_msg,"----->Clint %d with PID[%d] LOGGED OUT ! !\n",msg_clint.req_rep_info,msg_clint.pid));
            break;
        case 7:
            if(msg_clint.req_rep_info != OLTP_ADMIN_KEY)
            {
                dump_log(sprintf(log_msg,"----->%d AUTHENTIFICATION FAILED ! !\n",msg_clint.pid));
                msg_reply.req_rep_info=-7;
                break;
            }
            dump_log(sprintf(log_msg,"----->%d AS ADMINSTRATOR IS GOING TO SHUTTINGDOWN THE SERVER ! !\n",msg_clint.pid));
            msg_reply.mtype=msg_clint.pid;
            msg_reply.req_rep_info=AUTH_ADMIN;
            msgsnd(msgd,(struct  msgbuf*)(&msg_reply),MSG_LEN,0);
            dump_log(sprintf(log_msg,"----->OLTP SERVER DOWN\n"));
            time(&local_time);
            ctime_r(&local_time,time_ch);
            dump_log(sprintf(log_msg,"----->ON %s",time_ch));
            dump_log(sprintf(log_msg,"############### ANY QUESTIONS TO <[e-mail]> ###############\n"));
            close(log_d);close(mdf_d);
            sleep(5);
            semctl(semd,0,IPC_RMID,0);
            msgctl(msgd,IPC_RMID,&msg_stat);
            exit(0);
        default:
            printf("wrong CHOISE ! ! !\n");
            return;
    }
    msg_reply.mtype=msg_clint.pid;
    if((msgsnd(msgd,(struct  msgbuf*)(&msg_reply),MSG_LEN,0)) < 0)
    {
        printf("msgsnd() error.........Failed to send REPLY ! !\n");
        exit(6);
    };    
}
int is_acc(int mdf_d,int acc_no)
{
    int off,stat_mdf,how_many_acc;
    SB_ACC acc;
    off=sizeof(struct SB_ACC);
    stat_mdf=lseek(mdf_d,0,SEEK_END);
    how_many_acc=stat_mdf/off;
    if(acc_no > how_many_acc) return(-1);
    return(0);
}
void start_logging(void)
{
    time_t local_time;
    char time_ch[30];
    dump_log(sprintf(log_msg,"################ LOG FILE GENERATED BY OLTP SERVER #####################\n"));
    time(&local_time);
    ctime_r(&local_time,time_ch);
    dump_log(sprintf(log_msg,"----->ON %s",time_ch));
    dump_log(sprintf(log_msg,"----->Server started successfully.......with PID [%d]\n",getpid()));
    return;
}
int chan_gen(int pid)
{
    int i;
    for(i=0;i<MAX_NO_CLINTS;i++)
    {
        if(clint_list[i] == 0)
        {
            clint_list[i]=pid;
            return(i+2);/*because chan 1 is for MASTER*/
        }
    }
    return(-1);
}
void dump_log(int size)
{
    if(size < 0) return;
    write(log_d,log_msg,size);
    return;
}