Return to candidate.c CVS log

Up to [CSRG BSD Unix] / 43BSD / etc / timed

Annotation of 43BSD/etc/timed/candidate.c, revision 1.1

1.1     ! root        1: /*
        !             2:  * Copyright (c) 1983 Regents of the University of California.
        !             3:  * All rights reserved.  The Berkeley software License Agreement
        !             4:  * specifies the terms and conditions for redistribution.
        !             5:  */
        !             6: 
        !             7: #ifndef lint
        !             8: static char sccsid[] = "@(#)candidate.c        2.3 (Berkeley) 4/21/86";
        !             9: #endif not lint
        !            10: 
        !            11: #include "globals.h"
        !            12: #include <protocols/timed.h>
        !            13: 
        !            14: #define ELECTIONWAIT   3       /* seconds */
        !            15: 
        !            16: /*
        !            17:  * `election' candidates a host as master: it is called by a slave 
        !            18:  * which runs with the -M option set when its election timeout expires. 
        !            19:  * Note the conservative approach: if a new timed comes up, or another
        !            20:  * candidate sends an election request, the candidature is withdrawn.
        !            21:  */
        !            22: 
        !            23: election(net)
        !            24: struct netinfo *net;
        !            25: {
        !            26:        int ret;
        !            27:        struct tsp *resp, msg, *readmsg();
        !            28:        struct timeval wait;
        !            29:        struct tsp *answer, *acksend();
        !            30:        long casual();
        !            31:        struct sockaddr_in server;
        !            32: 
        !            33:        syslog(LOG_INFO, "THIS MACHINE IS A CANDIDATE");
        !            34:        if (trace) {
        !            35:                fprintf(fd, "THIS MACHINE IS A CANDIDATE\n");
        !            36:        }
        !            37: 
        !            38:        ret = MASTER;
        !            39:        slvcount = 1;
        !            40: 
        !            41:        msg.tsp_type = TSP_ELECTION;
        !            42:        msg.tsp_vers = TSPVERSION;
        !            43:        (void)strcpy(msg.tsp_name, hostname);
        !            44:        bytenetorder(&msg);
        !            45:        if (sendto(sock, (char *)&msg, sizeof(struct tsp), 0, &net->dest_addr,
        !            46:            sizeof(struct sockaddr_in)) < 0) {
        !            47:                syslog(LOG_ERR, "sendto: %m");
        !            48:                exit(1);
        !            49:        }
        !            50: 
        !            51:        do {
        !            52:                wait.tv_sec = ELECTIONWAIT;
        !            53:                wait.tv_usec = 0;
        !            54:                resp = readmsg(TSP_ANY, (char *)ANYADDR, &wait, net);
        !            55:                if (resp != NULL) {
        !            56:                        switch (resp->tsp_type) {
        !            57: 
        !            58:                        case TSP_ACCEPT:
        !            59:                                (void) addmach(resp->tsp_name, &from);
        !            60:                                break;
        !            61: 
        !            62:                        case TSP_MASTERUP:
        !            63:                        case TSP_MASTERREQ:
        !            64:                                /*
        !            65:                                 * If a timedaemon is coming up at the same time,
        !            66:                                 * give up the candidature: it will be the master.
        !            67:                                 */
        !            68:                                ret = SLAVE;
        !            69:                                break;
        !            70: 
        !            71:                        case TSP_QUIT:
        !            72:                        case TSP_REFUSE:
        !            73:                                /*
        !            74:                                 * Collision: change value of election timer 
        !            75:                                 * using exponential backoff.
        !            76:                                 * The value of timer will be recomputed (in slave.c)
        !            77:                                 * using the original interval when election will 
        !            78:                                 * be successfully completed.
        !            79:                                 */
        !            80:                                backoff *= 2;
        !            81:                                delay2 = casual((long)MINTOUT, 
        !            82:                                                        (long)(MAXTOUT * backoff));
        !            83:                                ret = SLAVE;
        !            84:                                break;
        !            85: 
        !            86:                        case TSP_ELECTION:
        !            87:                                /* no master for another round */
        !            88:                                msg.tsp_type = TSP_REFUSE;
        !            89:                                (void)strcpy(msg.tsp_name, hostname);
        !            90:                                server = from;
        !            91:                                answer = acksend(&msg, &server, resp->tsp_name,
        !            92:                                    TSP_ACK, (struct netinfo *)NULL);
        !            93:                                if (answer == NULL) {
        !            94:                                        syslog(LOG_ERR, "error in election");
        !            95:                                } else {
        !            96:                                        (void) addmach(resp->tsp_name, &from);
        !            97:                                }
        !            98:                                break;
        !            99: 
        !           100:                        case TSP_SLAVEUP:
        !           101:                                (void) addmach(resp->tsp_name, &from);
        !           102:                                break;
        !           103: 
        !           104:                        case TSP_SETDATE:
        !           105:                        case TSP_SETDATEREQ:
        !           106:                                break;
        !           107: 
        !           108:                        default:
        !           109:                                if (trace) {
        !           110:                                        fprintf(fd, "candidate: ");
        !           111:                                        print(resp, &from);
        !           112:                                }
        !           113:                                break;
        !           114:                        }
        !           115:                } else {
        !           116:                        break;
        !           117:                }
        !           118:        } while (ret == MASTER);
        !           119:        return(ret);
        !           120: }

This archive runs on limited infrastructure. Preserving old code on modern bandwidth. Automated agents are requested to crawl responsibly.