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 "manes/error.h"
  43 #include "resources/stream.h"
  44 #include "arch/low/general.h"
  45 #include "resources/block.h"
  46
  47 #include "arch/low/launch.h"
  48 #include "resources/fs.h"
  49 #include "services/logger.h"
  50 #include "services/dns_client.h"
  51 #include "resources/bus.h"
  52 #include "resources/net/ethernet.h"
  53 #include "resources/fat.h"
  54 #include "resources/pci.h"
  55 #include "resources/isa.h"
  56 #include "libs/delegate.h"
  57 #include "libs/string.h"
  58 #include "modules/loader.h"
  59 #include "resources/file.h"
  60 #include "services/ntp_client.h"
  61 #include "services/unmangler.h"
  62 #include "actors/actor.h"
  63 #include "actors/director.h"
  64 #include "modules/module.h"
  65 #include "resources/pio.h"
  66 #include "libs/setjmp.h"
  67 #include "services/stats.h"
  68 #include "libs/pointer.h"
  69 #include "resources/keybscr.h"
  70 #include "typeinfo"
  71 #include "resources/ne2k.h"
  72 #include "resources/net/ipv4.h"
  73 #include "resources/net/arp.h"
  74 #include "resources/net/udp.h"
  75 #include "resources/net/icmp.h"
  76 #include "resources/net/tcp.h"
  77
  78 using namespace services;
  79 using namespace modules;
  80 using namespace resources;
  81 using namespace manes;
  82 using namespace arch;
  83 using namespace actors;
  84 using namespace net;
  85
  86 void next();
  87
  88 void *operator new(unsigned int, int);
  89
  90 extern char *comp_vtable;
  91 extern p<nic> faar;
  92
  93 void launch_kernel();
  94
  95 extern "C" void jump_v86();
  96
  97 #include "arch/low/pit.h"
  98 #if USE_MULTIBOOT == CONF_YES
  99 extern "C" void start() {
 100 #else
 101 extern "C" void _start() {
 102 #endif
 103         /* Prepare to execute C++ code */
 104         runtime_start();
 105
 106         try {
 107                 launch_kernel();
 108         }
 109         catch (exception *ex) {
 110                 critical("WTF?");
 111         }
 112
 113 }
 114
 115 void launch_kernel() {
 116         delegate<void,const char> del;
 117
 118         /* Launch Managed Execution System */
 119         manei::get()->launch_manes();
 120
 121         manec::get()->connect_manes(manei::get()->get_root());
 122
 123         p<manec> main = manec::get();
 124
 125         /* Abstract types */
 126         main->register_abstract("device", "none");
 127         main->register_abstract("storage", "device");
 128         main->register_abstract("console", "device");
 129         main->register_abstract("nic", "device");
 130
 131         main->register_abstract("allocator", "none");
 132
 133         main->register_abstract("service", "none");
 134
 135         /* Run low-level procedures */
 136         arch::launch();
 137
 138         /* Register creators */
 139         manei::get()->register_creators();
 140
 141         /* Register built in types */
 142         manei::get()->register_builtin_types();
 143
 144         /* Run creators */
 145         manei::get()->animate_creators();
 146
 147         /* Initialize clock */
 148         arch::pit_init();
 149
 150         /* Manes is ready to use */
 151         p<logger> log = main->get<logger>("/early_logger");
 152
 153         jmp_buf ab;
 154         if (!setjmp(ab)) {
 155                 log->print("OK.\nStarting Quarn OS...",logger::log_critical);
 156                 longjmp(ab,1);
 157         }
 158
 159         p<stream> tty;
 160
 161         try {
 162         //      throw 5;
 163                 tty = main->get<stream>("/keybscr");
 164         }
 165         catch (char) {
 166                 while(1);
 167         }
 168         catch (int) {
 169
 170                 log->print("cannot create tty", services::logger::log_info);
 171                 //while(1);
 172         }
 173
 174         p<stats> stat = main->get<stats>("/stats");
 175
 176         p<logger> tlog = main->get<logger>("/tty_logger");
 177         tlog->print((string)"\n\nEFC caught so far " + stat->get_value(services::stats::efc_calls) + " function calls.", services::logger::log_info);
 178
 179         p<bus> mainbus = main->get<bus>("/isa");
 180         tlog->print((string)"\nFound ISA devices: " + mainbus->get_count(), services::logger::log_info);
 181
 182         p<bus> pbus = main->get<bus>("/pci");
 183         tlog->print((string)"\nFound PCI devices: " + pbus->get_count(), services::logger::log_info);
 184
 185         tlog->print((string)"\nAvailable memory: " + manec::get()->state()->get_memory_size() / 1024 / 1024 + " MB\n\n", services::logger::log_info);
 186
 187         if (faar.valid()) {
 188                 ethernet eth;
 189                 eth.set_nic(faar);
 190
 191                 ipv4 ip;
 192                 ip.set_link_layer(&eth);
 193                 ip.configure_ipv4(ipv4_addr::from_le(192 << 24 | 168 << 16 | 1 << 8 | 50), ipv4_addr::from_le(255 << 24 | 255 << 16 | 255 << 8), ipv4_addr::from_le(192 << 24 | 168 << 16 | 1 << 8 | 1));
 194
 195                 string str = "GET / HTTP/1.1\r\n\r\n";
 196
 197                 string qu = "quarnos.org";
 198                 /*tcp t;
 199                 t.set_internet_layer(&ip);
 200                 p<client_socket> tcli = t.create_client();
 201                 tcli->connect(ipv4_addr::from_le(192 << 24 | 168 << 16 | 1 << 8 | 3), 80);
 202                 tcli->write(str.to_mem());
 203         //      tcli->write(str.to_mem());
 204                 tcli->close();*/
 205
 206                 udp u;
 207                 u.set_internet_layer(&ip);
 208
 209                 dns_client dns;
 210                 dns.set(&u);
 211                 ipv4_addr addr = dns.get_ipv4(qu);
 212                 asm("cli\nhlt"::"a"(addr.to_le()));
 213
 214                 ntp_client ntp;
 215                 ntp.set(&u);
 216                 ntp.get_timestamp();
 217
 218                 icmp ping;
 219                 ping.set_internet_layer(&ip);
 220                 ping.ping(ipv4_addr::from_le(192 << 24 | 168 << 16 | 1 << 8 | 2));
 221
 222                 ping.ping(ipv4_addr::from_le(192 << 24 | 168 << 16 | 1 << 8 | 2));
 223
 224                 while (true) asm("hlt");
 225         }
 226
 227         p<block> floppy = main->get<block>("/fdc");
 228         p<fs> fs_floppy = main->get<fs>("/fat");
 229
 230         fs_floppy->mount(floppy);
 231         p<file> temp = main->get<file>("/file,authors");
 232
 233         tlog->print((string)(const char*)((const string)*temp), services::logger::log_warning);
 234
 235         p<module> mod = main->get<module>("/module,rs232.ko");
 236
 237         mod->place(module::module_kernel_space);
 238         mod->get_delegate()();
 239
 240         p<unmangler> unman = main->get<unmangler>("/unmangler");
 241
 242         p<stream> serial = main->get<stream>("/console,1");
 243
 244         string name = unman->unmangle(typeid(*serial).name());
 245         serial->write(name.to_mem());
 246
 247         //jump_v86();
 248
 249         p<director> sched = main->get<director>("/director");
 250         p<actor> proc = sched->new_component(cds::component_name::from_path("/type,actor")).cast<actor>();
 251
 252         proc->set(delegate<void>::function(next));
 253 /* Benchmark
 254         for (int i = 0; i < 10000; i++)
 255                 for (int j = 0; j < 1000; j++)
 256                         stat->get_value(stats::ks_timeticks);
 257 //*/
 258         tlog->print((string)"EFC caught so far " + stat->get_value(services::stats::efc_calls) + " function calls.\n", services::logger::log_info);
 259
 260 //      string ss = stat->full_stats();
 261 //      serial->write(ss.to_mem());
 262
 263         sched->launch(proc);
 264 }
 265
 266 void next() {
 267         p<manec> main = manec::get();
 268
 269 //      p<modules::module> mod = main->get<modules::module>("/module,shell.ko");
 270 //      mod->place(module::module_kernel_space);
 271
 272         p<director> sched = main->get<director>("/director");
 273 //      p<actor> proc = sched->new_component((type_name)"actor")->get<actor>();
 274 //      proc->set(mod->get_delegate());
 275 //      sched->start(proc);
 276
 277         /* PIO */
 278         p<stream> ttyS = main->get<stream>("/console,1");
 279
 280         p<pio> str = new pio;
 281
 282         string buf = "\n\xdHello World!!!";
 283         str->set_dep(ttyS);
 284         str->send_packet(buf.to_mem());
 285         str->set_speed(3);
 286         delegate<void> nul;
 287
 288 //      str->start(false, nul);
 289
 290         str.dispose();
 291
 292         while (1)  __asm__("hlt");
 293 }