| /* |
| * Copyright (C) 2012 Square, Inc. |
| * |
| * 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 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. |
| */ |
| package com.squareup.okhttp.internal.spdy; |
| |
| import org.junit.Test; |
| |
| import static com.squareup.okhttp.internal.spdy.Settings.DEFAULT_INITIAL_WINDOW_SIZE; |
| import static com.squareup.okhttp.internal.spdy.Settings.DOWNLOAD_BANDWIDTH; |
| import static com.squareup.okhttp.internal.spdy.Settings.DOWNLOAD_RETRANS_RATE; |
| import static com.squareup.okhttp.internal.spdy.Settings.MAX_CONCURRENT_STREAMS; |
| import static com.squareup.okhttp.internal.spdy.Settings.PERSISTED; |
| import static com.squareup.okhttp.internal.spdy.Settings.PERSIST_VALUE; |
| import static com.squareup.okhttp.internal.spdy.Settings.UPLOAD_BANDWIDTH; |
| import static org.junit.Assert.assertEquals; |
| import static org.junit.Assert.assertFalse; |
| import static org.junit.Assert.assertTrue; |
| |
| public final class SettingsTest { |
| @Test public void unsetField() { |
| Settings settings = new Settings(); |
| assertEquals(-3, settings.getUploadBandwidth(-3)); |
| } |
| |
| @Test public void setFields() { |
| Settings settings = new Settings(); |
| |
| // WARNING: clash on flags between spdy/3 and HTTP/2! |
| assertEquals(-3, settings.getUploadBandwidth(-3)); |
| assertEquals(-1, settings.getHeaderTableSize()); |
| settings.set(UPLOAD_BANDWIDTH, 0, 42); |
| assertEquals(42, settings.getUploadBandwidth(-3)); |
| settings.set(Settings.HEADER_TABLE_SIZE, 0, 8096); |
| assertEquals(8096, settings.getHeaderTableSize()); |
| |
| // WARNING: clash on flags between spdy/3 and HTTP/2! |
| assertEquals(true, settings.getEnablePush(true)); |
| settings.set(Settings.ENABLE_PUSH, 0, 1); |
| assertEquals(true, settings.getEnablePush(false)); |
| settings.clear(); |
| assertEquals(-3, settings.getDownloadBandwidth(-3)); |
| settings.set(DOWNLOAD_BANDWIDTH, 0, 53); |
| assertEquals(53, settings.getDownloadBandwidth(-3)); |
| |
| assertEquals(-3, settings.getRoundTripTime(-3)); |
| settings.set(Settings.ROUND_TRIP_TIME, 0, 64); |
| assertEquals(64, settings.getRoundTripTime(-3)); |
| |
| assertEquals(-3, settings.getMaxConcurrentStreams(-3)); |
| settings.set(MAX_CONCURRENT_STREAMS, 0, 75); |
| assertEquals(75, settings.getMaxConcurrentStreams(-3)); |
| |
| // WARNING: clash on flags between spdy/3 and HTTP/2! |
| assertEquals(-3, settings.getCurrentCwnd(-3)); |
| settings.set(Settings.CURRENT_CWND, 0, 86); |
| assertEquals(86, settings.getCurrentCwnd(-3)); |
| settings.clear(); |
| assertEquals(16384, settings.getMaxFrameSize(16384)); |
| settings.set(Settings.MAX_FRAME_SIZE, 0, 16777215); |
| assertEquals(16777215, settings.getMaxFrameSize(16384)); |
| |
| // WARNING: clash on flags between spdy/3 and HTTP/2! |
| assertEquals(-3, settings.getDownloadRetransRate(-3)); |
| settings.set(DOWNLOAD_RETRANS_RATE, 0, 97); |
| assertEquals(97, settings.getDownloadRetransRate(-3)); |
| settings.clear(); |
| assertEquals(-1, settings.getMaxHeaderListSize(-1)); |
| settings.set(Settings.MAX_HEADER_LIST_SIZE, 0, 16777215); |
| assertEquals(16777215, settings.getMaxHeaderListSize(-1)); |
| |
| assertEquals(DEFAULT_INITIAL_WINDOW_SIZE, |
| settings.getInitialWindowSize(DEFAULT_INITIAL_WINDOW_SIZE)); |
| settings.set(Settings.INITIAL_WINDOW_SIZE, 0, 108); |
| assertEquals(108, settings.getInitialWindowSize(DEFAULT_INITIAL_WINDOW_SIZE)); |
| |
| assertEquals(-3, settings.getClientCertificateVectorSize(-3)); |
| settings.set(Settings.CLIENT_CERTIFICATE_VECTOR_SIZE, 0, 117); |
| assertEquals(117, settings.getClientCertificateVectorSize(-3)); |
| } |
| |
| @Test public void isPersisted() { |
| Settings settings = new Settings(); |
| |
| // Initially false. |
| assertFalse(settings.isPersisted(Settings.ROUND_TRIP_TIME)); |
| |
| // Set no flags. |
| settings.set(Settings.ROUND_TRIP_TIME, 0, 0); |
| assertFalse(settings.isPersisted(Settings.ROUND_TRIP_TIME)); |
| |
| // Set the wrong flag. |
| settings.set(Settings.ROUND_TRIP_TIME, PERSIST_VALUE, 0); |
| assertFalse(settings.isPersisted(Settings.ROUND_TRIP_TIME)); |
| |
| // Set the right flag. |
| settings.set(Settings.ROUND_TRIP_TIME, PERSISTED, 0); |
| assertTrue(settings.isPersisted(Settings.ROUND_TRIP_TIME)); |
| |
| // Set multiple flags. |
| settings.set(Settings.ROUND_TRIP_TIME, PERSIST_VALUE | PERSISTED, 0); |
| assertTrue(settings.isPersisted(Settings.ROUND_TRIP_TIME)); |
| |
| // Clear the flag. |
| settings.set(Settings.ROUND_TRIP_TIME, PERSIST_VALUE, 0); |
| assertFalse(settings.isPersisted(Settings.ROUND_TRIP_TIME)); |
| |
| // Clear all flags. |
| settings.set(Settings.ROUND_TRIP_TIME, 0, 0); |
| assertFalse(settings.isPersisted(Settings.ROUND_TRIP_TIME)); |
| } |
| |
| @Test public void persistValue() { |
| Settings settings = new Settings(); |
| |
| // Initially false. |
| assertFalse(settings.persistValue(Settings.ROUND_TRIP_TIME)); |
| |
| // Set no flags. |
| settings.set(Settings.ROUND_TRIP_TIME, 0, 0); |
| assertFalse(settings.persistValue(Settings.ROUND_TRIP_TIME)); |
| |
| // Set the wrong flag. |
| settings.set(Settings.ROUND_TRIP_TIME, PERSISTED, 0); |
| assertFalse(settings.persistValue(Settings.ROUND_TRIP_TIME)); |
| |
| // Set the right flag. |
| settings.set(Settings.ROUND_TRIP_TIME, PERSIST_VALUE, 0); |
| assertTrue(settings.persistValue(Settings.ROUND_TRIP_TIME)); |
| |
| // Set multiple flags. |
| settings.set(Settings.ROUND_TRIP_TIME, PERSIST_VALUE | PERSISTED, 0); |
| assertTrue(settings.persistValue(Settings.ROUND_TRIP_TIME)); |
| |
| // Clear the flag. |
| settings.set(Settings.ROUND_TRIP_TIME, PERSISTED, 0); |
| assertFalse(settings.persistValue(Settings.ROUND_TRIP_TIME)); |
| |
| // Clear all flags. |
| settings.set(Settings.ROUND_TRIP_TIME, 0, 0); |
| assertFalse(settings.persistValue(Settings.ROUND_TRIP_TIME)); |
| } |
| |
| @Test public void merge() { |
| Settings a = new Settings(); |
| a.set(UPLOAD_BANDWIDTH, PERSIST_VALUE, 100); |
| a.set(DOWNLOAD_BANDWIDTH, PERSIST_VALUE, 200); |
| a.set(DOWNLOAD_RETRANS_RATE, 0, 300); |
| |
| Settings b = new Settings(); |
| b.set(DOWNLOAD_BANDWIDTH, 0, 400); |
| b.set(DOWNLOAD_RETRANS_RATE, PERSIST_VALUE, 500); |
| b.set(MAX_CONCURRENT_STREAMS, PERSIST_VALUE, 600); |
| |
| a.merge(b); |
| assertEquals(100, a.getUploadBandwidth(-1)); |
| assertEquals(PERSIST_VALUE, a.flags(UPLOAD_BANDWIDTH)); |
| assertEquals(400, a.getDownloadBandwidth(-1)); |
| assertEquals(0, a.flags(DOWNLOAD_BANDWIDTH)); |
| assertEquals(500, a.getDownloadRetransRate(-1)); |
| assertEquals(PERSIST_VALUE, a.flags(DOWNLOAD_RETRANS_RATE)); |
| assertEquals(600, a.getMaxConcurrentStreams(-1)); |
| assertEquals(PERSIST_VALUE, a.flags(MAX_CONCURRENT_STREAMS)); |
| } |
| } |