* @param length the second argument to {@link ByteSource#slice}
   * @param expectRead the number of bytes we expect to read
   */
  private static void assertCorrectSlice(int input, int offset, long length, int expectRead)
      throws IOException {
    checkArgument(expectRead == (int) max(0, min(input, offset + length) - offset));

    byte[] expected = newPreFilledByteArray(offset, expectRead);

     * @return the calculated response
     */
    public static byte[] getNTLMv2Response(final byte[] responseKeyNT, final byte[] serverChallenge, final byte[] clientChallenge,
            final long nanos1601, final byte[] avPairs) {
        final int avPairsLength = avPairs != null ? avPairs.length : 0;
        final byte[] temp = new byte[28 + avPairsLength + 4];

        Encdec.enc_uint32le(0x00000101, temp, 0); // Header

			} else if err := errors[fileline]; err == "" {
				t.Errorf("%s: missing error, want %s", fileline, all)
			} else if !strings.Contains(err, mm[0][1]) {
				t.Errorf("%s: wrong error for %s:\n%s", fileline, all, err)
			}
		} else {
			if errors[fileline] != "" {
				t.Errorf("unexpected error on %s: %v", fileline, errors[fileline])
			}
		}
		delete(errors, fileline)
	}

/**
 * Tests for error handling scenarios in SuggestIndexer.
 */
public class SuggestIndexerErrorHandlingTest {
    private static final String TEST_ID = "SuggestIndexerErrorHandlingTest";

    private static final long ASYNC_TIMEOUT_SECONDS = 5L;

    static Suggester suggester;
    static OpenSearchRunner runner;

    @BeforeClass
    public static void beforeClass() throws Exception {
        runner = new OpenSearchRunner();

        });
        final OpenSearchResultList<T> targetList = new OpenSearchResultList<>();
        final SearchHits hits = response.getHits();
        final TotalHits totalHits = hits.getTotalHits();
        final long totalHitsValue = totalHits != null ? totalHits.value() : 0;
        targetList.setTotalHits(totalHitsValue);
        targetList.setTookInMillis(response.getTook().getMillis());
        if (totalHitsValue != 0) {

40.732776641845703 -73.936798095703125 40.764118194580078 5 8.70 25.5 0.5 0.5 0 0 26.5 2 1 196 193 green 0.00 0.0 0.0 43 28 6.93 1288 717.02 4 Queens 071702 4071702 I QN18 Rego Park 4108 1419 43 4 Queens 004300 4004300 E QN68 Queensbridge-Ravenswood-Long Island City 4101 3389325 2 2014-03-22 19:12:44 2014-03-22 19:27:00 N 1 -73.863761901855469 40.732769012451172 -73.87249755859375 40.742450714111328 1 1.92 10 0 0.5 0 0 10.5 2 1 196 82 green 0.00 0.0 0.0 63 41 6.93 1288 717.02 4 Queens 071702 4071702...

        return OptionalThing.of(new FessUserBean(new TestUser(name, permissions)));
    }

    static class TestUser implements FessUser {

        private static final long serialVersionUID = 1L;

        private String name;

        private String[] permissions;

        TestUser(String name, String[] permissions) {
            this.name = name;

    }

    // Test serialization
    @Test
    public void test_serialVersionUID() {
        assertEquals(1L, getSerialVersionUID());
    }

    private long getSerialVersionUID() {
        try {
            java.lang.reflect.Field field = FessMessages.class.getDeclaredField("serialVersionUID");
            field.setAccessible(true);
            return field.getLong(null);

        hook.start();
      }
      for (Thread hook : hooks) {
        hook.join();
      }
    }
  }

  /* Half of a 1-second timeout in nanoseconds */
  private static final long HALF_SECOND_NANOS = NANOSECONDS.convert(1L, SECONDS) / 2;

  public void testShutdownAndAwaitTermination_immediateShutdown() throws Exception {
    ExecutorService service = Executors.newSingleThreadExecutor();

                return optional.get();
              }
            }
            return endOfData();
          }
        };
  }

  @GwtIncompatible @J2ktIncompatible private static final long serialVersionUID = 0;