~ubuntu-branches/ubuntu/trusty/httpcomponents-core/trusty

* $HeadURL:https://svn.apache.org/repos/asf/jakarta/httpcomponents/httpcore/trunk/module-nio/src/test/java/org/apache/http/impl/nio/TestBuffers.java $

* $Revision:503277 $

* $Date:2007-02-03 18:22:45 +0000 (Sat, 03 Feb 2007) $

* ====================================================================

* Licensed to the Apache Software Foundation (ASF) under one

* or more contributor license agreements. See the NOTICE file

* distributed with this work for additional information

* regarding copyright ownership. The ASF licenses this file

* to you 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.

* ====================================================================

* This software consists of voluntary contributions made by many

* individuals on behalf of the Apache Software Foundation. For more

* information on the Apache Software Foundation, please see

* <http://www.apache.org/>.

package org.apache.http.nio.util;

import java.io.ByteArrayOutputStream;

import java.io.IOException;

import java.nio.ByteBuffer;

import java.nio.channels.Channels;

import java.nio.channels.ReadableByteChannel;

import java.nio.channels.WritableByteChannel;

import junit.framework.Test;

import junit.framework.TestCase;

import junit.framework.TestSuite;

import org.apache.http.impl.io.HttpTransportMetricsImpl;

import org.apache.http.impl.nio.reactor.SessionOutputBufferImpl;

import org.apache.http.mockup.MockupDecoder;

import org.apache.http.mockup.MockupEncoder;

import org.apache.http.mockup.ReadableByteChannelMockup;

import org.apache.http.nio.ContentDecoder;

import org.apache.http.nio.ContentEncoder;

import org.apache.http.nio.reactor.SessionOutputBuffer;

import org.apache.http.params.BasicHttpParams;

import org.apache.http.params.HttpParams;

import org.apache.http.util.EncodingUtils;

