flag1.cxx

eCos1.31版

//==========================================================================
//
//        flag1.cxx
//
//        Flag test 1
//
//==========================================================================
//####COPYRIGHTBEGIN####
//                                                                          
// -------------------------------------------                              
// The contents of this file are subject to the Red Hat eCos Public License 
// Version 1.1 (the "License"); you may not use this file except in         
// compliance with the License.  You may obtain a copy of the License at    
// http://www.redhat.com/                                                   
//                                                                          
// Software distributed under the License is distributed on an "AS IS"      
// basis, WITHOUT WARRANTY OF ANY KIND, either express or implied.  See the 
// License for the specific language governing rights and limitations under 
// the License.                                                             
//                                                                          
// The Original Code is eCos - Embedded Configurable Operating System,      
// released September 30, 1998.                                             
//                                                                          
// The Initial Developer of the Original Code is Red Hat.                   
// Portions created by Red Hat are                                          
// Copyright (C) 1998, 1999, 2000 Red Hat, Inc.                             
// All Rights Reserved.                                                     
// -------------------------------------------                              
//                                                                          
//####COPYRIGHTEND####
//==========================================================================
//#####DESCRIPTIONBEGIN####
//
// Author:        dsm
// Contributors:    dsm
// Date:          1998-05-11
// Description:   Tests basic flag functionality.
//####DESCRIPTIONEND####

#include <pkgconf/kernel.h>

#include <cyg/kernel/thread.hxx>        // Cyg_Thread
#include <cyg/kernel/thread.inl>
#include <cyg/kernel/sched.hxx>         // Cyg_Scheduler::start()

#include <cyg/kernel/flag.hxx>

#include <cyg/infra/testcase.h>

#include <cyg/kernel/sched.inl>


#define NTHREADS 3
#include "testaux.hxx"

static Cyg_Flag f0, f1;
#ifdef CYGFUN_KERNEL_THREADS_TIMER
static Cyg_Flag f2;
#endif

static volatile cyg_atomic q = 0;

static void entry0( CYG_ADDRWORD data )
{
    CYG_TEST_INFO("Testing setbits() and maskbits()");
    CYG_TEST_CHECK(0==f0.peek(), "flag not initialized properly");
    f0.setbits(0x1);
    CYG_TEST_CHECK(1==f0.peek(), "setbits");
    f0.setbits(0x3);
    CYG_TEST_CHECK(3==f0.peek(), "setbits");
    f0.maskbits(~0x5);
    CYG_TEST_CHECK(2==f0.peek(), "maskbits");
    f0.setbits();
    CYG_TEST_CHECK(~0u==f0.peek(), "setbits no arg");
    f0.maskbits();
    CYG_TEST_CHECK(0==f0.peek(), "maskbits no arg");
    CYG_TEST_CHECK(0==q++, "bad synchronization");

    CYG_TEST_INFO("Testing wait()");
    f1.setbits(0x4);
    CYG_TEST_CHECK(0x4==f1.peek(), "maskbits no arg");
    CYG_TEST_CHECK(1==q++, "bad synchronization");
    f1.setbits(0x18);                   // wake t1
    f1.wait(0x11, Cyg_Flag::AND | Cyg_Flag::CLR);
    CYG_TEST_CHECK(0==f1.peek(), "flag value wrong");
    CYG_TEST_CHECK(3==q++, "bad synchronization");
    f0.setbits(0x2);                    // wake t1
    f1.wait(0x10, Cyg_Flag::AND );
    f0.setbits(0x1);                    // wake t1

    f1.wait(0x11, Cyg_Flag::AND | Cyg_Flag::CLR);

#ifdef CYGFUN_KERNEL_THREADS_TIMER
    f2.wait(0x2, Cyg_Flag::OR);    
    CYG_TEST_CHECK(20==q,"bad synchronization");
    f2.wait(0x10, Cyg_Flag::AND, 
            Cyg_Clock::real_time_clock->current_value()+80);
    CYG_TEST_CHECK(21==q++,"bad synchronization");
#endif
    f0.wait(1, Cyg_Flag::OR);

    CYG_TEST_FAIL_FINISH("Not reached");
}

