return err
		}
	}
}

// readN will return all the requested number of entries in order
// or all if n < 0.
// Will return io.EOF if end of stream is reached.
// If requesting 0 objects nil error will always be returned regardless of at end of stream.
// Use peek to determine if at end of stream.
func (r *metacacheReader) readN(n int, inclDeleted, inclDirs, inclVersions bool, prefix string) (metaCacheEntriesSorted, error) {

    <sub-class-of type="application/x-msdownload"/>
    <magic priority="55">
      <!-- Technically the header offset is stored at 0x3c, and isn't a -->
      <!-- constant, but it's almost always set to start at 0x80, 0xb0, -->
      <!-- 0xd0 or 0xf0. Will always have the MZ msdoc header too. -->
      <match value="MZ" type="string" offset="0">
         <match value="PE\000\000" type="string" offset="128"/>

import static com.google.common.collect.testing.Helpers.entryComparator;
import static com.google.common.collect.testing.Helpers.equal;
import static com.google.common.collect.testing.Helpers.mapEntry;
import static java.util.Arrays.asList;
import static java.util.Collections.sort;

import com.google.common.annotations.GwtCompatible;
import java.util.ArrayList;
import java.util.Collection;
import java.util.Comparator;
import java.util.List;

      }
      finished = true;
    }

    @Override
    protected HashCode makeHash() {
      if (!finished) {
        // processRemaining does teardown we always want to do -- the folding together of the four
        // rolling CRCs.  So we call it on an empty ByteBuffer if we didn't already.
        processRemaining(EMPTY);
      }
      return HashCode.fromInt(~crc0);
    }

import static com.google.common.cache.TestingCacheLoaders.identityLoader;
import static com.google.common.cache.TestingRemovalListeners.countingRemovalListener;
import static com.google.common.truth.Truth.assertThat;
import static java.util.Arrays.asList;
import static java.util.concurrent.TimeUnit.MILLISECONDS;
import static java.util.concurrent.TimeUnit.MINUTES;

import com.google.common.cache.TestingCacheLoaders.IdentityLoader;

            currentOffset += 20; // Simple SID size
        } else {
            SMBUtil.writeInt4(0, buffer, offset + 8);
        }

        // SACL offset (always 0)
        SMBUtil.writeInt4(0, buffer, offset + 12);

        // DACL offset
        if (includeDacl) {
            SMBUtil.writeInt4(currentOffset, buffer, offset + 16);

                                 * server will return "Access denied" even if a logoff is
                                 * sent. Unfortunately calling disconnect() doesn't always
                                 * actually shutdown the connection before other threads
                                 * have committed themselves (e.g. InterruptTest example).
                                 */

Foundation may assign the responsibility to serve as the Agreement Steward
to a suitable separate entity. Each new version of the Agreement will be given
a distinguishing version number. The Program (including Contributions) may
always be distributed subject to the version of the Agreement under which
it was received. In addition, after a new version of the Agreement is published,
Contributor may elect to distribute the Program (including its Contributions)

        assertFalse(conditionalRule.match(responseData)); // Doesn't match pattern

        testRule.setMatchResult(true);
        assertTrue(testRule.match(responseData)); // Always matches when set to true

        // Both should inherit same property behavior
        conditionalRule.setRuleId("conditional");
        testRule.setRuleId("test");

             * for whatever reason. I copy over the uid here so it appears correct
             * in logging output. Logging of andx segments of messages inadvertantly
             * print header information because of the way toString always makes a
             * super.toString() call(see toString() at the end of all smbs classes).
             */

            this.andx.uid = this.uid;