HPCToolkit
Communication.hpp
Go to the documentation of this file.
1 // -*-Mode: C++;-*-
2 
3 // * BeginRiceCopyright *****************************************************
4 //
5 // $HeadURL: https://hpctoolkit.googlecode.com/svn/branches/hpctoolkit-hpcserver/src/tool/hpcserver/Communication.hpp $
6 // $Id: Communication.hpp 4307 2013-07-18 17:04:52Z felipet1326@gmail.com $
7 //
8 // --------------------------------------------------------------------------
9 // Part of HPCToolkit (hpctoolkit.org)
10 //
11 // Information about sources of support for research and development of
12 // HPCToolkit is at 'hpctoolkit.org' and in 'README.Acknowledgments'.
13 // --------------------------------------------------------------------------
14 //
15 // Copyright ((c)) 2002-2019, Rice University
16 // All rights reserved.
17 //
18 // Redistribution and use in source and binary forms, with or without
19 // modification, are permitted provided that the following conditions are
20 // met:
21 //
22 // * Redistributions of source code must retain the above copyright
23 // notice, this list of conditions and the following disclaimer.
24 //
25 // * Redistributions in binary form must reproduce the above copyright
26 // notice, this list of conditions and the following disclaimer in the
27 // documentation and/or other materials provided with the distribution.
28 //
29 // * Neither the name of Rice University (RICE) nor the names of its
30 // contributors may be used to endorse or promote products derived from
31 // this software without specific prior written permission.
32 //
33 // This software is provided by RICE and contributors "as is" and any
34 // express or implied warranties, including, but not limited to, the
35 // implied warranties of merchantability and fitness for a particular
36 // purpose are disclaimed. In no event shall RICE or contributors be
37 // liable for any direct, indirect, incidental, special, exemplary, or
38 // consequential damages (including, but not limited to, procurement of
39 // substitute goods or services; loss of use, data, or profits; or
40 // business interruption) however caused and on any theory of liability,
41 // whether in contract, strict liability, or tort (including negligence
42 // or otherwise) arising in any way out of the use of this software, even
43 // if advised of the possibility of such damage.
44 //
45 // ******************************************************* EndRiceCopyright *
46 
47 //***************************************************************************
48 //
49 // File:
50 // $HeadURL: https://hpctoolkit.googlecode.com/svn/branches/hpctoolkit-hpcserver/src/tool/hpcserver/Communication.hpp $
51 //
52 // Purpose:
53 // Abstracts the MPI/No-MPI differences away.
54 //
55 // Description:
56 // [The set of functions, macros, etc. defined in the file]
57 //
58 //***************************************************************************
59 
60 
61 #ifndef COMMUNICATION_H_
62 #define COMMUNICATION_H_
63 
64 #include <string>
65 
66 #include "TimeCPID.hpp" //For Time
67 #include "ProgressBar.hpp"
69 #include "DataSocketStream.hpp"
70 #include "Filter.hpp"
71 
72 namespace TraceviewerServer
73 {
74 enum ServerType {
76  MASTER = 1,
77  SLAVE = 2
78 };
79 
81 public:
82 
83  static void sendParseInfo(Time minBegTime, Time maxEndTime, int headerSize);
84  static void sendParseOpenDB(string pathToDB);
85  static void sendStartGetData(SpaceTimeDataController* contr, int processStart, int processEnd,
86  Time timeStart, Time timeEnd, int verticalResolution, int horizontalResolution);
87  static void sendEndGetData(DataSocketStream* stream, ProgressBar* prog, SpaceTimeDataController* controller);
88  static void sendStartFilter(int count, bool excludeMatches);
89  static void sendFilter(BinaryRepresentationOfFilter filt);
90 
91  static bool basicInit(int argc, char** argv);
92  static void run();
93  static void closeServer();
94 };
95 }
96 #endif /* COMMUNICATION_H_ */
static void sendStartFilter(int count, bool excludeMatches)
static void sendParseInfo(Time minBegTime, Time maxEndTime, int headerSize)
static void sendEndGetData(DataSocketStream *stream, ProgressBar *prog, SpaceTimeDataController *controller)
static void sendFilter(BinaryRepresentationOfFilter filt)
static bool basicInit(int argc, char **argv)
static void sendStartGetData(SpaceTimeDataController *contr, int processStart, int processEnd, Time timeStart, Time timeEnd, int verticalResolution, int horizontalResolution)
static void sendParseOpenDB(string pathToDB)