gs_lesson4b

Two models, A & B, that send/receive strings. Model A receives input from a file and then sends it’s output to model B. Model B receives input from model A and sends it’s output to a file. Connections are made using the deprecated method of matching the args parameter in input/output drivers.

C Version

Model Code:

 1#include <stdio.h>
 2// Include methods for input/output channels
 3#include "YggInterface.h"
 4
 5#define MYBUFSIZ 1000
 6
 7int main(int argc, char *argv[]) {
 8  // Initialize input/output channels
 9  yggInput_t in_channel = yggInput("inputA");
10  yggOutput_t out_channel = yggOutput("outputA");
11
12  // Declare resulting variables and create buffer for received message
13  int flag = 1;
14  char buf[MYBUFSIZ];
15
16  // Loop until there is no longer input or the queues are closed
17  while (flag >= 0) {
18  
19    // Receive input from input channel
20    // If there is an error, the flag will be negative
21    // Otherwise, it is the size of the received message
22    flag = ygg_recv(in_channel, buf, MYBUFSIZ);
23    if (flag < 0) {
24      printf("Model A: No more input.\n");
25      break;
26    }
27
28    // Print received message
29    printf("Model A: %s\n", buf);
30
31    // Send output to output channel
32    // If there is an error, the flag will be negative
33    flag = ygg_send(out_channel, buf, flag);
34    if (flag < 0) {
35      printf("Model A: Error sending output.\n");
36      break;
37    }
38
39  }
40  
41  return 0;
42}
43

 1#include <stdio.h>
 2// Include methods for input/output channels
 3#include "YggInterface.h"
 4
 5#define MYBUFSIZ 1000
 6
 7int main(int argc, char *argv[]) {
 8  // Initialize input/output channels
 9  yggInput_t in_channel = yggInput("inputB");
10  yggOutput_t out_channel = yggOutput("outputB");
11
12  // Declare resulting variables and create buffer for received message
13  int flag = 1;
14  char buf[MYBUFSIZ];
15
16  // Loop until there is no longer input or the queues are closed
17  while (flag >= 0) {
18  
19    // Receive input from input channel
20    // If there is an error, the flag will be negative
21    // Otherwise, it is the size of the received message
22    flag = ygg_recv(in_channel, buf, MYBUFSIZ);
23    if (flag < 0) {
24      printf("Model B: No more input.\n");
25      break;
26    }
27
28    // Print received message
29    printf("Model B: %s\n", buf);
30
31    // Send output to output channel
32    // If there is an error, the flag will be negative
33    flag = ygg_send(out_channel, buf, flag);
34    if (flag < 0) {
35      printf("Model B: Error sending output.\n");
36      break;
37    }
38
39  }
40  
41  return 0;
42}
43

Model YAML:

 1models:
 2  - name: c_modelA
 3    language: c
 4    args: ./src/gs_lesson4b_modelA.c
 5
 6    inputs:
 7      - name: inputA
 8        driver: FileInputDriver
 9        args: ./Input/input.txt
10
11    outputs:
12      - name: outputA
13        driver: OutputDriver  # Output to another channel
14        args: A_to_B  # Connection to inputB
15
16  - name: c_modelB
17    language: c
18    args: ./src/gs_lesson4b_modelB.c
19
20    inputs:
21      - name: inputB
22        driver: InputDriver  # Input from another channel
23        args: A_to_B  # Conneciton to inputA
24
25    outputs:
26      - name: outputB
27        driver: FileOutputDriver
28        args: ./output.txt

C++ Version

