Subversion Repositories programming

/*******************************************************************************

 * elevator.cpp

 *

 * Implementation for the Elevator class.

 *

 * Copyright 2006, Ira W. Snyder (devel@irasnyder.com)

 ******************************************************************************/

#include "elevator.h"

Elevator::Elevator (int num_floors) : num_floors(num_floors)

{

    int i;

    this->terminate = false;

    this->pause = false;

    this->direction = IDLE;

    this->current_floor = 0.0;

    this->controller = NULL;

    this->stop_at_floors.reserve (num_floors);

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

        this->stop_at_floors.push_back(bool(false));

}

Elevator::~Elevator ()

{

    this->pause = false;

    this->terminate = true;

}

int Elevator::get_direction ()

{

    return this->direction;

}

/**

 * Return the number of floors above the current one that

 * are queued to be stopped at.

 */

int Elevator::floors_above_current ()

{

    int i = ((int)current_floor) + 1;

    int count = 0;

    for (/* see above */; i<num_floors; i++)

        if (stop_at_floors.at(i))

            count++;

    return count;

}

/**

 * Return the number of floors below the current one that

 * are queued to be stopped at.

 */

int Elevator::floors_below_current ()

{

    int i;

    int count = 0;

    if (near_a_floor ())

        i = (int)current_floor - 1;

    else

        i = (int)current_floor;

    for (/* see above */; i>=0; i--)

        if (stop_at_floors.at(i))

            count++;

    return count;

}

void Elevator::push_button (int floor)

{

    assert (floor < num_floors);

    assert (floor >= 0);

    this->stop_at_floors.at(floor) = true;

}

/**

 * This function is the entry point for a thread.

 *

 * You must pass the object in, since this is a static function

 * and we aren't allowed to access the this pointer.

 */

void Elevator::thread_entry (const Elevator *me)

{

    assert (me != NULL);

    Elevator *pthis = (Elevator*)me;

    while (!pthis->terminate)

    {

        /* Implement "pausing" */

        while (pthis->pause)

        {

            usleep (ELEVATOR_TIME_PAUSE_USEC);

        }

        pthis->run_elevator_logic ();

        usleep (ELEVATOR_TIME_DELAY_USEC);

    }

}

void Elevator::thread_start ()

{

    boost::thread the_thread (boost::bind (this->thread_entry, this));

}

void Elevator::run_elevator_logic ()

{

    int i;

    /* Decide what to do */

    switch (direction)

    {

        case IDLE:

            /* Move towards the direction that has more floors to stop at.

             * Prefer DOWN if there is a tie. */

            if (has_floors_to_stop_at ())

            {

                if (floors_above_current () > floors_below_current ())

                    direction = MOVE_UP;

                else

                    direction = MOVE_DOWN;

#ifndef QUIET

                if (direction == MOVE_UP)

                    std::cout << "changed direction to up" << std::endl;

                else

                    std::cout << "changed direction to down" << std::endl;

#endif

            }

            break;

        case MOVE_UP:

            /* Decide if we should stop at the floor we're at */

            if (should_stop_at_current_floor ())

                stop_at_floor (MOVE_UP);

            /* Decide to sit idle if we have no more floors to stop at */

            if (!has_floors_to_stop_at ())

            {

#ifndef QUIET

                puts ("decides to sit idle");

#endif

                direction = IDLE;

            }

            /* Decide to switch directions if we have no more floors to stop

             * at in the current direction, but we have floors in the

             * opposite direction to stop at. */

            else if (floors_below_current () && !floors_above_current ())

            {

#ifndef QUIET

                puts ("decides to switch direction to down");

#endif

                direction = MOVE_DOWN;

            }

            /* Since nothing else applies, we should keep moving in the

             * current direction, up. */

            else

            {

                current_floor += ELEVATOR_TIME_MOVE_AMOUNT;

                // Check to make sure we don't go too high

                assert (current_floor < (num_floors * 1.0));

            }

            break;

        case MOVE_DOWN:

            /* Decide if we should stop at the floor we're at */

            if (should_stop_at_current_floor ())

                stop_at_floor (MOVE_DOWN);

            /* Decide to sit idle if we have no more floors to stop at */

            if (!has_floors_to_stop_at ())

            {

#ifndef QUIET

                puts ("decides to sit idle");

#endif

                direction = IDLE;

            }

            /* Decide to switch directions if we have no more floors to stop

             * at in the current direction, but we have floors in the

             * opposite direction to stop at. */

            else if (floors_above_current () && !floors_below_current ())

            {

#ifndef QUIET

                puts ("decides to switch direction to up");

#endif

                direction = MOVE_UP;

            }

            /* Since nothing else applies, we should keep moving in the

             * current direction, down. */

            else

            {

                current_floor -= ELEVATOR_TIME_MOVE_AMOUNT;

                // Check to make sure we don't go too low

                assert (current_floor > -0.1);

            }

            break;

        default:

            assert (false); // bad value of direction

            break;

    }

    Dispatch_Data data;

    data.type = DISPATCH_DATA_UPDATE_LABEL;

    data.elev = this;

    data.farg = current_floor;

    data.direc = direction;

    controller->push_to_gui_queue (data);

    (*dispatcher)();

}

/**

 * Call this to stop the thread from running.

 */

void Elevator::thread_stop ()

{

    this->terminate = true;

}

/**

 * Call this to pause the thread without exiting it.

 */

void Elevator::thread_pause ()

{

    this->pause = true;

}

/**

 * Call this to unpause the thread.

 */

void Elevator::thread_unpause ()

{

    this->pause = false;

}

bool Elevator::near_a_floor ()

{

    int i;

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

        if (near_floor (i))

            return true;

    return false;

}

bool Elevator::near_floor (int floor)

{

    assert (floor >= 0);

    assert (floor < num_floors);

    const float thresh  = ELEVATOR_TIME_MOVE_AMOUNT / 2.0;

    const float greater = floor + thresh;

    const float lower   = floor - thresh;

    if (current_floor > lower && current_floor < greater)

        return true;

    return false;

}

bool Elevator::has_floors_to_stop_at ()

{

    int i;

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

        if (stop_at_floors.at(i))

            return true;

    return false;

}

bool Elevator::should_stop_at_current_floor ()

{

    int i;

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

        if (near_floor (i) && stop_at_floors.at(i) == true)

            return true;

    return false;

}

bool Elevator::button_is_pushed (int floor)

{

    assert (floor < num_floors);

    assert (floor >= 0);

    return stop_at_floors.at(floor);

}

float Elevator::get_current_floor ()

{

    return current_floor;

}

void Elevator::set_controller (Controller *c)

{

    this->controller = c;

}

void Elevator::stop_at_floor (int in_direction)

{

    int the_floor = (int)(current_floor+0.5);

#ifndef QUIET

    if (in_direction == MOVE_UP)

        printf ("stop at floor %d -- while going up\n", the_floor);

    else

        printf ("stop at floor %d -- while going down\n", the_floor);

#endif

    stop_at_floors.at(the_floor) = false;

    Dispatch_Data data;

    data.type = DISPATCH_DATA_STOP_AT_FLOOR;

    data.elev = this;

    data.iarg = the_floor;

    data.direc = in_direction;

    controller->push_to_gui_queue (data);

    (*dispatcher)();

}

void Elevator::set_dispatcher (Glib::Dispatcher *d)

{

    this->dispatcher = d;

}