hyracks-admin-console/src/main/java/edu/uci/ics/hyracks/adminconsole/client/panels/NodeControllersPanel.java

/*
 * Copyright 2009-2010 by The Regents of the University of California
 * 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 from
 * 
 *     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 edu.uci.ics.hyracks.adminconsole.client.panels;

import java.util.ArrayList;
import java.util.List;

import com.google.gwt.core.client.GWT;
import com.google.gwt.core.client.JsArray;
import com.google.gwt.http.client.RequestException;
import com.google.gwt.uibinder.client.UiBinder;
import com.google.gwt.uibinder.client.UiField;
import com.google.gwt.user.client.Timer;
import com.google.gwt.user.client.ui.Composite;
import com.google.gwt.user.client.ui.SplitLayoutPanel;
import com.google.gwt.user.client.ui.Widget;
import com.google.gwt.view.client.AsyncDataProvider;

import edu.uci.ics.hyracks.adminconsole.client.beans.NodeSummary;
import edu.uci.ics.hyracks.adminconsole.client.rest.AbstractRestFunction;
import edu.uci.ics.hyracks.adminconsole.client.rest.GetNodeSummariesFunction;
import edu.uci.ics.hyracks.adminconsole.client.widgets.NodesTableWidget;

public class NodeControllersPanel extends Composite implements NodesTableWidget.IRefreshRequestHandler {
    interface Binder extends UiBinder<Widget, NodeControllersPanel> {
    }

    private final static Binder binder = GWT.create(Binder.class);

    @UiField
    SplitLayoutPanel split;

    @UiField
    NodesTableWidget nodes;

    @UiField
    Widget details;

    private int callCounter;

    public NodeControllersPanel() {
        initWidget(binder.createAndBindUi(this));

        nodes.setRefreshRequestHandler(this);
        nodes.setClickListener(new NodesTableWidget.IClickListener() {
            @Override
            public void click(String nodeId) {
                if (details instanceof NodeControllerDetailsPanel) {
                    ((NodeControllerDetailsPanel) details).destroy();
                }
                split.remove(details);
                details = new NodeControllerDetailsPanel(nodeId);
                split.add(details);
            }
        });

        Timer timer = new Timer() {
            @Override
            public void run() {
                refresh();
            }
        };
        refresh();
        timer.scheduleRepeating(10000);
    }

    @Override
    public void refresh() {
        try {
            final int counter = ++callCounter;
            GetNodeSummariesFunction.INSTANCE.call(new AbstractRestFunction.ResultCallback<JsArray<NodeSummary>>() {
                @Override
                public void onSuccess(JsArray<NodeSummary> result) {
                    if (counter == callCounter) {
                        AsyncDataProvider<NodeSummary> dataProvider = nodes.getDataProvider();
                        List<NodeSummary> data = new ArrayList<NodeSummary>();
                        for (int i = 0; i < result.length(); ++i) {
                            data.add(result.get(i));
                        }
                        dataProvider.updateRowData(0, data);
                        dataProvider.updateRowCount(result.length(), true);
                    }
                }

                @Override
                public void onError(Throwable exception) {

                }
            });
        } catch (RequestException e) {
            e.printStackTrace();
        }
    }
}