Model Code:

 1#include <iostream>
 2// Include methods for input/output channels
 3#include "YggInterface.hpp"
 4
 5#define MYBUFSIZ 1000
 6
 7int main(int argc, char *argv[]) {
 8  // Initialize input/output channels
 9  YggInput in_channel("inputA");
10  YggOutput out_channel("outputA");
11
12  // Declare resulting variables and create buffer for received message
13  int flag = 1;
14  char buf[MYBUFSIZ];
15
16  // Loop until there is no longer input or the queues are closed
17  while (flag >= 0) {
18  
19    // Receive input from input channel
20    // If there is an error, the flag will be negative
21    // Otherwise, it is the size of the received message
22    flag = in_channel.recv(buf, MYBUFSIZ);
23    if (flag < 0) {
24      std::cout << "Model A: No more input." << std::endl;
25      break;
26    }
27
28    // Print received message
29    std::cout << "Model A: " << buf << std::endl;
30
31    // Send output to output channel
32    // If there is an error, the flag will be negative
33    flag = out_channel.send(buf, flag);
34    if (flag < 0) {
35      std::cout << "Model A: Error sending output." << std::endl;
36      break;
37    }
38
39  }
40  
41  return 0;
42}

 1#include <iostream>
 2// Include methods for input/output channels
 3#include "YggInterface.hpp"
 4
 5#define MYBUFSIZ 1000
 6
 7int main(int argc, char *argv[]) {
 8  // Initialize input/output channels
 9  YggInput in_channel("inputB");
10  YggOutput out_channel("outputB");
11
12  // Declare resulting variables and create buffer for received message
13  int flag = 1;
14  char buf[MYBUFSIZ];
15
16  // Loop until there is no longer input or the queues are closed
17  while (flag >= 0) {
18  
19    // Receive input from input channel
20    // If there is an error, the flag will be negative
21    // Otherwise, it is the size of the received message
22    flag = in_channel.recv(buf, MYBUFSIZ);
23    if (flag < 0) {
24      std::cout << "Model B: No more input." << std::endl;
25      break;
26    }
27
28    // Print received message
29    std::cout << "Model B: " << buf << std::endl;
30
31    // Send output to output channel
32    // If there is an error, the flag will be negative
33    flag = out_channel.send(buf, flag);
34    if (flag < 0) {
35      std::cout << "Model B: Error sending output." << std::endl;
36      break;
37    }
38
39  }
40  
41  return 0;
42}

Model YAML:

 1models:
 2  - name: cpp_modelA
 3    language: c++
 4    args: ./src/gs_lesson4b_modelA.cpp
 5
 6    inputs:
 7      - name: inputA
 8        driver: FileInputDriver
 9        args: ./Input/input.txt
10
11    outputs:
12      - name: outputA
13        driver: OutputDriver  # Output to another channel
14        args: A_to_B  # Connection to inputB
15
16  - name: cpp_modelB
17    language: c++
18    args: ./src/gs_lesson4b_modelB.cpp
19
20    inputs:
21      - name: inputB
22        driver: InputDriver  # Input from another channel
23        args: A_to_B  # Conneciton to inputA
24
25    outputs:
26      - name: outputB
27        driver: FileOutputDriver
28        args: ./output.txt

Fortran Version

Model Code:

 1PROGRAM main
 2  ! Include methods for input/output channels
 3  USE fygg
 4
 5  ! Declare resulting variables and create buffer for received message
 6  logical :: flag = .true.
 7  integer :: bufsiz
 8  character(len = 1000) :: buf
 9  TYPE(yggcomm) :: in_channel, out_channel
10
11  ! Initialize input/output channels
12  in_channel = ygg_input("inputA")
13  out_channel = ygg_output("outputA")
14
15  ! Loop until there is no longer input or the queues are closed
16  DO WHILE (flag)
17  
18     ! Receive input from input channel
19     ! If there is an error, the flag will be negative
20     ! Otherwise, it is the size of the received message
21     bufsiz = len(buf)
22     flag = ygg_recv(in_channel, buf, bufsiz)
23     IF (.not.flag) THEN
24        PRINT *, "Model A: No more input."
25        EXIT
26     END IF
27
28     ! Print received message
29     PRINT *, "Model A: ", buf
30
31     ! Send output to output channel
32     ! If there is an error, the flag will be negative
33     flag = ygg_send(out_channel, buf, bufsiz)
34     IF (.not.flag) THEN
35        PRINT *, "Model A: Error sending output."
36        EXIT
37     END IF
38
39  END DO
40
41END PROGRAM main

 1PROGRAM main
 2  ! Include methods for input/output channels
 3  USE fygg
 4
 5  ! Declare resulting variables and create buffer for received message
 6  logical :: flag = .true.
 7  integer :: bufsiz
 8  character(len = 1000) :: buf
 9  TYPE(yggcomm) :: in_channel, out_channel
