// Second decode - should overwrite previous value
        byte[] buffer2 = new byte[8];
        long indexNumber2 = 0x2222222222222222L;
        SMBUtil.writeInt8(indexNumber2, buffer2, 0);
        fileInternalInfo.decode(buffer2, 0, buffer2.length);
        assertEquals(indexNumber2, fileInternalInfo.getIndexNumber());

        // Third decode - should overwrite again
        byte[] buffer3 = new byte[8];

        this.metadata = metadata;
    }

    @Override
    public String getRemoteFilename() {
        return "maven-metadata.xml";
    }

    @Override
    public String getLocalFilename(ArtifactRepository repository) {
        return "maven-metadata-" + repository.getKey() + ".xml";
    }

    @Override

  // Fail fast on GetStatus requests so we can get errors instead of timeout
  // when updating cluster with non-exsitent worker
  tensorflow::setenv("GRPC_FAIL_FAST", "TRUE", /*overwrite=*/1);

  tensorflow::ServerDef server_def = GetServerDef(2);
  // This server def has the task index set to 0.
  string serialized = server_def.SerializeAsString();

  server_def.set_task_index(1);

        req.addFlags0(0x10);
        int flags0 = (int) getPrivateField(req, "flags0");
        assertTrue((flags0 & 0x10) != 0, "flag should be set after addFlags0");
        // Calling again should combine rather than overwrite
        req.addFlags0(0x20);
        flags0 = (int) getPrivateField(req, "flags0");
        assertTrue((flags0 & 0x20) != 0, "flag should accumulate");
    }

    @Test

            }

            @Override
            public String getCrawlerFileProtocols() {
                return "file,smb,smb1,ftp,storage,s3,gcs";
            }

            @Override
            public String getCrawlerDocumentFileNameEncoding() {
                return "";
            }

            @Override
            public String getCrawlerDocumentSiteEncoding() {
                return "";

type ApplyOptions struct {
	AutoEncrypt bool
}

// Apply applies the SSE bucket configuration on the given HTTP headers and
// sets the specified SSE headers.
//
// Apply does not overwrite any existing SSE headers. Further, it will
// set minimal SSE-KMS headers if autoEncrypt is true and the BucketSSEConfig
// is nil.
func (b *BucketSSEConfig) Apply(headers http.Header, opts ApplyOptions) {

                  </fileset>
                </copy>
                <!-- Any manually written supersource should take priority over the original guava source, so we set overwrite=true. -->
                <copy toDir="${project.build.directory}/guava-gwt-sources" overwrite="true">
                  <fileset dir="src-super" />
                </copy>
                <copy toDir="${project.build.directory}/guava-test-gwt-sources">

MAX_MAP_COUNT=262144

# Path to the GC log file
#FESS_GC_LOG_FILE=/var/log/fess/gc.log

# Fess PID file directory
PID_DIR=${packaging.fess.pid.dir}

# End of variables that can be overwritten in $DEFAULT

# overwrite settings from default file
if [ -f "$DEFAULT" ]; then
	. "$DEFAULT"
fi

# Define other required variables
PID_FILE="$PID_DIR/$NAME.pid"
DAEMON=$FESS_HOME/bin/fess

        }

        valueSources.add(modelValueSource1);

        valueSources.add(new MapBasedValueSource(config.getUserProperties()));

        // Overwrite existing values in model properties. Otherwise, it's not possible
        // to define them via command line e.g.: mvn -Drevision=6.5.7 ...
        versionProcessor.overwriteModelProperties(modelProperties, config);

            // Should not throw
            assertDoesNotThrow(() -> concreteImplementation.replaceCache());
        }

        @Test
        @DisplayName("Should overwrite existing cache entry")
        void testReplaceCacheOverwrite() {
            String key = "existing-key";
            DfsReferralDataInternal oldEntry = mock(DfsReferralDataInternal.class);