Return to client3.c CVS log

Up to [ELWIX - Embedded LightWeight unIX -] / ansh / src

Annotation of ansh/src/client3.c, revision 1.1.1.1

1.1       misho       1: /*************************************************************************
                      2:  * (C) 2011 AITNET - Sofia/Bulgaria - <office@aitnet.org>
                      3:  *  by Michael Pounov <misho@elwix.org>
                      4:  *
                      5:  * $Author: misho $
                      6:  * $Id: global.h,v 1.2 2011/06/08 12:45:40 misho Exp $
                      7:  *
                      8:  *************************************************************************/
                      9: #include "global.h"
                     10: 
                     11: 
                     12: static int
                     13: SetRemoteWinz(int h, u_short id, struct sockaddr *sa, u_char *buf, int buflen)
                     14: {
                     15:        u_short *pos = (u_short*) buf;
                     16:        struct winsize ws;
                     17: 
                     18:        FTRACE(5);
                     19: 
                     20:        memset(buf, 0, buflen);
                     21:        if (ioctl(STDOUT_FILENO, TIOCGWINSZ, &ws) == -1) {
                     22:                printf("Error:: ioctl(winsize) #%d - %s\n", errno, strerror(errno));
                     23:                return -1;
                     24:        }
                     25: 
                     26:        pos[0] = htons(ws.ws_row);
                     27:        pos[1] = htons(ws.ws_col);
                     28:        pos[2] = htons(ws.ws_xpixel);
                     29:        pos[3] = htons(ws.ws_ypixel);
                     30:        if (icmpSend(h, id, ANSH_FLG_WINZ, buf, sizeof ws, sa, sizeof(struct sockaddr)) == -1)
                     31:                return -1;
                     32: 
                     33:        return 0;
                     34: }
                     35: 
                     36: int
                     37: ConnectL3(int h, u_short id, struct sockaddr *sa, int len)
                     38: {
                     39:        fd_set rfd;
                     40:        struct timeval tv = { Timeout, 0 };
                     41:        struct termios otio;
                     42:        int rlen, ret = 0;
                     43:        u_short aid;
                     44:        struct sockaddr s;
                     45:        char flg;
                     46:        u_char *buf;
                     47:        socklen_t sl;
                     48: 
                     49:        FTRACE(3);
                     50: 
                     51:        if (!(buf = malloc(len))) {
                     52:                printf("Error:: no enough memory #%d - %s\n", errno, strerror(errno));
                     53:                return -1;
                     54:        }
                     55: 
                     56:        if (SetRemoteWinz(h, id, sa, buf, len) == -1) {
                     57:                free(buf);
                     58:                return -1;
                     59:        }
                     60: 
                     61:        ioSetRAWMode(STDIN_FILENO, &otio);
                     62: 
                     63:        while (!Kill) {
                     64:                FD_ZERO(&rfd);
                     65:                FD_SET(h, &rfd);
                     66:                FD_SET(STDIN_FILENO, &rfd);
                     67:                if (select(h + 1, &rfd, NULL, NULL, (Timeout ? &tv : NULL)) < 1) {
                     68:                        ret = -1;
                     69:                        break;
                     70:                }
                     71:                if (FD_ISSET(STDIN_FILENO, &rfd)) {
                     72:                        memset(buf, 0, len);
                     73:                        rlen = read(STDIN_FILENO, buf, len);
                     74:                        if (rlen == -1) {
                     75:                                printf("Error:: read(stdin) #%d - %s\n", errno, strerror(errno));
                     76:                                ret = -1;
                     77:                                break;
                     78:                        }
                     79:                        rlen = icmpSend(h, id, ANSH_FLG_CPOUT, buf, rlen, sa, sizeof(struct sockaddr));
                     80:                        if (rlen == ANSH_FLG_ERR) {
                     81:                                ret = -1;
                     82:                                break;
                     83:                        }
                     84:                } else {
                     85:                        sl = sizeof s;
                     86:                        rlen = len;
                     87:                        memset(buf, 0, rlen);
                     88:                        flg = icmpRecv(h, &aid, buf, &rlen, &s, &sl);
                     89:                        if (flg == ANSH_FLG_ERR) {
                     90:                                ret = -1;
                     91:                                break;
                     92:                        }
                     93:                        if (aid != id) {
                     94:                                VERB(4) LOG("different service id %d / %d\n", aid, id);
                     95:                                continue;
                     96:                        }
                     97:                        if (flg == ANSH_FLG_EOF) {
                     98:                                VERB(3) LOG("receive EOF going down.\n");
                     99:                                Kill++;
                    100:                        }
                    101:                        if (flg != ANSH_FLG_OK)
                    102:                                continue;
                    103:                        rlen = write(STDOUT_FILENO, buf, rlen);
                    104:                        if (rlen == -1) {
                    105:                                printf("Error:: write(stdout) #%d - %s\n", errno, strerror(errno));
                    106:                                ret = -1;
                    107:                                break;
                    108:                        }
                    109:                }
                    110:        }
                    111: 
                    112:        ioRestoreMode(STDIN_FILENO, otio);
                    113:        free(buf);
                    114:        return ret;
                    115: }