1 files changed, 138 insertions, 0 deletions
diff --git a/uitest/src/com/vaadin/tests/push/PushLargeData.java b/uitest/src/com/vaadin/tests/push/PushLargeData.java
new file mode 100644
index 0000000000..8ad005df81
--- /dev/null
+++ b/uitest/src/com/vaadin/tests/push/PushLargeData.java
@@ -0,0 +1,138 @@
+/*
+ * Copyright 2000-2013 Vaadin Ltd.
+ * 
+ * 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.
+ */
+
+/**
+ * 
+ */
+package com.vaadin.tests.push;
+
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
+
+import com.vaadin.server.VaadinRequest;
+import com.vaadin.tests.components.AbstractTestUIWithLog;
+import com.vaadin.tests.util.LoremIpsum;
+import com.vaadin.ui.Button;
+import com.vaadin.ui.Button.ClickEvent;
+import com.vaadin.ui.Button.ClickListener;
+import com.vaadin.ui.Label;
+import com.vaadin.ui.TextField;
+import com.vaadin.ui.UI;
+
+public abstract class PushLargeData extends AbstractTestUIWithLog {
+
+    private Label dataLabel = new Label();
+
+    private final ExecutorService executor = Executors
+            .newSingleThreadExecutor();
+
+    @Override
+    protected void setup(VaadinRequest request) {
+        dataLabel.setSizeUndefined();
+        final TextField dataSize = new TextField("Data size");
+        dataSize.setConverter(Integer.class);
+        final TextField interval = new TextField("Interval (ms)");
+        interval.setConverter(Integer.class);
+        final TextField duration = new TextField("Duration (ms)");
+        duration.setConverter(Integer.class);
+
+        dataSize.setValue((1000 * 1000) + "");
+        interval.setValue(2000 + "");
+        duration.setValue(40 * 1000 + "");
+
+        addComponent(dataSize);
+        addComponent(interval);
+        addComponent(duration);
+
+        Button b = new Button("Start pushing");
+        b.setId("startButton");
+        b.addClickListener(new ClickListener() {
+
+            @Override
+            public void buttonClick(ClickEvent event) {
+                Integer pushSize = (Integer) dataSize.getConvertedValue();
+                Integer pushInterval = (Integer) interval.getConvertedValue();
+                Integer pushDuration = (Integer) duration.getConvertedValue();
+                PushRunnable r = new PushRunnable(pushSize, pushInterval,
+                        pushDuration);
+                executor.execute(r);
+                log.log("Starting push, size: " + pushSize + ", interval: "
+                        + pushInterval + "ms, duration: " + pushDuration + "ms");
+            }
+        });
+        addComponent(b);
+        addComponent(dataLabel);
+    }
+
+    public Label getDataLabel() {
+        return dataLabel;
+    }
+
+    @Override
+    protected String getTestDescription() {
+        return "Tests that pushing large amounts of data do not cause problems";
+    }
+
+    @Override
+    protected Integer getTicketNumber() {
+        return 12567;
+    }
+
+    public static class PushRunnable implements Runnable {
+
+        private Integer size;
+        private Integer interval;
+        private Integer duration;
+
+        public PushRunnable(Integer size, Integer interval, Integer duration) {
+            this.size = size;
+            this.interval = interval;
+            this.duration = duration;
+        }
+
+        @Override
+        public void run() {
+            final long endTime = System.currentTimeMillis() + duration;
+            final String data = LoremIpsum.get(size);
+            int packageIndex = 1;
+            while (System.currentTimeMillis() < endTime) {
+                final int idx = packageIndex++;
+                UI.getCurrent().access(new Runnable() {
+                    @Override
+                    public void run() {
+                        PushLargeData ui = (PushLargeData) UI.getCurrent();
+                        ui.getDataLabel().setValue(
+                                System.currentTimeMillis() + ": " + data);
+                        ui.log("Package " + idx + " pushed");
+                    }
+                });
+                try {
+                    Thread.sleep(interval);
+                } catch (InterruptedException e) {
+                    return;
+                }
+            }
+            UI.getCurrent().access(new Runnable() {
+                @Override
+                public void run() {
+                    PushLargeData ui = (PushLargeData) UI.getCurrent();
+                    ui.log("Push complete");
+                }
+            });
+
+        }
+    }
+}