165953da4636fbf5f0a24b8f5f2b5fa7d76ff13d9Marius Renn/*
265953da4636fbf5f0a24b8f5f2b5fa7d76ff13d9Marius Renn * Copyright (C) 2011 The Android Open Source Project
365953da4636fbf5f0a24b8f5f2b5fa7d76ff13d9Marius Renn *
465953da4636fbf5f0a24b8f5f2b5fa7d76ff13d9Marius Renn * Licensed under the Apache License, Version 2.0 (the "License");
565953da4636fbf5f0a24b8f5f2b5fa7d76ff13d9Marius Renn * you may not use this file except in compliance with the License.
665953da4636fbf5f0a24b8f5f2b5fa7d76ff13d9Marius Renn * You may obtain a copy of the License at
765953da4636fbf5f0a24b8f5f2b5fa7d76ff13d9Marius Renn *
865953da4636fbf5f0a24b8f5f2b5fa7d76ff13d9Marius Renn *      http://www.apache.org/licenses/LICENSE-2.0
965953da4636fbf5f0a24b8f5f2b5fa7d76ff13d9Marius Renn *
1065953da4636fbf5f0a24b8f5f2b5fa7d76ff13d9Marius Renn * Unless required by applicable law or agreed to in writing, software
1165953da4636fbf5f0a24b8f5f2b5fa7d76ff13d9Marius Renn * distributed under the License is distributed on an "AS IS" BASIS,
1265953da4636fbf5f0a24b8f5f2b5fa7d76ff13d9Marius Renn * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
1365953da4636fbf5f0a24b8f5f2b5fa7d76ff13d9Marius Renn * See the License for the specific language governing permissions and
1465953da4636fbf5f0a24b8f5f2b5fa7d76ff13d9Marius Renn * limitations under the License.
1565953da4636fbf5f0a24b8f5f2b5fa7d76ff13d9Marius Renn */
1665953da4636fbf5f0a24b8f5f2b5fa7d76ff13d9Marius Renn
1765953da4636fbf5f0a24b8f5f2b5fa7d76ff13d9Marius Renn
1865953da4636fbf5f0a24b8f5f2b5fa7d76ff13d9Marius Rennpackage android.filterfw.core;
1965953da4636fbf5f0a24b8f5f2b5fa7d76ff13d9Marius Renn
2065953da4636fbf5f0a24b8f5f2b5fa7d76ff13d9Marius Renn/**
2165953da4636fbf5f0a24b8f5f2b5fa7d76ff13d9Marius Renn * @hide
2265953da4636fbf5f0a24b8f5f2b5fa7d76ff13d9Marius Renn */
2365953da4636fbf5f0a24b8f5f2b5fa7d76ff13d9Marius Rennpublic abstract class InputPort extends FilterPort {
2465953da4636fbf5f0a24b8f5f2b5fa7d76ff13d9Marius Renn
2565953da4636fbf5f0a24b8f5f2b5fa7d76ff13d9Marius Renn    protected OutputPort mSourcePort;
2665953da4636fbf5f0a24b8f5f2b5fa7d76ff13d9Marius Renn
2765953da4636fbf5f0a24b8f5f2b5fa7d76ff13d9Marius Renn    public InputPort(Filter filter, String name) {
2865953da4636fbf5f0a24b8f5f2b5fa7d76ff13d9Marius Renn        super(filter, name);
2965953da4636fbf5f0a24b8f5f2b5fa7d76ff13d9Marius Renn    }
3065953da4636fbf5f0a24b8f5f2b5fa7d76ff13d9Marius Renn
3165953da4636fbf5f0a24b8f5f2b5fa7d76ff13d9Marius Renn    public void setSourcePort(OutputPort source) {
3265953da4636fbf5f0a24b8f5f2b5fa7d76ff13d9Marius Renn        if (mSourcePort != null) {
3365953da4636fbf5f0a24b8f5f2b5fa7d76ff13d9Marius Renn            throw new RuntimeException(this + " already connected to " + mSourcePort + "!");
3465953da4636fbf5f0a24b8f5f2b5fa7d76ff13d9Marius Renn        }
3565953da4636fbf5f0a24b8f5f2b5fa7d76ff13d9Marius Renn        mSourcePort = source;
3665953da4636fbf5f0a24b8f5f2b5fa7d76ff13d9Marius Renn    }
3765953da4636fbf5f0a24b8f5f2b5fa7d76ff13d9Marius Renn
3865953da4636fbf5f0a24b8f5f2b5fa7d76ff13d9Marius Renn    public boolean isConnected() {
3965953da4636fbf5f0a24b8f5f2b5fa7d76ff13d9Marius Renn        return mSourcePort != null;
4065953da4636fbf5f0a24b8f5f2b5fa7d76ff13d9Marius Renn    }
4165953da4636fbf5f0a24b8f5f2b5fa7d76ff13d9Marius Renn
4265953da4636fbf5f0a24b8f5f2b5fa7d76ff13d9Marius Renn    public void open() {
4365953da4636fbf5f0a24b8f5f2b5fa7d76ff13d9Marius Renn        super.open();
4465953da4636fbf5f0a24b8f5f2b5fa7d76ff13d9Marius Renn        if (mSourcePort != null && !mSourcePort.isOpen()) {
4565953da4636fbf5f0a24b8f5f2b5fa7d76ff13d9Marius Renn            mSourcePort.open();
4665953da4636fbf5f0a24b8f5f2b5fa7d76ff13d9Marius Renn        }
4765953da4636fbf5f0a24b8f5f2b5fa7d76ff13d9Marius Renn    }
4865953da4636fbf5f0a24b8f5f2b5fa7d76ff13d9Marius Renn
4965953da4636fbf5f0a24b8f5f2b5fa7d76ff13d9Marius Renn    public void close() {
5065953da4636fbf5f0a24b8f5f2b5fa7d76ff13d9Marius Renn        if (mSourcePort != null && mSourcePort.isOpen()) {
5165953da4636fbf5f0a24b8f5f2b5fa7d76ff13d9Marius Renn            mSourcePort.close();
5265953da4636fbf5f0a24b8f5f2b5fa7d76ff13d9Marius Renn        }
5365953da4636fbf5f0a24b8f5f2b5fa7d76ff13d9Marius Renn        super.close();
5465953da4636fbf5f0a24b8f5f2b5fa7d76ff13d9Marius Renn    }
5565953da4636fbf5f0a24b8f5f2b5fa7d76ff13d9Marius Renn
5665953da4636fbf5f0a24b8f5f2b5fa7d76ff13d9Marius Renn    public OutputPort getSourcePort() {
5765953da4636fbf5f0a24b8f5f2b5fa7d76ff13d9Marius Renn        return mSourcePort;
5865953da4636fbf5f0a24b8f5f2b5fa7d76ff13d9Marius Renn    }
5965953da4636fbf5f0a24b8f5f2b5fa7d76ff13d9Marius Renn
6065953da4636fbf5f0a24b8f5f2b5fa7d76ff13d9Marius Renn    public Filter getSourceFilter() {
6165953da4636fbf5f0a24b8f5f2b5fa7d76ff13d9Marius Renn        return mSourcePort == null ? null : mSourcePort.getFilter();
6265953da4636fbf5f0a24b8f5f2b5fa7d76ff13d9Marius Renn    }
6365953da4636fbf5f0a24b8f5f2b5fa7d76ff13d9Marius Renn
6465953da4636fbf5f0a24b8f5f2b5fa7d76ff13d9Marius Renn    public FrameFormat getSourceFormat() {
6565953da4636fbf5f0a24b8f5f2b5fa7d76ff13d9Marius Renn        return mSourcePort != null ? mSourcePort.getPortFormat() : getPortFormat();
6665953da4636fbf5f0a24b8f5f2b5fa7d76ff13d9Marius Renn    }
6765953da4636fbf5f0a24b8f5f2b5fa7d76ff13d9Marius Renn
6865953da4636fbf5f0a24b8f5f2b5fa7d76ff13d9Marius Renn    public Object getTarget() {
6965953da4636fbf5f0a24b8f5f2b5fa7d76ff13d9Marius Renn        return null;
7065953da4636fbf5f0a24b8f5f2b5fa7d76ff13d9Marius Renn    }
7165953da4636fbf5f0a24b8f5f2b5fa7d76ff13d9Marius Renn
7265953da4636fbf5f0a24b8f5f2b5fa7d76ff13d9Marius Renn    public boolean filterMustClose() {
7365953da4636fbf5f0a24b8f5f2b5fa7d76ff13d9Marius Renn        return !isOpen() && isBlocking() && !hasFrame();
7465953da4636fbf5f0a24b8f5f2b5fa7d76ff13d9Marius Renn    }
7565953da4636fbf5f0a24b8f5f2b5fa7d76ff13d9Marius Renn
7665953da4636fbf5f0a24b8f5f2b5fa7d76ff13d9Marius Renn    public boolean isReady() {
7765953da4636fbf5f0a24b8f5f2b5fa7d76ff13d9Marius Renn        return hasFrame() || !isBlocking();
7865953da4636fbf5f0a24b8f5f2b5fa7d76ff13d9Marius Renn    }
7965953da4636fbf5f0a24b8f5f2b5fa7d76ff13d9Marius Renn
8065953da4636fbf5f0a24b8f5f2b5fa7d76ff13d9Marius Renn    public boolean acceptsFrame() {
8165953da4636fbf5f0a24b8f5f2b5fa7d76ff13d9Marius Renn        return !hasFrame();
8265953da4636fbf5f0a24b8f5f2b5fa7d76ff13d9Marius Renn    }
8365953da4636fbf5f0a24b8f5f2b5fa7d76ff13d9Marius Renn
8465953da4636fbf5f0a24b8f5f2b5fa7d76ff13d9Marius Renn    public abstract void transfer(FilterContext context);
8565953da4636fbf5f0a24b8f5f2b5fa7d76ff13d9Marius Renn}
86