formatted_io6¶
Two models, A & B, that send/receive 3D mesh data as Wavefront Obj meshes. 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.
C Version¶
Model Code:
1#include <stdio.h>
2// Include methods for input/output channels
3#include "YggInterface.h"
4
5int main(int argc, char *argv[]) {
6 // Initialize input/output channels
7 yggObjInput_t in_channel = yggObjInput("inputA");
8 yggObjOutput_t out_channel = yggObjOutput("outputA");
9
10 // Declare resulting variables and create buffer for received message
11 int flag = 1;
12 obj_t p = init_obj();
13
14 // Loop until there is no longer input or the queues are closed
15 while (flag >= 0) {
16
17 // Receive input from input channel
18 // If there is an error, the flag will be negative
19 // Otherwise, it is the size of the received message
20 flag = yggRecv(in_channel, &p);
21 if (flag < 0) {
22 printf("Model A: No more input.\n");
23 break;
24 }
25
26 // Print received message
27 printf("Model A: (%d verts, %d faces)\n", p.nvert, p.nface);
28 display_obj_indent(p, " ");
29
30 // Send output to output channel
31 // If there is an error, the flag will be negative
32 flag = yggSend(out_channel, p);
33 if (flag < 0) {
34 printf("Model A: Error sending output.\n");
35 break;
36 }
37
38 }
39
40 // Free dynamically allocated obj structure
41 free_obj(&p);
42
43 return 0;
44}
45
1#include <stdio.h>
2// Include methods for input/output channels
3#include "YggInterface.h"
4
5int main(int argc, char *argv[]) {
6 // Initialize input/output channels
7 yggObjInput_t in_channel = yggObjInput("inputB");
8 yggObjOutput_t out_channel = yggObjOutput("outputB");
9
10 // Declare resulting variables and create buffer for received message
11 int flag = 1;
12 obj_t p = init_obj();
13
14 // Loop until there is no longer input or the queues are closed
15 while (flag >= 0) {
16
17 // Receive input from input channel
18 // If there is an error, the flag will be negative
19 // Otherwise, it is the size of the received message
20 flag = yggRecv(in_channel, &p);
21 if (flag < 0) {
22 printf("Model B: No more input.\n");
23 break;
24 }
25
26 // Print received message
27 printf("Model B: (%d verts, %d faces)\n", p.nvert, p.nface);
28 display_obj_indent(p, " ");
29
30 // Send output to output channel
31 // If there is an error, the flag will be negative
32 flag = yggSend(out_channel, p);
33 if (flag < 0) {
34 printf("Model B: Error sending output.\n");
35 break;
36 }
37
38 }
39
40 // Free dynamically allocated obj structure
41 free_obj(&p);
42
43 return 0;
44}
45
Model YAML:
1models:
2 - name: c_modelA
3 language: c
4 args: ./src/formatted_io6_modelA.c
5 inputs: inputA
6 outputs: outputA
7
8 - name: c_modelB
9 language: c
10 args: ./src/formatted_io6_modelB.c
11 inputs: inputB
12 outputs: outputB
13
14connections:
15 - input: outputA # Connection between model A output & model B input
16 output: inputB
17 - input: ./Input/input.obj # Connection between file and model A input
18 output: inputA
19 filetype: obj
20 - input: outputB # Connection between model B output and file
21 output: ./output.obj
22 filetype: obj
C++ Version¶
Model Code:
1#include <iostream>
2// Include methods for input/output channels
3#include "YggInterface.hpp"
4
5int main(int argc, char *argv[]) {
6 // Initialize input/output channels
7 YggObjInput in_channel("inputA");
8 YggObjOutput out_channel("outputA");
9
10 // Declare resulting variables and create buffer for received message
11 int flag = 1;
12 obj_t p = init_obj();
13
14 // Loop until there is no longer input or the queues are closed
15 while (flag >= 0) {
16
17 // Receive input from input channel
18 // If there is an error, the flag will be negative
19 // Otherwise, it is the size of the received message
20 flag = in_channel.recv(1, &p);
21 if (flag < 0) {
22 std::cout << "Model A: No more input." << std::endl;
23 break;
24 }
25
26 // Print received message
27 printf("Model A: (%d verts, %d faces)\n", p.nvert, p.nface);
28 display_obj_indent(p, " ");
29
30 // Send output to output channel
31 // If there is an error, the flag will be negative
32 flag = out_channel.send(1, p);
33 if (flag < 0) {
34 std::cout << "Model A: Error sending output." << std::endl;
35 break;
36 }
37
38 }
39
40 // Free dynamically allocated structure
41 free_obj(&p);
42
43 return 0;
44}
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 YggObjInput in_channel("inputB");
10 YggObjOutput out_channel("outputB");
11
12 // Declare resulting variables and create buffer for received message
13 int flag = 1;
14 obj_t p = init_obj();
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(1, &p);
23 if (flag < 0) {
24 std::cout << "Model B: No more input." << std::endl;
25 break;
26 }
27
28 // Print received message
29 printf("Model B: (%d verts, %d faces)\n", p.nvert, p.nface);
30 display_obj_indent(p, " ");
31
32 // Send output to output channel
33 // If there is an error, the flag will be negative
34 flag = out_channel.send(1, p);
35 if (flag < 0) {
36 std::cout << "Model B: Error sending output." << std::endl;
37 break;
38 }
39
40 }
41
42 // Free dynamically allocated structure
43 free_obj(&p);
44
45 return 0;
46}
Model YAML:
1models:
2 - name: cpp_modelA
3 language: c++
4 args: ./src/formatted_io6_modelA.cpp
5 inputs: inputA
6 outputs: outputA
7
8 - name: cpp_modelB
9 language: c++
10 args: ./src/formatted_io6_modelB.cpp
11 inputs: inputB
12 outputs: outputB
13
14connections:
15 - input: outputA # Connection between model A output & model B input
16 output: inputB
17 - input: ./Input/input.obj # Connection between file and model A input
18 output: inputA
19 filetype: obj
20 - input: outputB # Connection between model B output and file
21 output: ./output.obj
22 filetype: obj
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 type(yggcomm) :: in_channel, out_channel
8 type(yggobj) :: p
9 p = init_obj()
10
11 ! initialize input/output channels
12 in_channel = ygg_obj_input("inputA")
13 out_channel = ygg_obj_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 number of variables filled
21 flag = ygg_recv_var(in_channel, yggarg(p))
22 if (.not.flag) then
23 print *, "Model A: No more input."
24 exit
25 end if
26
27 ! Print received message
28 print *, "Model A: (", p%nvert, " verts, ", p%nface, " faces)"
29 call display_obj_indent(p, " ")
30
31 ! Send output to output channel
32 ! If there is an error, the flag will be negative
33 flag = ygg_send_var(out_channel, yggarg(p))
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 type(yggcomm) :: in_channel, out_channel
8 type(yggobj) :: p
9 p = init_obj()
10
11 ! initialize input/output channels
12 in_channel = ygg_obj_input("inputB")
13 out_channel = ygg_obj_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 number of variables filled
21 flag = ygg_recv_var(in_channel, yggarg(p))
22 if (.not.flag) then
23 print *, "Model B: No more input."
24 exit
25 end if
26
27 ! Print received message
28 print *, "Model B: (", p%nvert, " verts, ", p%nface, " faces)"
29 call display_obj_indent(p, " ")
30
31 ! Send output to output channel
32 ! If there is an error, the flag will be negative
33 flag = ygg_send_var(out_channel, yggarg(p))
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/formatted_io6_modelA.f90
5 inputs: inputA
6 outputs: outputA
7
8 - name: fortran_modelB
9 language: fortran
10 args: ./src/formatted_io6_modelB.f90
11 inputs: inputB
12 outputs: outputB
13
14connections:
15 - input: outputA # Connection between model A output & model B input
16 output: inputB
17 - input: ./Input/input.obj # Connection between file and model A input
18 output: inputA
19 filetype: obj
20 - input: outputB # Connection between model B output and file
21 output: ./output.obj
22 filetype: obj
Matlab Version¶
Model Code:
1% Initialize input/output channels
2in_channel = YggInterface('YggObjInput', 'inputA');
3out_channel = YggInterface('YggObjOutput', '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, obj] = 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: (%d verts, %d faces)\n', ...
20 length(obj('vertices')), length(obj('faces')));
21 disp(obj);
22
23 % Send output to output channel
24 % If there is an error, the flag will be False
25 flag = out_channel.send(obj);
26 if (~flag)
27 error('Model A: Error sending output.');
28 break;
29 end;
30
31end;
1% Initialize input/output channels
2in_channel = YggInterface('YggObjInput', 'inputB');
3out_channel = YggInterface('YggObjOutput', '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, obj] = 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: (%d verts, %d faces)\n', ...
20 length(obj('vertices')), length(obj('faces')));
21 disp(obj);
22
23 % Send output to output channel
24 % If there is an error, the flag will be False
25 flag = out_channel.send(obj);
26 if (~flag)
27 error('Model B: Error sending output.');
28 break;
29 end;
30
31end;
Model YAML:
1models:
2 - name: matlab_modelA
3 language: matlab
4 args: ./src/formatted_io6_modelA.m
5 inputs: inputA
6 outputs: outputA
7
8 - name: matlab_modelB
9 language: matlab
10 args: ./src/formatted_io6_modelB.m
11 inputs: inputB
12 outputs: outputB
13
14connections:
15 - input: outputA # Connection between model A output & model B input
16 output: inputB
17 - input: ./Input/input.obj # Connection between file and model A input
18 output: inputA
19 filetype: obj
20 - input: outputB # Connection between model B output and file
21 output: ./output.obj
22 filetype: obj
Python Version¶
Model Code:
1import pprint
2# Import classes for input/output channels
3from yggdrasil.interface.YggInterface import (
4 YggObjInput, YggObjOutput)
5
6# Initialize input/output channels
7in_channel = YggObjInput('inputA')
8out_channel = YggObjOutput('outputA')
9
10# Loop until there is no longer input or the queues are closed
11while True:
12
13 # Receive input from input channel
14 # If there is an error, the flag will be False
15 flag, obj = in_channel.recv()
16 if not flag:
17 print("Model A: No more input.")
18 break
19
20 # Print received message
21 print('Model A: (%d verts, %d faces)' % (obj.nvert, obj.nface))
22 pprint.pprint(obj)
23
24 # Send output to output channel
25 # If there is an error, the flag will be False
26 flag = out_channel.send(obj)
27 if not flag:
28 raise RuntimeError("Model A: Error sending output.")
1import pprint
2# Import classes for input/output channels
3from yggdrasil.interface.YggInterface import (
4 YggObjInput, YggObjOutput)
5
6# Initialize input/output channels
7in_channel = YggObjInput('inputB')
8out_channel = YggObjOutput('outputB')
9
10# Loop until there is no longer input or the queues are closed
11while True:
12
13 # Receive input from input channel
14 # If there is an error, the flag will be False
15 flag, obj = in_channel.recv()
16 if not flag:
17 print("Model B: No more input.")
18 break
19
20 # Print received message
21 print('Model B: (%d verts, %d faces)' % (obj.nvert, obj.nface))
22 pprint.pprint(obj)
23
24 # Send output to output channel
25 # If there is an error, the flag will be False
26 flag = out_channel.send(obj)
27 if not flag:
28 raise RuntimeError("Model B: Error sending output.")
Model YAML:
1models:
2 - name: python_modelA
3 language: python
4 args: ./src/formatted_io6_modelA.py
5 inputs: inputA
6 outputs: outputA
7
8 - name: python_modelB
9 language: python
10 args: ./src/formatted_io6_modelB.py
11 inputs: inputB
12 outputs: outputB
13
14connections:
15 - input: outputA # Connection between model A output & model B input
16 output: inputB
17 - input: ./Input/input.obj # Connection between file and model A input
18 output: inputA
19 filetype: obj
20 - input: outputB # Connection between model B output and file
21 output: ./output.obj
22 filetype: obj
R Version¶
Model Code:
1# Import library for input/output
2library(yggdrasil)
3
4# Initialize input/output channels
5in_channel <- YggInterface('YggObjInput', 'inputA')
6out_channel <- YggInterface('YggObjOutput', '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, obj) %<-% 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: (%d verts, %d faces)',
21 length(obj[['vertices']]), length(obj[['faces']]))
22
23 # Send output to output channel
24 # If there is an error, the flag will be False
25 flag = out_channel$send(obj)
26 if (!flag) {
27 stop('Model A: Error sending output.')
28 }
29
30}
1# Import library for input/output
2library(yggdrasil)
3
4# Initialize input/output channels
5in_channel <- YggInterface('YggObjInput', 'inputB')
6out_channel <- YggInterface('YggObjOutput', '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, obj) %<-% 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: (%d verts, %d faces)',
21 length(obj[['vertices']]), length(obj[['faces']]))
22
23 # Send output to output channel
24 # If there is an error, the flag will be False
25 flag = out_channel$send(obj)
26 if (!flag) {
27 stop('Model B: Error sending output.')
28 }
29
30}
Model YAML:
1models:
2 - name: R_modelA
3 language: R
4 args: ./src/formatted_io6_modelA.R
5 inputs: inputA
6 outputs: outputA
7
8 - name: R_modelB
9 language: R
10 args: ./src/formatted_io6_modelB.R
11 inputs: inputB
12 outputs: outputB
13
14connections:
15 - input: outputA # Connection between model A output & model B input
16 output: inputB
17 - input: ./Input/input.obj # Connection between file and model A input
18 output: inputA
19 filetype: obj
20 - input: outputB # Connection between model B output and file
21 output: ./output.obj
22 filetype: obj