/**

* Buffer tests.

* @version $Id:TestBuffers.java 503277 2007-02-03 18:22:45 +0000 (Sat, 03 Feb 2007) olegk $

public class TestBuffers extends TestCase {

// ------------------------------------------------------------ Constructor

public TestBuffers(String testName) {

super(testName);

}

// ------------------------------------------------------------------- Main

public static void main(String args[]) {

String[] testCaseName = { TestBuffers.class.getName() };

junit.textui.TestRunner.main(testCaseName);

}

// ------------------------------------------------------- TestCase Methods

public static Test suite() {

return new TestSuite(TestBuffers.class);

}

public void testInputBufferOperations() throws IOException {

ReadableByteChannel channel = new ReadableByteChannelMockup(

new String[] {"stuff;", "more stuff"}, "US-ASCII");

ContentDecoder decoder = new MockupDecoder(channel);

SimpleInputBuffer buffer = new SimpleInputBuffer(4, new DirectByteBufferAllocator());

int count = buffer.consumeContent(decoder);

assertEquals(16, count);

assertTrue(decoder.isCompleted());

byte[] b1 = new byte[5];

int len = buffer.read(b1);

assertEquals("stuff", EncodingUtils.getAsciiString(b1, 0, len));

int c = buffer.read();

assertEquals(';', c);

100

byte[] b2 = new byte[1024];

101

102

len = buffer.read(b2);

103

assertEquals("more stuff", EncodingUtils.getAsciiString(b2, 0, len));

104

105

assertEquals(-1, buffer.read());

106

assertEquals(-1, buffer.read(b2));

107

assertEquals(-1, buffer.read(b2, 0, b2.length));

108

assertTrue(buffer.isEndOfStream());

109

110

buffer.reset();

111

assertFalse(buffer.isEndOfStream());

112

}

113

114

public void testOutputBufferOperations() throws IOException {

115

ByteArrayOutputStream outstream = new ByteArrayOutputStream();

116

WritableByteChannel channel = Channels.newChannel(outstream);

117

HttpParams params = new BasicHttpParams();

118

SessionOutputBuffer outbuf = new SessionOutputBufferImpl(1024, 128, params);

119

HttpTransportMetricsImpl metrics = new HttpTransportMetricsImpl();

120

121

ContentEncoder encoder = new MockupEncoder(channel, outbuf, metrics);

122

123

SimpleOutputBuffer buffer = new SimpleOutputBuffer(4, new DirectByteBufferAllocator());

124

125

buffer.write(EncodingUtils.getAsciiBytes("stuff"));

126

buffer.write(';');

127

buffer.produceContent(encoder);

128

129

buffer.write(EncodingUtils.getAsciiBytes("more "));

130

buffer.write(EncodingUtils.getAsciiBytes("stuff"));

131

buffer.produceContent(encoder);

132

133

byte[] content = outstream.toByteArray();

134

assertEquals("stuff;more stuff", EncodingUtils.getAsciiString(content));

135

}

136

137

public void testBufferInfo() throws Exception {

138

SimpleOutputBuffer buffer = new SimpleOutputBuffer(8, new DirectByteBufferAllocator());

139

BufferInfo bufferinfo = buffer;

140

141

assertEquals(0, bufferinfo.length());

142

assertEquals(8, bufferinfo.available());

143

buffer.write(new byte[] {'1', '2', '3', '4'});

144

assertEquals(4, bufferinfo.length());

145

assertEquals(4, bufferinfo.available());

146

buffer.write(new byte[] {'1', '2', '3', '4', '5', '6', '7', '8'});

147

assertEquals(12, bufferinfo.length());

148

assertEquals(0, bufferinfo.available());

149

}

150

151

public void testInputBufferNullInput() throws IOException {

152

SimpleInputBuffer buffer = new SimpleInputBuffer(4, new DirectByteBufferAllocator());

153

assertEquals(0, buffer.read(null));

154

assertEquals(0, buffer.read(null, 0, 0));

155

}

156

157

public void testOutputBufferNullInput() throws IOException {

158

SimpleOutputBuffer buffer = new SimpleOutputBuffer(4, new DirectByteBufferAllocator());

159

buffer.write(null);

160

buffer.write(null, 0, 10);

161

assertFalse(buffer.hasData());

162

}

163

164

public void testDirectByteBufferAllocator() {

165

DirectByteBufferAllocator allocator = new DirectByteBufferAllocator();

166

ByteBuffer buffer = allocator.allocate(1);

167

assertNotNull(buffer);

168

assertTrue(buffer.isDirect());

169

assertEquals(0, buffer.position());

170

assertEquals(1, buffer.limit());

171

assertEquals(1, buffer.capacity());

172

173

buffer = allocator.allocate(2048);

174

assertTrue(buffer.isDirect());

175

assertEquals(0, buffer.position());

176

assertEquals(2048, buffer.limit());

177

assertEquals(2048, buffer.capacity());

178

179

buffer = allocator.allocate(0);

180

assertTrue(buffer.isDirect());

181

assertEquals(0, buffer.position());

182

assertEquals(0, buffer.limit());

183

assertEquals(0, buffer.capacity());

184

}

185

186

public void testHeapByteBufferAllocator() {

187

HeapByteBufferAllocator allocator = new HeapByteBufferAllocator();

188

ByteBuffer buffer = allocator.allocate(1);

189

assertNotNull(buffer);

190

assertFalse(buffer.isDirect());

191

assertEquals(0, buffer.position());

192

assertEquals(1, buffer.limit());

193

assertEquals(1, buffer.capacity());

194

195

buffer = allocator.allocate(2048);

196

assertFalse(buffer.isDirect());

197

assertEquals(0, buffer.position());

198

assertEquals(2048, buffer.limit());

199

assertEquals(2048, buffer.capacity());

200

201

buffer = allocator.allocate(0);

202

assertFalse(buffer.isDirect());

203

assertEquals(0, buffer.position());

204

assertEquals(0, buffer.limit());

205

assertEquals(0, buffer.capacity());

206

}

207

208

}

Older »