MBDyn-1.7.3
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros Groups
stream2socket.cc
Go to the documentation of this file.
1 /* $Header: /var/cvs/mbdyn/mbdyn/mbdyn-1.0/utils/stream2socket.cc,v 1.23 2017/01/12 15:10:28 masarati Exp $ */
2 /*
3  * MBDyn (C) is a multibody analysis code.
4  * http://www.mbdyn.org
5  *
6  * Copyright (C) 1996-2017
7  *
8  * Pierangelo Masarati <masarati@aero.polimi.it>
9  * Paolo Mantegazza <mantegazza@aero.polimi.it>
10  *
11  * Dipartimento di Ingegneria Aerospaziale - Politecnico di Milano
12  * via La Masa, 34 - 20156 Milano, Italy
13  * http://www.aero.polimi.it
14  *
15  * Changing this copyright notice is forbidden.
16  *
17  * This program is free software; you can redistribute it and/or modify
18  * it under the terms of the GNU General Public License as published by
19  * the Free Software Foundation (version 2 of the License).
20  *
21  *
22  * This program is distributed in the hope that it will be useful,
23  * but WITHOUT ANY WARRANTY; without even the implied warranty of
24  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
25  * GNU General Public License for more details.
26  *
27  * You should have received a copy of the GNU General Public License
28  * along with this program; if not, write to the Free Software
29  * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
30  */
31 
32 #include "mbconfig.h" /* This goes first in every *.c,*.cc file */
33 
34 #include <cstring>
35 #include <sys/types.h>
36 #include <sys/socket.h>
37 #include <netinet/in.h>
38 #include <netdb.h>
39 #include <cstdio>
40 #include <cstdlib>
41 #include <cerrno>
42 #include <sys/socket.h>
43 #include <netinet/in.h>
44 #include <sys/un.h>
45 #include <arpa/inet.h>
46 #include <unistd.h>
47 #include <fcntl.h>
48 #include <signal.h>
49 
50 #include <iostream>
51 #include <sstream>
52 #include <vector>
53 
54 #include "sock.h"
55 #include "s2s.h"
56 
57 int
58 main(int argc, char *argv[])
59 {
60  struct s2s_t s2s;
61 
62  try {
63  s2s.parse(argc, argv);
64  s2s.prepare();
65 
66  } catch (...) {
67  s2s.shutdown();
68  exit(EXIT_FAILURE);
69  }
70 
71  if (s2s.nChannels == 0) {
72  std::string buf;
73  std::getline(std::cin, buf);
74 
75  std::istringstream str(buf);
76  for (;; s2s.nChannels++) {
77  double d;
78 
79  str >> d;
80 
81  if (!str) {
82  break;
83  }
84 
85  s2s.dbuf.insert(s2s.dbuf.end(), d);
86  }
87 
88  s2s.send(0);
89 
90  } else {
91  s2s.dbuf.resize(s2s.nChannels);
92  }
93 
94  while (true) {
95  for (int i = 0; i < s2s.nChannels; i++) {
96  std::cin >> s2s.dbuf[i];
97  if (!std::cin) {
98  goto done;
99  }
100  }
101 
102  s2s.send(0);
103  }
104 
105 done:;
106  s2s.shutdown();
107  exit(EXIT_SUCCESS);
108 }
109 
int main(int argc, char *argv[])
ssize_t send(int flags) const
void prepare(void)
int nChannels
Definition: s2s.h:56
std::vector< double > dbuf
Definition: s2s.h:69
static unsigned done
Definition: gust.cc:209
Definition: s2s.h:54
static doublereal buf[BUFSIZE]
Definition: discctrl.cc:333
void parse(int argc, char *argv[])
void shutdown(void)