manes/start.cpp

   1 /* Quarn OS
   2  *
   3  * Startup code
   4  *
   5  * Copyright (C) 2008-2009 Pawel Dziepak
   6  *
   7  * This program is free software; you can redistribute it and/or modify
   8  * it under the terms of the GNU General Public License as published by
   9  * the Free Software Foundation; either version 2 of the License, or
  10  * (at your option) any later version.
  11  *
  12  * This program is distributed in the hope that it will be useful,
  13  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  14  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  15  * GNU General Public License for more details.
  16  *
  17  * You should have received a copy of the GNU General Public License along
  18  * with this program; if not, write to the Free Software Foundation, Inc.,
  19  * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
  20  *
  21  */
  22
  23
  24 /* This file consist of functions that are called in order to run Manes. It
  25  * includes initialization of hardware and internal kernel data structures.
  26  * After this operation kernel can change to the standard way of working witch
  27  * preemption, resources, actors and so on.
  28  */
  29
  30 /**
  31  * @mainpage Quarn OS Documentation
  32  * @image html http://quarnos.org/img/qoslogo.png
  33  */
  34 #if __GNUC__ < 4
  35 #error Quarn OS is needed to be compiled on GCC 4 or later.
  36 #endif
  37
  38 #include "runtime.h"
  39 #include "services/kernel_state.h"
  40 #include "manec.h"
  41 #include "manei.h"
  42 #include "resources/stream.h"
  43 #include "arch/low/general.h"
  44 #include "resources/block.h"
  45
  46 #include "arch/low/launch.h"
  47 #include "arch/low/console.h"
  48 #include "resources/fs.h"
  49 #include "services/logger.h"
  50 #include "resources/bus.h"
  51 #include "resources/ethernet.h"
  52 #include "resources/fat.h"
  53 #include "resources/pci.h"
  54 #include "resources/isa.h"
  55 #include "libs/delegate.h"
  56 #include "libs/string.h"
  57 #include "modules/loader.h"
  58 #include "resources/file.h"
  59 #include "services/unmangler.h"
  60 #include "actors/actor.h"
  61 #include "actors/director.h"
  62 #include "modules/module.h"
  63 #include "resources/pio.h"
  64 #include "libs/setjmp.h"
  65 #include "services/stats.h"
  66 #include "libs/pointer.h"
  67 #include "typeinfo"
  68 #include "resources/ne2k.h"
  69 #include "resources/ipv4.h"
  70 #include "resources/arp.h"
  71 #include "resources/icmp.h"
  72
  73 using namespace services;
  74 using namespace modules;
  75 using namespace resources;
  76 using namespace manes;
  77 using namespace arch;
  78 using namespace actors;
  79
  80 void next();
  81
  82 void *operator new(unsigned int, int);
  83
  84 extern char *comp_vtable;
  85 extern ne2k *faar;
  86
  87 extern "C" void jump_v86();
  88 #include "arch/low/pit.h"
  89 #if USE_MULTIBOOT == CONF_YES
  90 extern "C" void start() {
  91 #else
  92 extern "C" void _start() {
  93 #endif
  94         delegate<void,const char> del;
  95
  96         /* Prepare to execute C++ code */
  97         runtime_start();
  98
  99         /* Launch Managed Execution System */
 100         manei::get()->launch_manes();
 101
 102         manec::get()->connect_manes(manei::get()->get_root());
 103
 104         p<manec> main = manec::get();
 105
 106         /* Abstract types */
 107         main->register_abstract("storage", "noeene");
 108         main->register_abstract("console", "naaone");
 109         main->register_abstract("nic", "none");
 110
 111         /* Run low-level procedures */
 112         arch::launch();
 113
 114         /* Register creators */
 115         manei::get()->register_creators();
 116
 117         /* Register built in types */
 118         manei::get()->register_builtin_types();
 119
 120         /* Run creators */
 121         manei::get()->animate_creators();
 122
 123         /* Initialize clock */
 124         arch::pit_init();
 125
 126         /* Manes is ready to use */
 127         p<logger> log = main->get<logger>("/early_logger");
 128
 129         jmp_buf ab;
 130         if (!setjmp(ab)) {
 131                 log->print("OK.\nStarting Quarn OS...",logger::log_critical);
 132                 longjmp(ab,1);
 133         }
 134
 135         p<stream> tty;
 136
 137         /*try {
 138                 throw 5;
 139                 tty = main->get<stream>("/keybscr");
 140         }
 141         catch (int) {
 142
 143                 log->print("cannot create tty", services::logger::log_info);
 144                 while(1);
 145         }*/
 146
 147         p<stats> stat = main->get<stats>("/stats");
 148
 149         p<logger> tlog = main->get<logger>("/tty_logger");
 150         tlog->print((string)"EFC caught so far " + stat->get_value(services::stats::efc_calls) + " function calls.", services::logger::log_info);
 151
 152         p<bus> mainbus = main->get<bus>("/isa");
 153         tlog->print((string)"\nFound ISA devices: " + mainbus->get_count(), services::logger::log_info);
 154
 155         p<bus> pbus = main->get<bus>("/pci");
 156         tlog->print((string)"\nFound PCI devices: " + pbus->get_count(), services::logger::log_info);
 157
 158         tlog->print((string)"\nAvailable memory: " + manec::get()->state()->get_memory_size() / 1024 / 1024 + " MB\n\n", services::logger::log_info);
 159
 160         ethernet eth;
 161         eth.set_nic(faar);
 162
 163         ipv4 ip;
 164         ip.set_link_layer(&eth);
 165         ip.configure_ipv4(192 << 24 | 168 << 16 | 1 << 8 | 50, 255 << 24 | 255 << 16 | 255 << 8, 192 << 24 | 168 << 16 | 1 << 8 | 1);
 166
 167         icmp ping;
 168         ping.set_ipv4(&ip);
 169 //      ping.ping(192 << 24 | 168 << 16 | 1 << 8 | 2);
 170
 171 //      ping.ping(192 << 24 | 168 << 16 | 1 << 8 | 2);
 172
 173         p<block> floppy = main->get<block>("/fdc");
 174         p<fs> fs_floppy = main->get<fs>("/fat");
 175
 176         type *pcit = main->get<type>("/type,pci");
 177
 178         fs_floppy->mount(floppy);
 179         p<file> temp = main->get<file>("/file,authors");
 180
 181         tlog->print((string)(const char*)((const string)*temp), services::logger::log_warning);
 182
 183         p<modules::module> mod = main->get_component(component_name((type_name)"loader",0))->get<loader>()->get_component(component_name((type_name)"module","rs232.ko"))->get<modules::module>();
 184         mod->place(module::module_kernel_space);
 185         mod->get_delegate()();
 186
 187         p<unmangler> unman = main->get<unmangler>("/unmangler");
 188
 189         stream *serial = main->get<stream>("/console,1");
 190
 191         string name = unman->unmangle(typeid(*serial).name());
 192         serial->write_bytes(name, name.length());
 193
 194         delegate<void> del_next;
 195         del_next.function(next);
 196
 197         jump_v86();
 198
 199         p<director> sched = main->get_component(component_name((type_name)"director",0))->get<director>();
 200         p<actor> proc = sched->new_component((type_name)"actor")->get<actor>();
 201
 202         proc->set(del_next);
 203 /* Benchmark
 204         for (int i = 0; i < 10000; i++)
 205                 for (int j = 0; j < 1000; j++)
 206                         stat->get_value(stats::ks_timeticks);
 207 */
 208         tlog->print((string)"EFC caught so far " + stat->get_value(services::stats::efc_calls) + " function calls.\n", services::logger::log_info);
 209         string ss = stat->full_stats();
 210         serial->write_bytes(ss, ss.length());
 211         //tlog->print(ss, services::logger::log_warning);
 212
 213         sched->launch(proc);
 214
 215 }
 216
 217 void next() {
 218         p<manec> main = manec::get();
 219 while(1) asm("hlt");
 220         p<modules::module> mod = main->get<modules::module>("/module,shell.ko");
 221         mod->place(module::module_kernel_space);
 222
 223 /*      p<director> sched = main->get_component(component_name((type_name)"director",0))->get<director>();
 224         p<actor> proc = sched->new_component((type_name)"actor")->get<actor>();
 225         proc->set(mod->get_delegate());
 226         sched->start(proc);*/
 227
 228         /* PIO */
 229         stream *ttyS = main->get<stream>("/console,1");
 230
 231         pio *str = main->get<pio>("/pio");
 232
 233         char buffer[] = "\n\xdHello World!!!";
 234         str->set_dep(ttyS);
 235         str->send_packet(buffer,strlen(buffer));
 236         str->set_speed(3);
 237         delegate<void> nul;
 238         str->start(false, nul);
 239
 240         while (1)  __asm__("hlt");
 241 }