10
11  ! Initialize input/output channels
12  in_channel = ygg_input("inputB")
13  out_channel = ygg_output("outputB")
14
15  ! Loop until there is no longer input or the queues are closed
16  DO WHILE (flag)
17  
18     ! Receive input from input channel
19     ! If there is an error, the flag will be negative
20     ! Otherwise, it is the size of the received message
21     bufsiz = len(buf)
22     flag = ygg_recv(in_channel, buf, bufsiz)
23     IF (.not.flag) THEN
24        PRINT *, "Model B: No more input."
25        EXIT
26     END IF
27
28     ! Print received message
29     PRINT *, "Model B: ", buf
30
31     ! Send output to output channel
32     ! If there is an error, the flag will be negative
33     flag = ygg_send(out_channel, buf, bufsiz)
34     IF (.not.flag) THEN
35        PRINT *, "Model B: Error sending output."
36        EXIT
37     END IF
38
39  END DO
40
41END PROGRAM main

Model YAML:

 1models:
 2  - name: fortran_modelA
 3    language: fortran
 4    args: ./src/gs_lesson4b_modelA.f90
 5
 6    inputs:
 7      - name: inputA
 8        driver: FileInputDriver
 9        args: ./Input/input.txt
10
11    outputs:
12      - name: outputA
13        driver: OutputDriver  # Output to another channel
14        args: A_to_B  # Connection to inputB
15
16  - name: fortran_modelB
17    language: fortran
18    args: ./src/gs_lesson4b_modelB.f90
19
20    inputs:
21      - name: inputB
22        driver: InputDriver  # Input from another channel
23        args: A_to_B  # Conneciton to inputA
24
25    outputs:
26      - name: outputB
27        driver: FileOutputDriver
28        args: ./output.txt

Julia Version

Model Code:

 1# Import library for input/output channels
 2using Yggdrasil
 3using Printf
 4
 5# Initialize input/output channels
 6in_channel = Yggdrasil.YggInterface("YggInput", "inputA")
 7out_channel = Yggdrasil.YggInterface("YggOutput", "outputA")
 8
 9# Loop until there is no longer input or the queues are closed
10while true
11
12    # Receive input from input channel
13    # If there is an error, the flag will be false
14    flag, msg = in_channel.recv()
15    if (!flag)
16        println("Model A: No more input.")
17	break
18    end
19
20    # Print received message
21    @printf("Model A: %s", msg)
22
23    # Send output to output channel
24    # If there is an error, the flag will be false
25    flag = out_channel.send(msg)
26    if (!flag)
27        error("Model A: Error sending output.")
28    end
29
30end  # while

 1# Import library for input/output channels
 2using Yggdrasil
 3using Printf
 4
 5# Initialize input/output channels
 6in_channel = Yggdrasil.YggInterface("YggInput", "inputB")
 7out_channel = Yggdrasil.YggInterface("YggOutput", "outputB")
 8
 9# Loop until there is no longer input or the queues are closed
10while true
11
12    # Receive input from input channel
13    # If there is an error, the flag will be false
14    flag, msg = in_channel.recv()
15    if (!flag)
16        println("Model B: No more input.")
17	break
18    end
19
20    # Print received message
21    @printf("Model B: %s", msg)
22
23    # Send output to output channel
24    # If there is an error, the flag will be false
25    flag = out_channel.send(msg)
26    if (!flag)
27        error("Model B: Error sending output.")
28    end
29
30end  # while

