source: example/io/tty-echo.cfa@ 7711064

//
// Cforall Version 1.0.0 Copyright (C) 2020 University of Waterloo
//
// The contents of this file are covered under the licence agreement in the
// file "LICENCE" distributed with Cforall.
//
// io.cfa --
//
// Author           : Thierry Delisle
// Created On       : Thu Feb 18 20:31:00 2021
// Last Modified By :
// Last Modified On :
// Update Count     :
//

#include <fstream.hfa>
#include <iofwd.hfa>
#include <time.hfa>
#include <thread.hfa>

thread EchoThread {};
void main(EchoThread & this) {
        char buffer[100];
        for() {
                int ret = cfa_read(0, buffer + 1, 97, 0);
                if(ret < 0) {
                        serr | "Failed to read from fd 0";
                        exit(1);
                }
                if(ret == 0) return;
                buffer[0]     = '\'';
                buffer[ret]   = '\'';
                buffer[ret+1] = '\n';
                ret = cfa_write(1, buffer, ret + 2, 0);
                if(ret < 0) {
                        serr | "Failed to write from fd 1 (ET)";
                        exit(1);
                }
        }
}

thread HeartBeatThread {};
void main(HeartBeatThread & this) {
        for() {
                waitfor( ^?{} : this) {
                        return;
                }
                or else;
                int ret = cfa_write(1, ".", 1, 0);
                if(ret < 0) {
                        serr | "Failed to write from fd 1 (ET)";
                        exit(1);
                }
                sleep(5`s);
        }
}

int main() {
        HeartBeatThread hb;
        {
                EchoThread et;
        }
}