static void entry1( CYG_ADDRWORD data )
{
    f1.wait(0xc, Cyg_Flag::AND);
    CYG_TEST_CHECK(2==q++, "bad synchronization");
    CYG_TEST_CHECK(0x1c==f1.peek(), "flag value wrong");
    f1.setbits(0x1);                    // wake t0
    f0.wait(0x3, Cyg_Flag::OR);
    CYG_TEST_CHECK(4==q++, "bad synchronization");
    CYG_TEST_CHECK(2==f0.peek(), "flag value wrong");
    
    f1.setbits(0xf0);                   // wake t0,t2
    f0.wait(0x5, Cyg_Flag::AND | Cyg_Flag::CLR); // wait for t0 & t2
    CYG_TEST_CHECK(0==f0.peek(), "flag value wrong");
    CYG_TEST_CHECK(0xf0==f1.peek(), "flag value wrong");
    CYG_TEST_CHECK(5==q++, "bad synchronization");
    f1.maskbits();
    CYG_TEST_CHECK(0==f1.peek(), "flag value wrong");
    
    CYG_TEST_INFO("Testing poll()");
    f0.setbits(0x55);
    CYG_TEST_CHECK(0x55==f0.peek(), "flag value wrong");
    CYG_TEST_CHECK(0x55==f0.poll(0x3, Cyg_Flag::OR),"bad poll() return");
    CYG_TEST_CHECK(0==f0.poll(0xf, Cyg_Flag::AND),"poll()");
    CYG_TEST_CHECK(0==f0.poll(0xa, Cyg_Flag::OR),"poll()");
    CYG_TEST_CHECK(0x55==f0.peek(), "flag value wrong");
    CYG_TEST_CHECK(0x55==f0.poll(0xf, Cyg_Flag::OR | Cyg_Flag::CLR),"poll");
    CYG_TEST_CHECK(0x0==f0.peek(), "flag value wrong");
    f0.setbits(0x50);
    CYG_TEST_CHECK(0x50==f0.poll(0x10, Cyg_Flag::AND | Cyg_Flag::CLR),"poll");
    CYG_TEST_CHECK(0x0==f0.peek(), "flag value wrong");

    CYG_TEST_INFO("Testing waiting()");
    f0.maskbits();
    CYG_TEST_CHECK(!f0.waiting(), "waiting()");

#ifdef CYGFUN_KERNEL_THREADS_TIMER
    thread[1]->delay(40); // allow other threads to reach wait on f1
    CYG_TEST_CHECK(f1.waiting(), "waiting() not true");
    f1.setbits();                       // wake one of t0,t2
    CYG_TEST_CHECK(f1.waiting(), "waiting() not true");
#else
    f1.setbits(0x11);                   // wake one of t0,t2
#endif
    f1.setbits(0x11);                   // wake other of t0,t2    
    CYG_TEST_CHECK(!f1.waiting(), "waiting not false");

#ifdef CYGFUN_KERNEL_THREADS_TIMER
    CYG_TEST_INFO("Testing wait() with timeout");
    q=20;
    f2.setbits(0x2);                    // synchronize with t0,t2
    CYG_TEST_CHECK(20==q,"bad synchronization");
    f2.wait(0x20, Cyg_Flag::AND,
            Cyg_Clock::real_time_clock->current_value()+40);
    CYG_TEST_CHECK(22==q++,"bad synchronization");
#endif

    CYG_TEST_PASS_FINISH("Flag 1 OK");
}

static void entry2( CYG_ADDRWORD data )
{
    f1.wait(0x60, Cyg_Flag::OR);
    f0.setbits(0x4);

    f1.wait(0x11, Cyg_Flag::AND | Cyg_Flag::CLR);
#ifdef CYGFUN_KERNEL_THREADS_TIMER
    f2.wait(0x2, Cyg_Flag::OR);
    CYG_TEST_CHECK(20==q,"bad synchronization");
    CYG_TEST_CHECK(0==f2.wait(0x40, Cyg_Flag::AND,
                              Cyg_Clock::real_time_clock->current_value()+20),
                   "timed wait() wrong");
    CYG_TEST_CHECK(20==q++,"bad synchronization");
    // Now wake t0 before it times out
    f2.setbits(0x10);
#endif
    f0.wait(1, Cyg_Flag::OR);    
    
    CYG_TEST_FAIL_FINISH("Not reached");
}

void flag1_main( void )
{
    CYG_TEST_INIT();

    new_thread(entry0, 0);
    new_thread(entry1, 1);
    new_thread(entry2, 2);

    Cyg_Scheduler::start();

    CYG_TEST_FAIL_FINISH("Not reached");
}

externC void
cyg_start( void )
{ 
    flag1_main();
}

// EOF flag1.cxx