pio_rpc.h 1.03 KB
Newer Older
Deike Kleberg's avatar
Deike Kleberg committed
1
2
3
#ifndef PIO_RPC_H
#define PIO_RPC_H

4
5
6
7
8
9
#ifdef HAVE_CONFIG_H
#  include "config.h"
#endif

#ifdef USE_MPI

Deike Kleberg's avatar
Deike Kleberg committed
10
11
#include <mpi.h>

Deike Kleberg's avatar
Deike Kleberg committed
12
13
14
typedef enum
  {
    FINALIZE,
Deike Kleberg's avatar
Deike Kleberg committed
15
    RESOURCES,
Deike Kleberg's avatar
Deike Kleberg committed
16
17
18
    WINCREATE,
    WRITETS
  } command;
19

Deike Kleberg's avatar
Deike Kleberg committed
20
21
22
23
24
25
26
27
28
enum 
{ GRID      = 1,
  ZAXIS     = 2,
  TAXIS     = 3,
  INSTITUTE = 4,
  MODEL     = 5,
  STREAM    = 6,
  VLIST     = 7,
  START     = 55555555,
29
30
31
  SEPARATOR = 66666666,
  DATATOKEN = 77777777,
  FUNCCALL  = 88888888,
Deike Kleberg's avatar
Deike Kleberg committed
32
33
  END       = 99999999 
};
34

Deike Kleberg's avatar
Deike Kleberg committed
35
36
enum
{
37
  winBufferOverhead = 1,
Deike Kleberg's avatar
Deike Kleberg committed
38
  winBufferOverheadChunk = 5,
Deike Kleberg's avatar
Deike Kleberg committed
39
  winBufferOverheadFuncCall = 3,
40
41
42
  timestepSize = 3
};

43
44
#define MAXWINBUFFERSIZE ((size_t)512 * 1024 * 1024)

Deike Kleberg's avatar
Deike Kleberg committed
45
46
47
48
enum { nFuncs = 3, STREAMOPEN = 0, STREAMDEFVLIST = 1, STREAMCLOSE = 2 };
enum { MAXDATAFILENAME = 256, MINFUNCID = STREAMOPEN, MAXFUNCID = STREAMCLOSE };
extern char * funcMap[nFuncs];

49
void rpcUnpackResources ( char *, int, MPI_Comm );
50

Deike Kleberg's avatar
Deike Kleberg committed
51
#endif
52
53

#endif
54
55
56
57
58
59
60
61
62
/*
 * Local Variables:
 * c-file-style: "Java"
 * c-basic-offset: 2
 * indent-tabs-mode: nil
 * show-trailing-whitespace: t
 * require-trailing-newline: t
 * End:
 */