ProxyPipe.h

/*
 * qb - C++ Actor Framework
 * Copyright (C) 2011-2019 isndev (www.qbaf.io). All rights reserved.
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *         http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 *         limitations under the License.
 */

#ifndef QB_PROXYPIPE_H
#define QB_PROXYPIPE_H
# include <qb/system/allocator/pipe.h>
# include "ActorId.h"
# include "Event.h"

namespace qb {
    using Pipe = allocator::pipe<CacheLine>;

    class ProxyPipe {
        Pipe *pipe;
        ActorId dest;
        ActorId source;

    public:
        ProxyPipe() = default;
        ProxyPipe(ProxyPipe const &) = default;
        ProxyPipe &operator=(ProxyPipe const &) = default;

        ProxyPipe(Pipe &i_pipe, ActorId i_dest, ActorId i_source)
                : pipe(&i_pipe), dest(i_dest), source(i_source) {}

        template<typename T, typename ..._Args>
        T &push(_Args &&...args);

        template<typename T, typename ..._Args>
        T &allocated_push(std::size_t size, _Args &&...args);

        inline ActorId getDestination() const {
            return dest;
        }

        inline ActorId getSource() const {
            return source;
        }

    };

} // namespace qb

#endif //QB_PROXYPIPE_H