123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325 |
- /*
- * Copyright 2000-2016 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;
-
- import java.io.File;
- import java.io.FileInputStream;
- import java.io.FileNotFoundException;
- import java.io.FileOutputStream;
- import java.io.IOException;
- import java.io.InputStream;
- import java.io.OutputStream;
- import java.lang.management.ManagementFactory;
- import java.lang.management.MemoryMXBean;
-
- import com.vaadin.server.LegacyApplication;
- import com.vaadin.server.StreamResource;
- import com.vaadin.shared.ui.ContentMode;
- import com.vaadin.ui.Button;
- import com.vaadin.ui.Button.ClickEvent;
- import com.vaadin.ui.Label;
- import com.vaadin.ui.Layout;
- import com.vaadin.ui.LegacyWindow;
- import com.vaadin.ui.Link;
- import com.vaadin.ui.Panel;
- import com.vaadin.ui.Upload;
- import com.vaadin.ui.Upload.FailedEvent;
- import com.vaadin.ui.Upload.FailedListener;
- import com.vaadin.ui.Upload.FinishedEvent;
- import com.vaadin.ui.Upload.StartedEvent;
- import com.vaadin.ui.Upload.StartedListener;
- import com.vaadin.ui.Upload.SucceededEvent;
- import com.vaadin.ui.Upload.SucceededListener;
- import com.vaadin.ui.VerticalLayout;
- import com.vaadin.v7.ui.ProgressIndicator;
-
- public class TestForStyledUpload extends LegacyApplication
- implements Upload.FinishedListener, FailedListener, SucceededListener,
- StartedListener {
-
- Layout main = new VerticalLayout();
-
- TmpFileBuffer buffer = new TmpFileBuffer();
-
- VerticalLayout statusLayout = new VerticalLayout();
- Panel status = new Panel("Uploaded file:", statusLayout);
-
- private final Upload up;
-
- private final Label l;
-
- private final Label transferred = new Label("");
-
- private final ProgressIndicator pi = new ProgressIndicator();
-
- private final Label memoryStatus;
-
- public TestForStyledUpload() {
- main.addComponent(new Label(
- "Clicking on button b updates information about upload components status or same with garbage collector."));
-
- up = new Upload(null, buffer);
- up.setButtonCaption("Select file");
- up.setImmediateMode(true);
- up.addFinishedListener(this);
- up.addFailedListener(this);
- up.addSucceededListener(this);
- up.addStartedListener(this);
-
- up.addProgressListener(new Upload.ProgressListener() {
-
- @Override
- public void updateProgress(long readBytes, long contentLenght) {
- pi.setValue(new Float(readBytes / (float) contentLenght));
-
- refreshMemUsage();
-
- transferred.setValue(
- "Transferred " + readBytes + " of " + contentLenght);
- }
-
- });
-
- final Button b = new Button("Update status",
- new Button.ClickListener() {
- @Override
- public void buttonClick(ClickEvent event) {
- readState();
- }
- });
-
- final Button c = new Button("Update status with gc",
- new Button.ClickListener() {
- @Override
- public void buttonClick(ClickEvent event) {
- gc();
- }
- });
-
- main.addComponent(up);
- l = new Label("Idle");
- main.addComponent(l);
-
- pi.setVisible(false);
- pi.setPollingInterval(300);
- main.addComponent(pi);
- main.addComponent(transferred);
-
- memoryStatus = new Label();
- main.addComponent(memoryStatus);
-
- statusLayout.setMargin(true);
- status.setVisible(false);
- main.addComponent(status);
-
- Button cancel = new Button("Cancel current upload");
- cancel.addClickListener(new Button.ClickListener() {
- @Override
- public void buttonClick(ClickEvent event) {
- buffer.cancel();
- }
- });
-
- main.addComponent(cancel);
-
- final Button restart = new Button("Restart demo application");
- restart.addClickListener(new Button.ClickListener() {
-
- @Override
- public void buttonClick(ClickEvent event) {
- TestForStyledUpload.this.close();
- }
- });
- main.addComponent(restart);
- main.addComponent(b);
- main.addComponent(c);
-
- }
-
- public void gc() {
- Runtime.getRuntime().gc();
- readState();
- }
-
- public void readState() {
- final StringBuffer sb = new StringBuffer();
-
- if (up.isUploading()) {
- sb.append("Uploading...");
- sb.append(up.getBytesRead());
- sb.append("/");
- sb.append(up.getUploadSize());
- sb.append(" ");
- sb.append(Math.round(
- 100 * up.getBytesRead() / (double) up.getUploadSize()));
- sb.append("%");
- } else {
- sb.append("Idle");
- }
- l.setValue(sb.toString());
- refreshMemUsage();
- }
-
- @Override
- public void uploadFinished(FinishedEvent event) {
- statusLayout.removeAllComponents();
- final InputStream stream = buffer.getStream();
- if (stream == null) {
- statusLayout.addComponent(
- new Label("Upload finished, but output buffer is null!!"));
- } else {
- statusLayout.addComponent(new Label(
- "<b>Name:</b> " + event.getFilename(), ContentMode.HTML));
- statusLayout.addComponent(
- new Label("<b>Mimetype:</b> " + event.getMIMEType(),
- ContentMode.HTML));
- statusLayout.addComponent(
- new Label("<b>Size:</b> " + event.getLength() + " bytes.",
- ContentMode.HTML));
-
- statusLayout
- .addComponent(new Link("Download " + buffer.getFileName(),
- new StreamResource(buffer, buffer.getFileName())));
-
- status.setVisible(true);
- }
- }
-
- public interface Buffer
- extends StreamResource.StreamSource, Upload.Receiver {
-
- String getFileName();
- }
-
- public class TmpFileBuffer implements Buffer {
- String mimeType;
-
- String fileName;
-
- private File file;
-
- private FileInputStream stream;
-
- public TmpFileBuffer() {
- final String tempFileName = "upload_tmpfile_"
- + System.currentTimeMillis();
- try {
- file = File.createTempFile(tempFileName, null);
- } catch (final IOException e) {
- // TODO Auto-generated catch block
- e.printStackTrace();
- }
-
- }
-
- public void cancel() {
- up.interruptUpload();
- }
-
- @Override
- public InputStream getStream() {
- if (file == null) {
- return null;
- }
- try {
- stream = new FileInputStream(file);
- return stream;
- } catch (final FileNotFoundException e) {
- // TODO Auto-generated catch block
- e.printStackTrace();
- }
- return null;
- }
-
- /**
- * @see com.vaadin.ui.Upload.Receiver#receiveUpload(String, String)
- */
- @Override
- public OutputStream receiveUpload(String filename, String MIMEType) {
- fileName = filename;
- mimeType = MIMEType;
- try {
- return new FileOutputStream(file);
- } catch (final FileNotFoundException e) {
- // TODO Auto-generated catch block
- e.printStackTrace();
- }
- return null;
- }
-
- /**
- * Returns the fileName.
- *
- * @return String
- */
- @Override
- public String getFileName() {
- return fileName;
- }
-
- /**
- * Returns the mimeType.
- *
- * @return String
- */
- public String getMimeType() {
- return mimeType;
- }
-
- }
-
- @Override
- public void uploadFailed(FailedEvent event) {
- pi.setVisible(false);
- l.setValue("Upload was interrupted");
- }
-
- @Override
- public void uploadSucceeded(SucceededEvent event) {
- pi.setVisible(false);
- l.setValue("Finished upload, idle");
- System.out.println(event);
- }
-
- private void refreshMemUsage() {
- // memoryStatus.setValue("Not available in Java 1.4");
- StringBuffer mem = new StringBuffer();
- MemoryMXBean mmBean = ManagementFactory.getMemoryMXBean();
- mem.append("Heap (M):");
- mem.append(mmBean.getHeapMemoryUsage().getUsed() / 1048576);
- mem.append(" | Non-Heap (M):");
- mem.append(mmBean.getNonHeapMemoryUsage().getUsed() / 1048576);
- memoryStatus.setValue(mem.toString());
-
- }
-
- @Override
- public void uploadStarted(StartedEvent event) {
- pi.setVisible(true);
- l.setValue("Started uploading file " + event.getFilename());
- }
-
- @Override
- public void init() {
- LegacyWindow w = new LegacyWindow();
- setTheme("runo");
- w.addComponent(main);
- setMainWindow(w);
-
- }
-
- }
|