Search Options

Results per page
Sort
Preferred Languages
Advance

Results 101 - 110 of 220 for unpack (0.06 sec)

  1. cmd/bootstrap-messages.go

    type bootstrapTracer struct {
    	mu   sync.RWMutex
    	info []madmin.TraceInfo
    }
    
    var globalBootstrapTracer = &bootstrapTracer{}
    
    func (bs *bootstrapTracer) Record(info madmin.TraceInfo) {
    	bs.mu.Lock()
    	defer bs.mu.Unlock()
    
    	if len(bs.info) > bootstrapTraceLimit {
    		return
    	}
    	bs.info = append(bs.info, info)
    }
    
    func (bs *bootstrapTracer) Events() []madmin.TraceInfo {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 23 10:07:06 UTC 2023
    - 1.7K bytes
    - Viewed (0)
  2. cmd/ilm-config.go

    }
    
    func (c *ilmConfig) getTransitionWorkers() int {
    	c.mu.RLock()
    	defer c.mu.RUnlock()
    
    	return c.cfg.TransitionWorkers
    }
    
    func (c *ilmConfig) update(cfg ilm.Config) {
    	c.mu.Lock()
    	defer c.mu.Unlock()
    
    	c.cfg = cfg
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Mar 05 02:50:24 UTC 2024
    - 1.3K bytes
    - Viewed (0)
  3. tests/prepared_stmt_test.go

    	}
    
    	pdb.Mux.Lock()
    	if len(pdb.Stmts) == 0 {
    		pdb.Mux.Unlock()
    		t.Fatalf("prepared stmt can not be empty")
    	}
    	pdb.Mux.Unlock()
    
    	pdb.Reset()
    	pdb.Mux.Lock()
    	defer pdb.Mux.Unlock()
    	if len(pdb.Stmts) != 0 {
    		t.Fatalf("prepared stmt should be empty")
    	}
    }
    
    func isUsingClosedConnError(err error) bool {
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Thu Aug 22 11:02:05 UTC 2024
    - 8.5K bytes
    - Viewed (0)
  4. cmd/metacache-set.go

    	go func() {
    		var results metaCacheEntriesSorted
    		var returned bool
    		for entry := range in {
    			if returned {
    				// past limit
    				continue
    			}
    			mu.Lock()
    			returned = done
    			mu.Unlock()
    			if returned {
    				resCh = nil
    				continue
    			}
    			if !o.IncludeDirectories && (entry.isDir() || (!o.Versioned && entry.isObjectDir() && entry.isLatestDeletemarker())) {
    				continue
    			}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 12 16:23:16 UTC 2024
    - 30.7K bytes
    - Viewed (0)
  5. internal/logger/target/http/http.go

    	name := h.Name()
    
    	defer func() {
    		// re-load the global buffer pointer
    		// in case it was modified by a new target.
    		logChLock.Lock()
    		currentGlobalBuffer, ok := logChBuffers[name]
    		logChLock.Unlock()
    		if !ok {
    			return
    		}
    
    		for _, v := range entries {
    			select {
    			case currentGlobalBuffer <- v:
    			default:
    			}
    		}
    
    		if mainWorker {
    		drain:
    			for {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Sep 11 22:20:42 UTC 2024
    - 15.6K bytes
    - Viewed (0)
  6. cmd/signals.go

    	exit := func(success bool) {
    		if globalLoggerOutput != nil {
    			globalLoggerOutput.Close()
    		}
    
    		// If global profiler is set stop before we exit.
    		globalProfilerMu.Lock()
    		defer globalProfilerMu.Unlock()
    		for _, p := range globalProfiler {
    			p.Stop()
    		}
    
    		if success {
    			os.Exit(0)
    		}
    
    		os.Exit(1)
    	}
    
    	stopProcess := func() bool {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Sep 04 17:02:39 UTC 2024
    - 3.2K bytes
    - Viewed (0)
  7. android/guava-tests/test/com/google/common/util/concurrent/InterruptibleTaskTest.java

                try {
                  new CountDownLatch(1).await(); // the interrupt will wake us up
                } catch (InterruptedException ie) {
                  // continue
                }
                LockSupport.unpark(Thread.currentThread()); // simulate a spurious wakeup.
                return null;
              }
    
              @Override
              boolean isDone() {
                return false;
              }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 6.6K bytes
    - Viewed (0)
  8. src/main/java/org/codelibs/fess/mylasta/direction/sponsor/FessCurtainBeforeHook.java

        @Override
        public void hook(final FwAssistantDirector assistantDirector) {
            processDBFluteSystem();
        }
    
        protected void processDBFluteSystem() {
            DBFluteSystem.unlock();
            DBFluteSystem.setFinalTimeZoneProvider(createFinalTimeZoneProvider());
            DBFluteSystem.lock();
        }
    
        protected DfFinalTimeZoneProvider createFinalTimeZoneProvider() {
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 1.8K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/util/concurrent/InterruptibleTask.java

            try {
              ((Thread) currentRunner).interrupt();
            } finally {
              Runnable prev = getAndSet(DONE);
              if (prev == PARKED) {
                LockSupport.unpark((Thread) currentRunner);
              }
            }
          }
        }
      }
    
      /**
       * Using this as the blocker object allows introspection and debugging tools to see that the
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 02:42:09 UTC 2024
    - 10.1K bytes
    - Viewed (0)
  10. cmd/bootstrap-peer-server.go

    				defer wg.Done()
    
    				if clnt.gridConn.State() != grid.StateConnected {
    					mu.Lock()
    					offlineEndpoints = append(offlineEndpoints, fmt.Errorf("%s is unreachable: %w", clnt, grid.ErrDisconnected))
    					mu.Unlock()
    					return
    				}
    
    				ctx, cancel := context.WithTimeout(ctx, 2*time.Second)
    				defer cancel()
    
    				err := clnt.Verify(ctx, srcCfg)
    				mu.Lock()
    				if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 01 22:13:18 UTC 2024
    - 8.4K bytes
    - Viewed (0)
Back to top