Model YAML:

 1models:
 2  - name: julia_modelA
 3    language: julia
 4    args: ./src/gs_lesson4b_modelA.jl
 5
 6    inputs:
 7      - name: inputA
 8        driver: FileInputDriver
 9        args: ./Input/input.txt
10
11    outputs:
12      - name: outputA
13        driver: OutputDriver  # Output to another channel
14        args: A_to_B  # Connection to inputB
15
16  - name: julia_modelB
17    language: julia
18    args: ./src/gs_lesson4b_modelB.jl
19
20    inputs:
21      - name: inputB
22        driver: InputDriver  # Input from another channel
23        args: A_to_B  # Conneciton to inputA
24
25    outputs:
26      - name: outputB
27        driver: FileOutputDriver
28        args: ./output.txt

Matlab Version

Model Code:

 1% Initialize input/output channels 
 2in_channel = YggInterface('YggInput', 'inputA');
 3out_channel = YggInterface('YggOutput', 'outputA');
 4
 5flag = true;
 6
 7% Loop until there is no longer input or the queues are closed
 8while flag
 9
10  % Receive input from input channel
11  % If there is an error, the flag will be False.
12  [flag, msg] = in_channel.recv();
13  if (~flag)
14    disp('Model A: No more input.');
15    break;
16  end;
17
18  % Print received message
19  fprintf('Model A: %s\n', char(msg));
20
21  % Send output to output channel
22  % If there is an error, the flag will be False
23  flag = out_channel.send(msg);
24  if (~flag)
25    error('Model A: Error sending output.');
26    break;
27  end;
28  
29end;

 1% Initialize input/output channels 
 2in_channel = YggInterface('YggInput', 'inputB');
 3out_channel = YggInterface('YggOutput', 'outputB');
 4
 5flag = true;
 6
 7% Loop until there is no longer input or the queues are closed
 8while flag
 9
10  % Receive input from input channel
11  % If there is an error, the flag will be False.
12  [flag, msg] = in_channel.recv();
13  if (~flag)
14    disp('Model B: No more input.');
15    break;
16  end;
17
18  % Print received message
19  fprintf('Model B: %s\n', char(msg));
20
21  % Send output to output channel
22  % If there is an error, the flag will be False
23  flag = out_channel.send(msg);
24  if (~flag)
25    error('Model B: Error sending output.');
26    break;
27  end;
28  
29end;

Model YAML:

 1models:
 2  - name: matlab_modelA
 3    language: matlab
 4    args: ./src/gs_lesson4b_modelA.m
 5
 6    inputs:
 7      - name: inputA
 8        driver: FileInputDriver
 9        args: ./Input/input.txt
10
11    outputs:
12      - name: outputA
13        driver: OutputDriver  # Output to another channel
14        args: A_to_B  # Conneciton to inputB
15
16  - name: matlab_modelB
17    language: matlab
18    args: ./src/gs_lesson4b_modelB.m
19
20    inputs:
21      - name: inputB
22        driver: InputDriver  # Input from another channel
23        args: A_to_B  # Conneciton to inputA
24
25    outputs:
26      - name: outputB
27        driver: FileOutputDriver
28        args: ./output.txt

Python Version

Model Code:

 1# Import classes for input/output channels
 2from yggdrasil.interface.YggInterface import YggInput, YggOutput
 3
 4# Initialize input/output channels
 5in_channel = YggInput('inputA')
 6out_channel = YggOutput('outputA')
 7
 8# Loop until there is no longer input or the queues are closed
 9while True:
10
11    # Receive input from input channel
12    # If there is an error, the flag will be False
13    flag, msg = in_channel.recv()
14    if not flag:
15        print("Model A: No more input.")
16        break
17
18    # Print received message
19    print('Model A: %s' % msg)
20
21    # Send output to output channel
22    # If there is an error, the flag will be False
23    flag = out_channel.send(msg)
24    if not flag:
25        raise RuntimeError("Model A: Error sending output.")

 1# Import classes for input/output channels
 2from yggdrasil.interface.YggInterface import YggInput, YggOutput
 3
 4# Initialize input/output channels
 5in_channel = YggInput('inputB')
 6out_channel = YggOutput('outputB')
 7
 8# Loop until there is no longer input or the queues are closed
 9while True:
