xan/awips2
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Issue #2290 - fix subscription status

Browse source 
Change-Id: I93ca6074af9eeec1b2cda9145418daa569817d10

Former-commit-id: 6a69d4d97e [formerly 6e08ebdd8f] [formerly 59a0765ae5] [formerly 59a0765ae5 [formerly 5684600e1c]] [formerly 6a69d4d97e [formerly 6e08ebdd8f] [formerly 59a0765ae5] [formerly 59a0765ae5 [formerly 5684600e1c]] [formerly a6d5ff3e2c [formerly 59a0765ae5 [formerly 5684600e1c] [formerly a6d5ff3e2c [formerly f2cd68bf1a7a21ed7d21d2c0f81ea54cca9a55dd]]]]]
Former-commit-id: a6d5ff3e2c
Former-commit-id: 9ad77e09a0 [formerly 5bdd1eabf6] [formerly c9bdfebbb5] [formerly 20f3680f0a6b269e1670ea4f738eb952c360a9b8 [formerly 4c37bcf4039580316d48461276616a53abe7b0f7] [formerly c9bdfebbb5 [formerly 0597182e66]]]
Former-commit-id: feb169642a35ba53887bf27721e021d25d9233ca [formerly 9c69ce25d88a00660f1359c22231e94fba55fd31] [formerly 1485bb7e61 [formerly f597526c3c]]
Former-commit-id: 1485bb7e61
Former-commit-id: 9cab1f2130
This commit is contained in:
Mike Duff 2013-08-28 15:35:22 -05:00
parent e05aa4ce90
commit fc5c3f32f2
3 changed files with 67 additions and 45 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
cave/com.raytheon.uf.viz.datadelivery/src/com/raytheon/uf/viz/datadelivery/subscription/SubscriptionStatusDlg.java
View file

@ -49,6 +49,7 @@ import com.raytheon.viz.ui.dialogs.CaveSWTDialog;
* ------------ ---------- ----------- --------------------------
* Jul 18, 2013 1653 mpduff Initial creation
* Aug 21, 2013 2248 bgonzale Changed label to minutes.
* Aug 28, 2013 2290 mpduff Changed output to work with unscheduled subs.
*
* </pre>
*
@ -168,10 +169,15 @@ public class SubscriptionStatusDlg extends CaveSWTDialog {
l3.setText("Start Time: ");
Calendar cal = TimeUtil.newGmtCalendar();
cal.setTimeInMillis(summary.getStartTime());
Label l33 = new Label(sumComp, SWT.NONE);
l33.setLayoutData(new GridData(SWT.LEFT, SWT.DEFAULT, true, false));
if (summary.getStartTime() != SubscriptionStatusSummary.MISSING_VALUE) {
cal.setTimeInMillis(summary.getStartTime());
l33.setText(sdf.format(cal.getTime()));
} else {
l33.setText("");
}
Label l4 = new Label(sumComp, SWT.NONE);
l4.setLayoutData(new GridData(SWT.LEFT, SWT.DEFAULT, false, false));
@ -180,6 +186,10 @@ public class SubscriptionStatusDlg extends CaveSWTDialog {
cal.setTimeInMillis(summary.getEndTime());
Label l44 = new Label(sumComp, SWT.NONE);
l44.setLayoutData(new GridData(SWT.LEFT, SWT.DEFAULT, true, false));
if (summary.getEndTime() != SubscriptionStatusSummary.MISSING_VALUE) {
l44.setText(sdf.format(cal.getTime()));
} else {
l44.setText("");
}
}
}

16
edexOsgi/com.raytheon.uf.common.datadelivery.bandwidth/src/com/raytheon/uf/common/datadelivery/bandwidth/data/SubscriptionStatusSummary.java
View file

@ -36,6 +36,7 @@ import com.raytheon.uf.common.util.StringUtil;
* Date Ticket# Engineer Description
* ------------ ---------- ----------- --------------------------
* Jul 17, 2013 1653 mpduff Initial creation
* Aug 28, 2013 2290 mpduff Added default missing values.
*
* </pre>
*
@ -44,17 +45,22 @@ import com.raytheon.uf.common.util.StringUtil;
*/
@DynamicSerialize
public class SubscriptionStatusSummary {
@DynamicSerializeElement
private long dataSize;
/**
* Missing data value.
*/
public static final long MISSING_VALUE = -9999;
@DynamicSerializeElement
private long startTime;
private long dataSize = MISSING_VALUE;
@DynamicSerializeElement
private long endTime;
private long startTime = MISSING_VALUE;
@DynamicSerializeElement
private long latency;
private long endTime = MISSING_VALUE;
@DynamicSerializeElement
private long latency = MISSING_VALUE;
/**
* @return the dataSize

10
edexOsgi/com.raytheon.uf.edex.datadelivery.bandwidth/src/com/raytheon/uf/edex/datadelivery/bandwidth/hibernate/HibernateBandwidthDao.java
View file

@ -62,6 +62,7 @@ import com.raytheon.uf.edex.datadelivery.bandwidth.util.BandwidthUtil;
* Jun 13, 2013 2095 djohnson Implement ability to store a collection of subscriptions.
* Jun 24, 2013 2106 djohnson Implement new methods.
* Jul 18, 2013 1653 mpduff Added getSubscriptionStatusSummary.
* Aug 28, 2013 2290 mpduff Check for no subscriptions.
*
* </pre>
*
@ -528,6 +529,8 @@ public class HibernateBandwidthDao implements IBandwidthDao {
List<BandwidthSubscription> bandwidthSubList = this
.getBandwidthSubscription(sub);
if (bandwidthSubList != null && !bandwidthSubList.isEmpty()) {
Collections.sort(bandwidthSubList,
new Comparator<BandwidthSubscription>() {
@Override
@ -567,8 +570,11 @@ public class HibernateBandwidthDao implements IBandwidthDao {
summary.setStartTime(subRetrievalList.get(0).getStartTime()
.getTimeInMillis());
summary.setEndTime(subRetrievalList.get(subRetrievalList.size() - 1)
.getEndTime().getTimeInMillis());
summary.setEndTime(subRetrievalList
.get(subRetrievalList.size() - 1).getEndTime()
.getTimeInMillis());
}
summary.setDataSize(sub.getDataSetSize());
summary.setLatency(sub.getLatencyInMinutes());