- Sort Score
- Num 10 results
- Language All
Results 521 - 530 of 649 for set_op (0.05 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
cmd/bucket-targets.go
return nil } func (sys *BucketTargetSys) updateBandwidthLimit(bucket, arn string, limit int64) { if limit == 0 { globalBucketMonitor.DeleteBucketThrottle(bucket, arn) return } // Setup bandwidth throttling globalBucketMonitor.SetBandwidthLimit(bucket, arn, limit) } // RemoveTarget - removes a remote bucket target for this source bucket.
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 20.9K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/helper/SystemHelper.java
} /** * Checks if the system is in a force-stop state. * * @return true if the system is force-stopping, false otherwise. */ public boolean isForceStop() { return forceStop.get(); } /** * Sets the force-stop state of the system. * * @param b true to force-stop the system. */ public void setForceStop(final boolean b) {Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Sat Mar 28 06:59:19 GMT 2026 - 43.2K bytes - Click Count (0) -
gradlew
# treated as '${Hostname}' itself on the command line. set -- \ "-Dorg.gradle.appname=$APP_BASE_NAME" \ -jar "$APP_HOME/gradle/wrapper/gradle-wrapper.jar" \ "$@" # Stop when "xargs" is not available. if ! command -v xargs >/dev/null 2>&1 then die "xargs is not available" fi # Use "xargs" to parse quoted args. #
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Fri Mar 20 08:59:10 GMT 2026 - 8.5K bytes - Click Count (0) -
cmd/site-replication-utils.go
} } return &m } // save in-memory stats to disk func (sm *siteResyncMetrics) save(ctx context.Context) { sTimer := time.NewTimer(siteResyncSaveInterval) defer sTimer.Stop() for { select { case <-sTimer.C: if globalSiteReplicationSys.isEnabled() { sm.Lock() wg := sync.WaitGroup{} for dID, rs := range sm.peerResyncMap {
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 8.8K bytes - Click Count (0) -
cmd/erasure-sets.go
time.Sleep(time.Duration(r.Float64() * float64(time.Second))) // Pre-emptively connect the disks if possible. s.connectDisks(false) monitor := time.NewTimer(monitorInterval) defer monitor.Stop() for { select { case <-ctx.Done(): return case <-monitor.C: if serverDebugLog { console.Debugln("running drive monitoring") } s.connectDisks(true)
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 37K bytes - Click Count (1) -
cmd/xl-storage-disk-id-check.go
// Once the disk has been deemed ok, it will return to online status. func (p *xlStorageDiskIDCheck) monitorDiskStatus(spent time.Duration, fn string) { t := time.NewTicker(5 * time.Second) defer t.Stop() for range t.C { if contextCanceled(p.diskCtx) { return } err := p.storage.WriteAll(context.Background(), minioMetaTmpBucket, fn, toWrite) if err != nil { continue }
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Apr 25 05:41:04 GMT 2025 - 34.5K bytes - Click Count (0) -
src/test/java/jcifs/netbios/LmhostsTest.java
*/ class LmhostsTest { private Lmhosts lmhosts; private CIFSContext mockContext; private Configuration mockConfig; @TempDir Path tempDir; @BeforeEach void setUp() { lmhosts = new Lmhosts(); mockContext = mock(CIFSContext.class); mockConfig = mock(Configuration.class); when(mockContext.getConfig()).thenReturn(mockConfig); } @TestCreated: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Thu Aug 14 05:31:44 GMT 2025 - 18.2K bytes - Click Count (0) -
build-tools-internal/src/integTest/groovy/org/elasticsearch/gradle/internal/PublishPluginFuncTest.groovy
import org.junit.Ignore import org.xmlunit.builder.DiffBuilder import org.xmlunit.builder.Input import spock.lang.IgnoreRest class PublishPluginFuncTest extends AbstractGradleFuncTest { def setup() { // required for JarHell to work addSubProject(":libs:elasticsearch-core") << "apply plugin:'java'" } def "artifacts and tweaked pom is published"() { given: buildFile << """Created: Wed Apr 08 16:19:15 GMT 2026 - Last Modified: Tue Jun 22 07:24:59 GMT 2021 - 19K bytes - Click Count (0) -
tensorflow/c/eager/c_api_test_util.cc
std::vector<int64_t> subdiv_offsets; TFE_OpSetAttrIntList(op, "subdiv_offsets", subdiv_offsets.data(), subdiv_offsets.size()); return op; } TFE_Op* SendOp(TFE_Context* ctx, TFE_TensorHandle* in, const std::string& op_name, const std::string& send_device, const std::string& recv_device, tensorflow::uint64 send_device_incarnation) {
Created: Tue Apr 07 12:39:13 GMT 2026 - Last Modified: Thu Oct 09 05:56:18 GMT 2025 - 23.4K bytes - Click Count (0) -
src/test/java/org/codelibs/fess/job/IndexExportJobTest.java
public class IndexExportJobTest extends UnitFessTestCase { private IndexExportJob indexExportJob; private Path tempDir; @Override protected void setUp(TestInfo testInfo) throws Exception { super.setUp(testInfo); indexExportJob = new IndexExportJob(); tempDir = Files.createTempDirectory("indexExportJobTest"); } @OverrideCreated: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Sun Mar 15 09:08:38 GMT 2026 - 66.1K bytes - Click Count (0)