3 This file is part of the MSP Märklin suite
4 Copyright © 2010 Mikkosoft Productions, Mikko Rasa
5 Distributed under the GPL
8 #include <msp/net/resolve.h>
11 #include <msp/io/print.h>
15 using namespace Marklin;
17 Application::RegApp<Serial> Serial::reg;
19 Serial::Serial(int, char **argv):
25 DataFile::load(catalogue, "locos.dat");
27 client.use_event_dispatcher(event_disp);
28 client.signal_train_added.connect(sigc::mem_fun(this, &Serial::train_added));
29 client.signal_error.connect(sigc::mem_fun(this, &Serial::error));
31 string addr_str = argv[1];
32 if(addr_str.find(':')==string::npos)
34 Net::SockAddr *addr = Net::resolve(addr_str);
35 client.connect(*addr);
38 serial_port.set_parameters("9600,8N1");
39 event_disp.add(serial_port);
40 serial_port.signal_data_available.connect(sigc::mem_fun(this, &Serial::data_available));
48 void Serial::train_added(NetTrain &t)
54 void Serial::error(const string &e)
59 void Serial::set_train(NetTrain *t)
62 serial_port.write(format("A%02d", train->get_address()));
65 void Serial::next_train()
67 const map<unsigned, NetTrain *> &trains = client.get_trains();
69 map<unsigned, NetTrain *>::const_iterator i = trains.find(train->get_address());
77 void Serial::prev_train()
79 const map<unsigned, NetTrain *> &trains = client.get_trains();
81 map<unsigned, NetTrain *>::const_iterator i = trains.find(train->get_address());
89 void Serial::data_available()
92 serial_port.read(&c, 1);
95 if(c=='S' || c=='H' || c=='L')
96 rx_buf[rx_fill++] = c;
99 IO::print("Reverse\n");
100 train->set_reverse(!train->get_reverse());
109 rx_buf[rx_fill++] = c;
110 if(rx_buf[0]=='H' && rx_fill==2)
112 train->set_function(rx_buf[1]-'0', true);
113 IO::print("Func %d on\n", rx_buf[1]-'0');
116 else if(rx_buf[0]=='L' && rx_fill==2)
118 train->set_function(rx_buf[1]-'0', false);
119 IO::print("Func %d off\n", rx_buf[1]-'0');
122 else if(rx_buf[0]=='S' && rx_fill==3)
124 unsigned speed = (rx_buf[1]-'0')*10+(rx_buf[2]-'0');
125 IO::print("Set speed %d\n", speed);
126 train->set_speed(speed);