Search Options

Results per page
Sort
Preferred Languages
Advance

Results 91 - 100 of 227 for unpack (0.12 sec)

  1. cmd/service.go

    	globalServiceFreezeMu.Lock()
    	// If multiple calls, first one creates channel.
    	globalServiceFreezeCnt++
    	if globalServiceFreezeCnt == 1 {
    		globalServiceFreeze.Store(make(chan struct{}))
    	}
    	globalServiceFreezeMu.Unlock()
    }
    
    // unfreezeServices will unfreeze all incoming S3 API calls.
    // For each call, unfreezeServices must be called once.
    func unfreezeServices() {
    	// We need a lock since we need the 2 atomic values to remain in sync.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Feb 28 07:02:14 UTC 2024
    - 3.8K bytes
    - Viewed (0)
  2. cmd/metacache-server-pool.go

    				defer wg.Done()
    				err := set.listPath(listCtx, o, innerResults)
    				mu.Lock()
    				defer mu.Unlock()
    				if err == nil {
    					allAtEOF = false
    				}
    				errs[i] = err
    			}(len(errs), set)
    			errs = append(errs, nil)
    		}
    	}
    	mu.Unlock()
    
    	// Gather results to a single channel.
    	// Quorum is one since we are merging across sets.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 12 16:23:16 UTC 2024
    - 12.7K bytes
    - Viewed (0)
  3. src/test/resources/plugin/repo3/index.html

    <a href="fess-webapp-semantic-search/" title="fess-webapp-semantic-search/">fess-webapp-semantic-search/</a>                                     -         -      
    <a href="fess-xpack/" title="fess-xpack/">fess-xpack/</a>                                                      -         -      
    		</pre>
    	</main>
    	<hr/>
    </body>
    
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Mon Jun 17 13:30:41 UTC 2024
    - 6.2K bytes
    - Viewed (0)
  4. cmd/lock-rest-server.go

    // UnlockHandler - releases the acquired lock.
    func (l *lockRESTServer) UnlockHandler(args *dsync.LockArgs) (*dsync.LockResp, *grid.RemoteErr) {
    	resp := lockRPCUnlock.NewResponse()
    	_, err := l.ll.Unlock(context.Background(), *args)
    	// Ignore the Unlock() "reply" return value because if err == nil, "reply" is always true
    	// Consequently, if err != nil, reply is always false
    	return l.makeResp(resp, err)
    }
    
    // RLockHandler - Acquires an RLock.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 5.8K bytes
    - Viewed (0)
  5. cmd/batch-handlers.go

    		binary.LittleEndian.PutUint16(data[2:4], version)
    
    		buf, err := ri.MarshalMsg(data)
    		ri.mu.Unlock()
    		if err != nil {
    			return err
    		}
    		path, err := ri.getJobReportPath()
    		if err != nil {
    			batchLogIf(ctx, err)
    			return err
    		}
    		return saveConfig(ctx, api, path, buf)
    	}
    	ri.mu.Unlock()
    	return nil
    }
    
    // Note: to be used only with batch jobs that affect multiple versions through
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 18 15:32:09 UTC 2024
    - 62.2K bytes
    - Viewed (0)
  6. cmd/dynamic-timeouts.go

    			logCopy := [dynamicTimeoutLogSize]time.Duration{}
    			copy(logCopy[:], dt.log[:])
    
    			// reset log entries
    			atomic.StoreInt64(&dt.entries, 0)
    			dt.mutex.Unlock()
    
    			dt.adjust(logCopy)
    			return
    		}
    		dt.mutex.Unlock()
    	}
    }
    
    // adjust changes the value of the dynamic timeout based on the
    // previous results
    func (dt *dynamicTimeout) adjust(entries [dynamicTimeoutLogSize]time.Duration) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Aug 19 23:21:05 UTC 2022
    - 4.5K bytes
    - Viewed (0)
  7. internal/s3select/progress.go

    	// This allows another goroutine to close the reader.
    	pr.closedMu.Lock()
    	defer pr.closedMu.Unlock()
    	if pr.closed {
    		return 0, errors.New("progressReader: read after Close")
    	}
    	return pr.processedReader.Read(p)
    }
    
    func (pr *progressReader) Close() error {
    	pr.closedMu.Lock()
    	defer pr.closedMu.Unlock()
    	if pr.closed {
    		return nil
    	}
    	pr.closed = true
    	if pr.closer != nil {
    		pr.closer.Close()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 22 00:33:43 UTC 2024
    - 4.3K bytes
    - Viewed (0)
  8. internal/config/identity/openid/provider/keycloak.go

    		return err
    	}
    	defer resp.Body.Close()
    
    	var accessToken Token
    	if err = json.NewDecoder(resp.Body).Decode(&accessToken); err != nil {
    		return err
    	}
    
    	k.Lock()
    	k.accessToken = accessToken
    	k.Unlock()
    	return nil
    }
    
    // LookupUser lookup user by their userid.
    func (k *KeycloakProvider) LookupUser(userid string) (User, error) {
    	req, err := http.NewRequest(http.MethodGet, k.adminURL, nil)
    	if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Jul 14 18:12:07 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  9. cmd/bucket-replication-metrics.go

    func (m *rateMeasurement) updateExponentialMovingAverage(endTime time.Time) {
    	// Calculate aggregate avg bandwidth and exp window avg
    	m.lock.Lock()
    	defer func() {
    		m.startTime = endTime
    		m.lock.Unlock()
    	}()
    
    	if m.startTime.IsZero() {
    		return
    	}
    
    	if endTime.Before(m.startTime) {
    		return
    	}
    
    	duration := endTime.Sub(m.startTime)
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 14.2K bytes
    - Viewed (0)
  10. cmd/erasure-sets.go

    				if globalIsDistErasure {
    					globalLocalSetDrives[s.poolIndex][setIndex][diskIndex] = disk
    				}
    				globalLocalDrivesMap[disk.Endpoint().String()] = disk
    				globalLocalDrivesMu.Unlock()
    			}
    			s.erasureDisksMu.Unlock()
    		}(endpoint)
    	}
    
    	wg.Wait()
    }
    
    // monitorAndConnectEndpoints this is a monitoring loop to keep track of disconnected
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 27 10:41:37 UTC 2024
    - 37K bytes
    - Viewed (1)
Back to top