| // 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. |
| package common; |
| |
| import java.awt.image.DataBufferInt; |
| import java.util.Arrays; |
| |
| import streamer.BaseElement; |
| import streamer.ByteBuffer; |
| import streamer.Element; |
| import streamer.Link; |
| |
| public class BufferedImageCopyRectAdapter extends BaseElement { |
| |
| public static final String SRC_X = "srcX"; |
| public static final String SRC_Y = "srcY"; |
| public static final String TARGET_X = "x"; |
| public static final String TARGET_Y = "y"; |
| public static final String WIDTH = "width"; |
| public static final String HEIGHT = "height"; |
| |
| protected BufferedImageCanvas canvas; |
| |
| public BufferedImageCopyRectAdapter(String id, BufferedImageCanvas canvas) { |
| super(id); |
| this.canvas = canvas; |
| declarePads(); |
| } |
| |
| private void declarePads() { |
| inputPads.put(STDIN, null); |
| } |
| |
| @Override |
| public String toString() { |
| return "Renderer(" + id + ")"; |
| } |
| |
| @Override |
| public void handleData(ByteBuffer buf, Link link) { |
| if (buf == null) |
| return; |
| |
| if (verbose) |
| System.out.println("[" + this + "] INFO: Data received: " + buf + "."); |
| |
| int x = (Integer)buf.getMetadata(TARGET_X); |
| int y = (Integer)buf.getMetadata(TARGET_Y); |
| int width = (Integer)buf.getMetadata(WIDTH); |
| int height = (Integer)buf.getMetadata(HEIGHT); |
| int srcX = (Integer)buf.getMetadata(SRC_X); |
| int srcY = (Integer)buf.getMetadata(SRC_Y); |
| buf.unref(); |
| |
| // Copy image |
| canvas.getOfflineGraphics().copyArea(srcX, srcY, width, height, x - srcX, y - srcY); |
| |
| // Request update of repainted area |
| canvas.repaint(x, y, width, height); |
| } |
| |
| public static void main(String args[]) { |
| System.setProperty("streamer.Element.debug", "true"); |
| |
| BufferedImageCanvas canvas = new BufferedImageCanvas(4, 4); |
| |
| Element renderer = new BufferedImageCopyRectAdapter("renderer", canvas); |
| |
| int[] pixelsBeforeCopy = new int[] { |
| // 0 |
| 1, 2, 3, 4, |
| // 1 |
| 5, 6, 7, 8, |
| // 2 |
| 9, 10, 11, 12, |
| // 3 |
| 13, 14, 15, 16}; |
| int[] pixelsAfterCopy = new int[] { |
| // 0 |
| 11, 12, 3, 4, |
| // 1 |
| 15, 16, 7, 8, |
| // 2 |
| 9, 10, 11, 12, |
| // 3 |
| 13, 14, 15, 16}; |
| |
| // Initalize image |
| int[] data = ((DataBufferInt)canvas.getOfflineImage().getRaster().getDataBuffer()).getData(); |
| System.arraycopy(pixelsBeforeCopy, 0, data, 0, pixelsBeforeCopy.length); |
| |
| ByteBuffer buf = new ByteBuffer(new byte[0]); |
| buf.putMetadata(TARGET_X, 0); |
| buf.putMetadata(TARGET_Y, 0); |
| buf.putMetadata(WIDTH, 2); |
| buf.putMetadata(HEIGHT, 2); |
| buf.putMetadata(SRC_X, 2); |
| buf.putMetadata(SRC_Y, 2); |
| |
| renderer.handleData(buf, null); |
| |
| data = ((DataBufferInt)canvas.getOfflineImage().getRaster().getDataBuffer()).getData(); |
| String actualData = Arrays.toString(data); |
| String expectedData = Arrays.toString(pixelsAfterCopy); |
| if (!actualData.equals(expectedData)) |
| System.err.println("Actual image: " + actualData + "\nExpected image: " + expectedData + "."); |
| |
| } |
| |
| } |