Skip to content

Commit 5b21696

Browse files
GagravarrGagravarr
committed
Reformat indents
1 parent 6561136 commit 5b21696

1 file changed

Lines changed: 191 additions & 191 deletions

File tree

‎core/src/test/java/org/gagravarr/ogg/TestBasicWrite.java‎

Lines changed: 191 additions & 191 deletions
Original file line numberDiff line numberDiff line change
@@ -25,195 +25,195 @@
2525
*/
2626
@SuppressWarnings("resource")
2727
public class TestBasicWrite extends TestCase {
28-
public void testOpen() throws IOException {
29-
ByteArrayOutputStream baos = new ByteArrayOutputStream();
30-
OggFile ogg = new OggFile(baos);
31-
32-
// Can't read
33-
try {
34-
ogg.getPacketReader();
35-
fail();
36-
} catch(IllegalStateException e) {}
37-
38-
// Can add
39-
OggPacketWriter w = ogg.getPacketWriter(1234);
40-
w.close();
41-
ogg.close();
42-
43-
}
44-
45-
public void testEmptyPages() throws IOException {
46-
InputStream inp;
47-
OggFile opened;
48-
OggPage page;
49-
OggPacket p;
50-
51-
ByteArrayOutputStream baos = new ByteArrayOutputStream();
52-
OggFile ogg = new OggFile(baos);
53-
54-
// Write an empty stream
55-
OggPacketWriter w = ogg.getPacketWriter(1234);
56-
w.close();
57-
58-
// Should have created an empty single page
59-
// with a single empty packet
60-
assertEquals(28, baos.size());
61-
62-
63-
// Check at page level
64-
inp = new ByteArrayInputStream(baos.toByteArray());
65-
inp.read(); inp.read(); inp.read(); inp.read();
66-
page = new OggPage(inp);
67-
assertEquals(1, page.getNumLVs());
68-
69-
70-
// Check
71-
opened = new OggFile( new ByteArrayInputStream(baos.toByteArray()) );
72-
OggPacketReader r = opened.getPacketReader();
73-
p = r.getNextPacket();
74-
75-
assertNotNull(p);
76-
assertEquals(true, p.isBeginningOfStream());
77-
assertEquals(true, p.isEndOfStream());
78-
assertEquals(1234, p.getSid());
79-
assertEquals(0, p.getSequenceNumber());
80-
assertEquals(0, p.getData().length);
81-
82-
assertNull(r.getNextPacket());
83-
84-
85-
// Now add a 2nd stream
86-
w = ogg.getPacketWriter(54321);
87-
88-
// Will do nothing as no pages yet
89-
w.flush();
90-
91-
// Add an empty packet
92-
p = new OggPacket(new byte[0]);
93-
w.bufferPacket(p);
94-
w.flush();
95-
96-
// And a packet with something in it,
97-
// and with a granule position
98-
p = new OggPacket(new byte[] {22});
99-
w.bufferPacket(p, 54321l);
100-
w.close();
101-
102-
// Check again
103-
opened = new OggFile( new ByteArrayInputStream(baos.toByteArray()) );
104-
r = opened.getPacketReader();
105-
106-
p = r.getNextPacket();
107-
assertNotNull(p);
108-
assertEquals(true, p.isBeginningOfStream());
109-
assertEquals(true, p.isEndOfStream());
110-
assertEquals(1234, p.getSid());
111-
assertEquals(0, p.getGranulePosition());
112-
assertEquals(0, p.getSequenceNumber());
113-
assertEquals(0, p.getData().length);
114-
115-
p = r.getNextPacket();
116-
assertNotNull(p);
117-
assertEquals(true, p.isBeginningOfStream());
118-
assertEquals(false, p.isEndOfStream());
119-
assertEquals(54321, p.getSid());
120-
assertEquals(0, p.getGranulePosition());
121-
assertEquals(0, p.getSequenceNumber());
122-
assertEquals(0, p.getData().length);
123-
124-
p = r.getNextPacket();
125-
assertNotNull(p);
126-
assertEquals(false, p.isBeginningOfStream());
127-
assertEquals(true, p.isEndOfStream());
128-
assertEquals(54321, p.getSid());
129-
assertEquals(54321l, p.getGranulePosition());
130-
assertEquals(1, p.getSequenceNumber());
131-
assertEquals(1, p.getData().length);
132-
133-
assertNull(r.getNextPacket());
134-
}
135-
136-
137-
public void testInterleaved() throws IOException {
138-
ByteArrayOutputStream baos = new ByteArrayOutputStream();
139-
OggFile ogg = new OggFile(baos);
140-
141-
OggPacketWriter w1 = ogg.getPacketWriter(1234);
142-
OggPacketWriter w2 = ogg.getPacketWriter(4321);
143-
144-
OggPacket p;
145-
146-
// Add plus flush
147-
p = new OggPacket(new byte[] {1});
148-
w1.bufferPacket(p, true);
149-
150-
p = new OggPacket(new byte[] {2});
151-
w2.bufferPacket(p, true);
152-
153-
// Add to one, flush another
154-
p = new OggPacket(new byte[] {1,1});
155-
w1.bufferPacket(p);
156-
p = new OggPacket(new byte[] {1,2});
157-
w1.bufferPacket(p, false);
158-
159-
p = new OggPacket(new byte[] {2,2});
160-
w2.bufferPacket(p);
161-
w2.close();
162-
163-
// Close 1
164-
w1.close();
165-
166-
167-
// Check
168-
OggFile opened = new OggFile( new ByteArrayInputStream(baos.toByteArray()) );
169-
OggPacketReader r = opened.getPacketReader();
170-
171-
p = r.getNextPacket();
172-
assertEquals(1234, p.getSid());
173-
assertEquals(0, p.getSequenceNumber());
174-
assertEquals(true, p.isBeginningOfStream());
175-
assertEquals(false, p.isEndOfStream());
176-
assertEquals(1, p.getData().length);
177-
assertEquals(1, p.getData()[0]);
178-
179-
p = r.getNextPacket();
180-
assertEquals(4321, p.getSid());
181-
assertEquals(0, p.getSequenceNumber());
182-
assertEquals(true, p.isBeginningOfStream());
183-
assertEquals(false, p.isEndOfStream());
184-
assertEquals(1, p.getData().length);
185-
assertEquals(2, p.getData()[0]);
186-
187-
// Didn't flush w1, so next is on w2
188-
189-
p = r.getNextPacket();
190-
assertEquals(4321, p.getSid());
191-
assertEquals(1, p.getSequenceNumber());
192-
assertEquals(false, p.isBeginningOfStream());
193-
assertEquals(true, p.isEndOfStream());
194-
assertEquals(2, p.getData().length);
195-
assertEquals(2, p.getData()[0]);
196-
assertEquals(2, p.getData()[1]);
197-
198-
// Now the w1 ones
199-
p = r.getNextPacket();
200-
assertEquals(1234, p.getSid());
201-
assertEquals(1, p.getSequenceNumber());
202-
assertEquals(false, p.isBeginningOfStream());
203-
assertEquals(false, p.isEndOfStream());
204-
assertEquals(2, p.getData().length);
205-
assertEquals(1, p.getData()[0]);
206-
assertEquals(1, p.getData()[1]);
207-
208-
p = r.getNextPacket();
209-
assertEquals(1234, p.getSid());
210-
assertEquals(1, p.getSequenceNumber());
211-
assertEquals(false, p.isBeginningOfStream());
212-
assertEquals(true, p.isEndOfStream());
213-
assertEquals(2, p.getData().length);
214-
assertEquals(1, p.getData()[0]);
215-
assertEquals(2, p.getData()[1]);
216-
217-
assertEquals(null, r.getNextPacket());
218-
}
28+
public void testOpen() throws IOException {
29+
ByteArrayOutputStream baos = new ByteArrayOutputStream();
30+
OggFile ogg = new OggFile(baos);
31+
32+
// Can't read
33+
try {
34+
ogg.getPacketReader();
35+
fail();
36+
} catch(IllegalStateException e) {}
37+
38+
// Can add
39+
OggPacketWriter w = ogg.getPacketWriter(1234);
40+
w.close();
41+
ogg.close();
42+
43+
}
44+
45+
public void testEmptyPages() throws IOException {
46+
InputStream inp;
47+
OggFile opened;
48+
OggPage page;
49+
OggPacket p;
50+
51+
ByteArrayOutputStream baos = new ByteArrayOutputStream();
52+
OggFile ogg = new OggFile(baos);
53+
54+
// Write an empty stream
55+
OggPacketWriter w = ogg.getPacketWriter(1234);
56+
w.close();
57+
58+
// Should have created an empty single page
59+
// with a single empty packet
60+
assertEquals(28, baos.size());
61+
62+
63+
// Check at page level
64+
inp = new ByteArrayInputStream(baos.toByteArray());
65+
inp.read(); inp.read(); inp.read(); inp.read();
66+
page = new OggPage(inp);
67+
assertEquals(1, page.getNumLVs());
68+
69+
70+
// Check
71+
opened = new OggFile( new ByteArrayInputStream(baos.toByteArray()) );
72+
OggPacketReader r = opened.getPacketReader();
73+
p = r.getNextPacket();
74+
75+
assertNotNull(p);
76+
assertEquals(true, p.isBeginningOfStream());
77+
assertEquals(true, p.isEndOfStream());
78+
assertEquals(1234, p.getSid());
79+
assertEquals(0, p.getSequenceNumber());
80+
assertEquals(0, p.getData().length);
81+
82+
assertNull(r.getNextPacket());
83+
84+
85+
// Now add a 2nd stream
86+
w = ogg.getPacketWriter(54321);
87+
88+
// Will do nothing as no pages yet
89+
w.flush();
90+
91+
// Add an empty packet
92+
p = new OggPacket(new byte[0]);
93+
w.bufferPacket(p);
94+
w.flush();
95+
96+
// And a packet with something in it,
97+
// and with a granule position
98+
p = new OggPacket(new byte[] {22});
99+
w.bufferPacket(p, 54321l);
100+
w.close();
101+
102+
// Check again
103+
opened = new OggFile( new ByteArrayInputStream(baos.toByteArray()) );
104+
r = opened.getPacketReader();
105+
106+
p = r.getNextPacket();
107+
assertNotNull(p);
108+
assertEquals(true, p.isBeginningOfStream());
109+
assertEquals(true, p.isEndOfStream());
110+
assertEquals(1234, p.getSid());
111+
assertEquals(0, p.getGranulePosition());
112+
assertEquals(0, p.getSequenceNumber());
113+
assertEquals(0, p.getData().length);
114+
115+
p = r.getNextPacket();
116+
assertNotNull(p);
117+
assertEquals(true, p.isBeginningOfStream());
118+
assertEquals(false, p.isEndOfStream());
119+
assertEquals(54321, p.getSid());
120+
assertEquals(0, p.getGranulePosition());
121+
assertEquals(0, p.getSequenceNumber());
122+
assertEquals(0, p.getData().length);
123+
124+
p = r.getNextPacket();
125+
assertNotNull(p);
126+
assertEquals(false, p.isBeginningOfStream());
127+
assertEquals(true, p.isEndOfStream());
128+
assertEquals(54321, p.getSid());
129+
assertEquals(54321l, p.getGranulePosition());
130+
assertEquals(1, p.getSequenceNumber());
131+
assertEquals(1, p.getData().length);
132+
133+
assertNull(r.getNextPacket());
134+
}
135+
136+
137+
public void testInterleaved() throws IOException {
138+
ByteArrayOutputStream baos = new ByteArrayOutputStream();
139+
OggFile ogg = new OggFile(baos);
140+
141+
OggPacketWriter w1 = ogg.getPacketWriter(1234);
142+
OggPacketWriter w2 = ogg.getPacketWriter(4321);
143+
144+
OggPacket p;
145+
146+
// Add plus flush
147+
p = new OggPacket(new byte[] {1});
148+
w1.bufferPacket(p, true);
149+
150+
p = new OggPacket(new byte[] {2});
151+
w2.bufferPacket(p, true);
152+
153+
// Add to one, flush another
154+
p = new OggPacket(new byte[] {1,1});
155+
w1.bufferPacket(p);
156+
p = new OggPacket(new byte[] {1,2});
157+
w1.bufferPacket(p, false);
158+
159+
p = new OggPacket(new byte[] {2,2});
160+
w2.bufferPacket(p);
161+
w2.close();
162+
163+
// Close 1
164+
w1.close();
165+
166+
167+
// Check
168+
OggFile opened = new OggFile( new ByteArrayInputStream(baos.toByteArray()) );
169+
OggPacketReader r = opened.getPacketReader();
170+
171+
p = r.getNextPacket();
172+
assertEquals(1234, p.getSid());
173+
assertEquals(0, p.getSequenceNumber());
174+
assertEquals(true, p.isBeginningOfStream());
175+
assertEquals(false, p.isEndOfStream());
176+
assertEquals(1, p.getData().length);
177+
assertEquals(1, p.getData()[0]);
178+
179+
p = r.getNextPacket();
180+
assertEquals(4321, p.getSid());
181+
assertEquals(0, p.getSequenceNumber());
182+
assertEquals(true, p.isBeginningOfStream());
183+
assertEquals(false, p.isEndOfStream());
184+
assertEquals(1, p.getData().length);
185+
assertEquals(2, p.getData()[0]);
186+
187+
// Didn't flush w1, so next is on w2
188+
189+
p = r.getNextPacket();
190+
assertEquals(4321, p.getSid());
191+
assertEquals(1, p.getSequenceNumber());
192+
assertEquals(false, p.isBeginningOfStream());
193+
assertEquals(true, p.isEndOfStream());
194+
assertEquals(2, p.getData().length);
195+
assertEquals(2, p.getData()[0]);
196+
assertEquals(2, p.getData()[1]);
197+
198+
// Now the w1 ones
199+
p = r.getNextPacket();
200+
assertEquals(1234, p.getSid());
201+
assertEquals(1, p.getSequenceNumber());
202+
assertEquals(false, p.isBeginningOfStream());
203+
assertEquals(false, p.isEndOfStream());
204+
assertEquals(2, p.getData().length);
205+
assertEquals(1, p.getData()[0]);
206+
assertEquals(1, p.getData()[1]);
207+
208+
p = r.getNextPacket();
209+
assertEquals(1234, p.getSid());
210+
assertEquals(1, p.getSequenceNumber());
211+
assertEquals(false, p.isBeginningOfStream());
212+
assertEquals(true, p.isEndOfStream());
213+
assertEquals(2, p.getData().length);
214+
assertEquals(1, p.getData()[0]);
215+
assertEquals(2, p.getData()[1]);
216+
217+
assertEquals(null, r.getNextPacket());
218+
}
219219
}

0 commit comments

Comments
 (0)