You cannot select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
156 lines
3.5 KiB
C++
156 lines
3.5 KiB
C++
#include "arch/lapic.h"
|
|
#include "boot/startup_ap.h"
|
|
#include "arch/core_interrupt.h"
|
|
#include "debug/copystream.h"
|
|
#include "debug/output.h"
|
|
#include "debug/assert.h"
|
|
|
|
#include "arch/cga.h"
|
|
#include "arch/textwindow.h"
|
|
#include "arch/serial.h"
|
|
#include "device/serialstream.h"
|
|
#include "device/textstream.h"
|
|
#include "device/ps2controller.h"
|
|
#include "arch/ioapic.h"
|
|
#include "thread/scheduler.h"
|
|
#include "user/app1/appl.h"
|
|
#include "sync/ticketlock.h"
|
|
#include "interrupt/guard.h"
|
|
|
|
#include "arch/context.h"
|
|
#include "thread/thread.h"
|
|
|
|
///TextStream kout = TextStream(0, 80, 0, 10, true);
|
|
Ticketlock koutlock;
|
|
Scheduler sch;
|
|
|
|
//TextStream dout[8] = {
|
|
// TextStream(0 ,20,12,25,false),
|
|
// TextStream(20,40,12,25,false),
|
|
// TextStream(40,60,12,25,false),
|
|
// TextStream(60,80,12,25,false),
|
|
// TextStream(0 ,0 ,0, 0,false),
|
|
// TextStream(0 ,0 ,0, 0,false),
|
|
// TextStream(0 ,0 ,0, 0,false),
|
|
// TextStream(0 ,0 ,0, 0,false),
|
|
//};
|
|
|
|
|
|
TextStream dout[Core::MAX] = {
|
|
{0, 40, 10, 14},
|
|
{40, 80, 10, 14},
|
|
{0, 40, 14, 18},
|
|
{40, 80, 14, 18},
|
|
{0, 40, 18, 22},
|
|
{40, 80, 18, 22},
|
|
{0, 40, 22, 25},
|
|
{40, 80, 22, 25},
|
|
};
|
|
|
|
CopyStream copystream[Core::MAX]{
|
|
{&dout[0], &sout},
|
|
{&dout[1], &sout},
|
|
{&dout[2], &sout},
|
|
{&dout[3], &sout},
|
|
{&dout[4], &sout},
|
|
{&dout[5], &sout},
|
|
{&dout[6], &sout},
|
|
{&dout[7], &sout},
|
|
};
|
|
|
|
OutputStream* copyout[Core::MAX]{
|
|
&dout[0],
|
|
©stream[1],
|
|
&dout[2],
|
|
&dout[3],
|
|
&dout[4],
|
|
&dout[5],
|
|
&dout[6],
|
|
&dout[7]
|
|
};
|
|
|
|
unsigned int testx, testy;
|
|
|
|
Context test1;
|
|
uint8_t test1_stack[1024];
|
|
//Thread test1_thread = Thread(&test1_stack[sizeof(test1_stack)-1]);
|
|
Application application = Application(&test1_stack[sizeof(test1_stack)-1]);
|
|
|
|
//Context test2;
|
|
//uint8_t test2_stack[256];
|
|
//Thread test2_thread = Thread(&test2_stack[sizeof(test2_stack)-1]);
|
|
|
|
//void test_func1(){
|
|
// while(1){
|
|
// {
|
|
// Guarded g = Guard::enter();
|
|
// g.vault().kout << "test 1\n" << flush;
|
|
// }
|
|
// context_switch(&test2, &test1);
|
|
// }
|
|
//}
|
|
//
|
|
//void test_func2(){
|
|
// while(1){
|
|
// {
|
|
// Guarded g = Guard::enter();
|
|
// g.vault().kout << "test 2\n" << flush;
|
|
// }
|
|
// context_switch(&test1, &test2);
|
|
// }
|
|
//}
|
|
|
|
|
|
// Main function
|
|
// (the bootstrap processor starts here)}
|
|
extern "C" int main() {
|
|
CGA::setCursor(0, 0);
|
|
|
|
unsigned int numCPUs = Core::count();
|
|
/* Start application processors
|
|
* To avoid unexpected behaviour, make sure that interrupts are not
|
|
* enabled before the APs are booted. Otherwise it might interfere with the
|
|
* Startup IPIs or even block devices like keyboard because of a missing EOI
|
|
*/
|
|
|
|
ApplicationProcessor::boot();
|
|
|
|
PS2Controller::init();
|
|
|
|
IOAPIC::init();
|
|
IOAPIC::config(1, Core::Interrupt::KEYBOARD);
|
|
IOAPIC::allow(1);
|
|
|
|
Core::Interrupt::enable();
|
|
|
|
PS2Controller::drainBuffer();
|
|
|
|
DBG << "Main CPU " << static_cast<int>(LAPIC::getID()) << endl << flush;
|
|
|
|
sch.ready(&application);
|
|
sch.schedule();
|
|
|
|
|
|
//Application{}.action();
|
|
while (true){
|
|
//DBG << "pos: " << testx << ", " << testy << endl << flush;
|
|
//Core::pause();
|
|
}
|
|
|
|
return 0;
|
|
}
|
|
|
|
// Main function for application processors
|
|
extern "C" int main_ap() {
|
|
DBG_VERBOSE << "CPU core " << static_cast<int>(Core::getID()) << " / LAPIC "
|
|
<< static_cast<int>(LAPIC::getID()) << " in main_ap()" << endl;
|
|
Core::Interrupt::enable();
|
|
|
|
DBG << "App CPU " << static_cast<int>(Core::getID()) << endl << flush;
|
|
|
|
//assert(Core::getID() != 1);
|
|
//Application{}.action();
|
|
|
|
return 0;
|
|
}
|