/*
 *
 * Licensed to the Apache Software Foundation (ASF) under one
 * or more contributor license agreements.  See the NOTICE file
 * distributed with this work for additional information
 * regarding copyright ownership.  The ASF licenses this file
 * to you 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.
 *
 */
#include "MultiVersionConnectionInputHandler.h"
#include "Connection.h"
#include "PreviewConnection.h"
#include "qpid/framing/reply_exceptions.h"

namespace qpid {
namespace broker {

MultiVersionConnectionInputHandler::MultiVersionConnectionInputHandler(
    qpid::sys::ConnectionOutputHandler* _out, 
    Broker& _broker, 
    const std::string& _id) : linkVersion(99,0), out(_out), broker(_broker), id(_id) {}

void MultiVersionConnectionInputHandler::received(qpid::framing::AMQFrame& f)
{
    check();
    handler->received(f);
}

void MultiVersionConnectionInputHandler::idleOut()
{
    check();
    handler->idleOut();
}

void MultiVersionConnectionInputHandler::idleIn()
{
    check();
    handler->idleIn();
}

bool MultiVersionConnectionInputHandler::doOutput()
{
    return handler.get() &&  handler->doOutput();
}
    
void MultiVersionConnectionInputHandler::closed()
{
    if (handler.get()) handler->closed();
    //else closed before initiated, nothing to do
}

void MultiVersionConnectionInputHandler::check()
{
    if (!handler.get()) { 
        throw qpid::framing::InternalErrorException("Handler not initialised!");
    }
}

}
}