File: pipe2_05_add_variables.txt

package info (click to toggle)
adios2 2.10.2%2Bdfsg1-2
  • links: PTS, VCS
  • area: main
  • in suites: trixie
  • size: 33,764 kB
  • sloc: cpp: 175,964; ansic: 160,510; f90: 14,630; yacc: 12,668; python: 7,275; perl: 7,126; sh: 2,825; lisp: 1,106; xml: 1,049; makefile: 579; lex: 557
file content (55 lines) | stat: -rw-r--r-- 1,758 bytes parent folder | download | duplicates (2)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
# Config file for Task 1 in a pipeline
#   - Produce variables  a  b  c 
#   - Write variables    a  b  c     to    stream_T1.bp

# Config file for Task 2 in a pipeline
#   - Read in variables  a  b  from Task 1 (ignore c) from stream_T1.bp
#     using a different decomposition
#   - Produce variable   d  e
#   - Write variables    a  b  d  e  to   stream_T2.bp


group  io_T1
  # item  type    varname     N   [dim1 dim2 ... dimN  decomp1 decomp2 ... decompN]
  array   double  a           2    100   200              X       YZ
  array   float   b           1    100                    XYZ 
  array   float   c           3    100   200   300        XY      z     1

group  io_T2_in
  # item  type    varname     N   [dim1 dim2 ... dimN  decomp1 decomp2 ... decompN]
  array   double  a           2    100   200              XY      Z
  array   float   b           1    100                    XYZ 

group  io_T2_out
  # use all variables read into io_T2_in in the output 
  link group io_T2_in
  array   int     d           3    100   200   300        XY      z     1
  array   float   e           2    250   128              X       YZ



# Task 1 actions
app 1
  steps   3
  sleep   5.0      
    # write all of io_T1 into stream_T1.bp
  write   stream_T1.bp    io_T1

# Task 2 actions
app 2
  steps   over stream_T1.bp   
  # read a & b from stream_T1.bp using io_T2_in definition without blocking wait
  read  next  stream_T1.bp    io_T2_in  0   a   b

  # Sleep and write only if read was successful:
  cond stream_T1.bp   sleep   2.0      
  # write io_T2 into stream_T2.bp
  #    a & b  will be the data from stream_T1.bp
  #    d & e  will be generated by app 2
  cond stream_T1.bp  write    stream_T2.bp    io_T2_out  

  sleep   1.123456789