Search Options

Results per page
Sort
Preferred Languages
Advance

Results 381 - 390 of 1,339 for contextos (0.07 sec)

  1. cni/pkg/install/cniconfig_test.go

    			}
    
    			// Handle chained CNI plugin cases
    			// Call with goroutine to test fsnotify watcher
    			parent, cancel := context.WithCancel(context.Background())
    			defer cancel()
    			resultChan, errChan := make(chan string, 1), make(chan error, 1)
    			go func(resultChan chan string, errChan chan error, ctx context.Context, cniConfName, mountedCNINetDir string, chained bool) {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Aug 01 18:38:14 UTC 2024
    - 15.3K bytes
    - Viewed (0)
  2. cmd/grid.go

    var globalGridStart = make(chan struct{})
    
    // globalLockGridStart is a channel that will block startup of lock grid connections until closed.
    var globalLockGridStart = make(chan struct{})
    
    func initGlobalGrid(ctx context.Context, eps EndpointServerPools) error {
    	hosts, local := eps.GridHosts()
    	lookupHost := globalDNSCache.LookupHost
    	g, err := grid.NewManager(ctx, grid.ManagerOptions{
    		// Pass Dialer for websocket grid, make sure we do not
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 3.7K bytes
    - Viewed (0)
  3. cmd/metacache-manager.go

    	// We should have either a trashed bucket or this
    	return metacache{}, errVolumeNotFound
    }
    
    // getBucket will get a bucket metacache or load it from disk if needed.
    func (m *metacacheManager) getBucket(ctx context.Context, bucket string) *bucketMetacache {
    	m.init.Do(m.initManager)
    
    	// Return a transient bucket for invalid or system buckets.
    	m.mu.RLock()
    	b, ok := m.buckets[bucket]
    	if ok {
    		m.mu.RUnlock()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 25 00:44:15 UTC 2022
    - 5.2K bytes
    - Viewed (0)
  4. cmd/data-usage_test.go

    	xls := xlStorage{drivePath: base, diskInfoCache: cachevalue.New[DiskInfo]()}
    	xls.diskInfoCache.InitOnce(time.Second, cachevalue.Opts{}, func(ctx context.Context) (DiskInfo, error) {
    		return DiskInfo{Total: 1 << 40, Free: 1 << 40}, nil
    	})
    	weSleep := func() bool { return false }
    
    	got, err := scanDataFolder(context.Background(), nil, &xls, dataUsageCache{Info: dataUsageCacheInfo{Name: bucket}}, getSize, 0, weSleep)
    	if err != nil {
    		t.Fatal(err)
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 04 22:23:33 UTC 2024
    - 14.7K bytes
    - Viewed (0)
  5. src/main/java/jcifs/smb/MIEName.java

     */
    package jcifs.smb;
    
    
    import java.util.Objects;
    
    import org.bouncycastle.asn1.ASN1ObjectIdentifier;
    
    
    /**
     * This class is used to parse the name of context initiator and
     * context acceptor which are retrieved from GSSContext.
     * 
     * @author Shun
     *
     */
    class MIEName {
    
        private static byte[] TOK_ID = {
            04, 01
        };
        private static int TOK_ID_SIZE = 2;
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Jul 01 13:12:10 UTC 2018
    - 3.5K bytes
    - Viewed (0)
  6. cmd/bitrot-whole.go

    //
    // You should have received a copy of the GNU Affero General Public License
    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package cmd
    
    import (
    	"context"
    	"hash"
    	"io"
    )
    
    // Implementation to calculate bitrot for the whole file.
    type wholeBitrotWriter struct {
    	disk      StorageAPI
    	volume    string
    	filePath  string
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jan 31 02:11:45 UTC 2024
    - 2.7K bytes
    - Viewed (0)
  7. .github/ISSUE_TEMPLATE/10_contributor_bug_report.yml

          description: Tell us what should happen
        validations:
          required: true
      - type: textarea
        id: context
        attributes:
          label: Context (optional)
          description: |
            How has this issue affected you? What are you trying to accomplish?
            Providing context helps us come up with a solution that is most useful in the real world
        validations:
          required: false
      - type: textarea
    Registered: Wed Nov 06 11:36:14 UTC 2024
    - Last Modified: Mon Sep 09 14:48:49 UTC 2024
    - 3K bytes
    - Viewed (0)
  8. .github/workflows/test.yml

          - synchronize
      schedule:
        # cron every week on monday
        - cron: "0 0 * * 1"
    
    env:
      UV_SYSTEM_PYTHON: 1
    
    jobs:
      lint:
        runs-on: ubuntu-latest
        steps:
          - name: Dump GitHub context
            env:
              GITHUB_CONTEXT: ${{ toJson(github) }}
            run: echo "$GITHUB_CONTEXT"
          - uses: actions/checkout@v4
          - name: Set up Python
            uses: actions/setup-python@v5
            with:
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sat Oct 12 12:27:19 UTC 2024
    - 4.2K bytes
    - Viewed (0)
  9. cmd/admin-handlers-users-race_test.go

    //go:build !race
    // +build !race
    
    // Tests in this file are not run under the `-race` flag as they are too slow
    // and cause context deadline errors.
    
    package cmd
    
    import (
    	"context"
    	"fmt"
    	"runtime"
    	"testing"
    	"time"
    
    	"github.com/minio/madmin-go/v3"
    	minio "github.com/minio/minio-go/v7"
    	"github.com/minio/pkg/v3/sync/errgroup"
    )
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 28 09:06:25 UTC 2024
    - 4K bytes
    - Viewed (0)
  10. cmd/metrics-v2.go

    // to populate new values upon cache invalidation.
    func (g *MetricsGroupV2) RegisterRead(read func(context.Context) []MetricV2) {
    	g.metricsCache = cachevalue.NewFromFunc(g.cacheInterval,
    		cachevalue.Opts{ReturnLastGood: true},
    		func(ctx context.Context) ([]MetricV2, error) {
    			if g.metricsGroupOpts.dependGlobalObjectAPI {
    				objLayer := newObjectLayerFn()
    				// Service not initialized yet
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 131.9K bytes
    - Viewed (0)
Back to top