develop/APipe_8h_source.html

/*

 * AUI Framework - Declarative UI toolkit for modern C++20

 * Copyright (C) 2020-2025 Alex2772 and Contributors

 *

 * SPDX-License-Identifier: MPL-2.0

 *

 * This Source Code Form is subject to the terms of the Mozilla Public

 * License, v. 2.0. If a copy of the MPL was not distributed with this

 * file, You can obtain one at http://mozilla.org/MPL/2.0/.

 */


//

// Created by alex2 on 15.11.2020.

//


#pragma once


#include "IInputStream.h"

#include "IOutputStream.h"


class API_AUI_CORE APipe: public IInputStream, public IOutputStream {

private:

    char mCircularBuffer[0x10000];

    uint16_t mReaderPos = 0;

    uint16_t mWriterPos = 0;


    AMutex mMutex;

    AConditionVariable mConditionVariable;


    bool mClosed = false;


public:

    APipe();

    virtual ~APipe();


    size_t read(char* dst, size_t size) override;

    void write(const char* src, size_t size) override;


    size_t available();


    void close();


};


AConditionVariable
Represents a condition variable.
Definition AConditionVariable.h:24

APipe::write
void write(const char *src, size_t size) override
Writes exact size bytes to stream. Blocking (waiting for write all data) is allowed.

APipe::read
size_t read(char *dst, size_t size) override
Reads up to size bytes from stream. Blocking (waiting for new data) is allowed.

IInputStream
Represents an input stream.
Definition IInputStream.h:26

IOutputStream
Definition IOutputStream.h:18

AMutex
Basic syscall-based synchronization primitive.
Definition AMutex.h:33