-
Notifications
You must be signed in to change notification settings - Fork 20
Expand file tree
/
Copy pathAISBinaryDataSource.java
More file actions
148 lines (123 loc) · 3.51 KB
/
AISBinaryDataSource.java
File metadata and controls
148 lines (123 loc) · 3.51 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
package AIS;
import java.io.ByteArrayInputStream;
import java.io.ByteArrayOutputStream;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.File;
import java.io.IOException;
import PamguardMVC.PamDataUnit;
import binaryFileStorage.BinaryDataSource;
import binaryFileStorage.BinaryHeader;
import binaryFileStorage.BinaryObjectData;
import binaryFileStorage.ModuleFooter;
import binaryFileStorage.ModuleHeader;
public class AISBinaryDataSource extends BinaryDataSource {
private AISDataBlock aisDataBlock;
private AISControl aisControl;
public AISBinaryDataSource(AISControl aisControl, AISDataBlock sisterDataBlock) {
super(sisterDataBlock);
this.aisControl = aisControl;
this.aisDataBlock = sisterDataBlock;
}
@Override
public int getModuleVersion() {
return 1;
}
@Override
public byte[] getModuleHeaderData() {
// TODO Auto-generated method stub
return null;
}
@Override
public String getStreamName() {
return aisControl.getUnitName();
}
@Override
public int getStreamVersion() {
return 0;
}
@Override
public void newFileOpened(File outputFile) {
// TODO Auto-generated method stub
}
private ByteArrayOutputStream bos;
private DataOutputStream dos;
@Override
public BinaryObjectData getPackedData(PamDataUnit pamDataUnit) {
AISDataUnit aisDataUnit = (AISDataUnit) pamDataUnit;
// make a byte array output stream and write the data to that,
// then dump that down to the main storage stream
if (dos == null || bos == null) {
dos = new DataOutputStream(bos = new ByteArrayOutputStream());
}
else {
bos.reset();
}
try {
dos.writeInt(aisDataUnit.mmsiNumber);
dos.writeShort(aisDataUnit.fillBits);
dos.writeUTF(aisDataUnit.charData);
dos.writeUTF(aisDataUnit.aisChannel);
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
BinaryObjectData pbo = new BinaryObjectData(0, bos.toByteArray());
try {
dos.close();
} catch (IOException e) {
e.printStackTrace();
}
return pbo;
}
@Override
public PamDataUnit sinkData(BinaryObjectData binaryObjectData,
BinaryHeader bh, int moduleVersion) {
int mmsiNumber = 0;
int fillBits = 0;
String charData;
String aisChannel;
// if (true) return null;
ByteArrayInputStream bis = new ByteArrayInputStream(binaryObjectData.getData(),
0, binaryObjectData.getDataLength());
DataInputStream dis = new DataInputStream(bis);
int writtenVersion = binaryObjectData.getVersionNumber();
try {
mmsiNumber = dis.readInt();
fillBits = dis.readShort();
charData = dis.readUTF();
if (writtenVersion >= 1) {
aisChannel = dis.readUTF();
}
dis.close();
} catch (IOException e) {
e.printStackTrace();
return null;
}
AISDataUnit aisDataUnit = new AISDataUnit(binaryObjectData.getTimeMilliseconds(),
charData, fillBits);
if (aisDataUnit.decodeMessage()) {
aisDataBlock.addAISData(aisDataUnit);
return null; // stop PAMGUARD from adding the same data again
/**
* A consequence of this is that the data unit will not have any file information
* attached to it - but OK since these data will never be resaved.
*/
}
else {
return null;
}
}
@Override
public ModuleFooter sinkModuleFooter(BinaryObjectData binaryObjectData,
BinaryHeader bh, ModuleHeader moduleHeader) {
// TODO Auto-generated method stub
return null;
}
@Override
public ModuleHeader sinkModuleHeader(BinaryObjectData binaryObjectData,
BinaryHeader bh) {
// TODO Auto-generated method stub
return null;
}
}