I3Triggers Class Reference

{
    TriggersHandshakeMsg *hmsg = dynamic_cast<TriggersHandshakeMsg*>(msg);
    TriggersMsg *tmsg = NULL;

    if (!hmsg) tmsg = dynamic_cast<TriggersMsg*>(msg);

    if (myIndex == 0) {
        // act as server

        if (hmsg) {
            getParentModule()->bubble("Got handshake!");

            // this is a handshake message
            TriggersHandshakeMsg *newMsg = new TriggersHandshakeMsg();

            // create a new private trigger
            I3Identifier privateId;
            privateId.createRandomKey();

            // insert it into i3
            insertTrigger(privateId);

            // store the client's value
            Client client;
            client.clientId = hmsg->getTriggerId();
            client.privateId = privateId;
            client.sentValue = hmsg->getValue();
            clients[privateId] = client;

            // notify the client back
            newMsg->setValue(0);
            newMsg->setTriggerId(privateId);
            sendPacket(hmsg->getTriggerId(), newMsg);



        } else if (tmsg) {

            getParentModule()->bubble("Got normal message!");

            // this is a normal message. just reply with sent value
            TriggersMsg *newMsg = new TriggersMsg();

            Client &client = clients[matchingTrigger.getIdentifier()];
            newMsg->setValue(client.sentValue);
            sendPacket(client.clientId, newMsg);
        }

    } else {
        //act as client

        if (hmsg) {

            getParentModule()->bubble("Finished handshaking!");

            // store the private trigger
            privateIdentifier = hmsg->getTriggerId();
            WATCH(privateIdentifier);

        } else {

            // check if the value is valid
            if (tmsg->getValue() == myIndex) {
                getParentModule()->bubble("Got packet - Got my id!");
            } else {
                getParentModule()->bubble("Got packet - Got an unknown id");
            }

        }
    }
}

{
    if (myIndex != 0) {
        if (msg == handShakeTimer) {

            // start handshake
            TriggersHandshakeMsg *msg = new TriggersHandshakeMsg();

            msg->setValue(myIndex);
            msg->setTriggerId(myIdentifier);
            sendPacket(publicIdentifier, msg);
            getParentModule()->bubble("Started handshake");

        } else if (msg == sendPacketTimer) {

            //send a packet
            TriggersMsg *msg = new TriggersMsg();
            msg->setValue(0);
            sendPacket(privateIdentifier, msg);

            // reset timer
            sendPacketTimer = new cMessage("packet timer");
            scheduleAt(simTime() + 5, sendPacketTimer);

            getParentModule()->bubble("Sending packet");
        }
    }
    delete msg;
}

{
    myIndex = index++;

    WATCH(myIndex);
    WATCH(myIdentifier);
}

                              {
    publicIdentifier.createFromHash("Triggers 0");

    ostringstream os;
    os << "Triggers " << myIndex;

    myIdentifier.createFromHash(os.str());
    insertTrigger(myIdentifier);

    // handshake timer must be set before the packet timer!
    handShakeTimer = new cMessage("handshake timer");
    scheduleAt(simTime() + 5, handShakeTimer);

    sendPacketTimer = new cMessage("packet timer");
    scheduleAt(simTime() + 10, sendPacketTimer);
}