10
11    # Receive input from input channel
12    # If there is an error, the flag will be False
13    flag, msg = in_channel.recv()
14    if not flag:
15        print("Model B: No more input.")
16        break
17
18    # Print received message
19    print('Model B: %s' % msg)
20
21    # Send output to output channel
22    # If there is an error, the flag will be False
23    flag = out_channel.send(msg)
24    if not flag:
25        raise RuntimeError("Model B: Error sending output.")

Model YAML:

 1models:
 2  - name: python_modelA
 3    language: python
 4    args: ./src/gs_lesson4b_modelA.py
 5
 6    inputs:
 7      - name: inputA
 8        driver: FileInputDriver
 9        args: ./Input/input.txt
10
11    outputs:
12      - name: outputA
13        driver: OutputDriver  # Output to another channel
14        args: A_to_B  # Connection to inputB
15
16  - name: python_modelB
17    language: python
18    args: ./src/gs_lesson4b_modelB.py
19
20    inputs:
21      - name: inputB
22        driver: InputDriver  # Input from another channel
23        args: A_to_B  # Conneciton to inputA
24
25    outputs:
26      - name: outputB
27        driver: FileOutputDriver
28        args: ./output.txt

R Version

Model Code:

 1# Import library for input/output
 2library(yggdrasil)
 3
 4# Initialize input/output channels
 5in_channel <- YggInterface('YggInput', 'inputA')
 6out_channel <- YggInterface('YggOutput', 'outputA')
 7
 8# Loop until there is no longer input or the queues are closed
 9while(TRUE) {
10
11  # Receive input from input channel
12  # If there is an error, the flag will be False
13  c(flag, msg) %<-% in_channel$recv()
14  if (!flag) {
15    print('Model A: No more input.')
16    break
17  }
18
19  # Print received message
20  fprintf('Model A: %s', msg)
21
22  # Send output to output channel
23  # If there is an error, the flag will be False
24  flag = out_channel$send(msg)
25  if (!flag) {
26    stop('Model A: Error sending output.')
27  }
28
29}

 1# Import library for input/output
 2library(yggdrasil)
 3
 4# Initialize input/output channels
 5in_channel <- YggInterface('YggInput', 'inputB')
 6out_channel <- YggInterface('YggOutput', 'outputB')
 7
 8# Loop until there is no longer input or the queues are closed
 9while(TRUE) {
10
11  # Receive input from input channel
12  # If there is an error, the flag will be False
13  c(flag, msg) %<-% in_channel$recv()
14  if (!flag) {
15    print('Model B: No more input.')
16    break
17  }
18
19  # Print received message
20  fprintf('Model B: %s', msg)
21
22  # Send output to output channel
23  # If there is an error, the flag will be False
24  flag = out_channel$send(msg)
25  if (!flag) {
26    stop('Model B: Error sending output.')
27  }
28
29}

Model YAML:

 1models:
 2  - name: R_modelA
 3    language: R
 4    args: ./src/gs_lesson4b_modelA.R
 5
 6    inputs:
 7      - name: inputA
 8        driver: FileInputDriver
 9        args: ./Input/input.txt
10
11    outputs:
12      - name: outputA
13        driver: OutputDriver  # Output to another channel
14        args: A_to_B  # Connection to inputB
15
16  - name: R_modelB
17    language: R
18    args: ./src/gs_lesson4b_modelB.R
19
20    inputs:
21      - name: inputB
22        driver: InputDriver  # Input from another channel
23        args: A_to_B  # Conneciton to inputA
24
25    outputs:
26      - name: outputB
27        driver: FileOutputDriver
28        args: ./output.txt