Search Options

Results per page
Sort
Preferred Languages
Advance

Results 161 - 170 of 453 for ctx_ (0.06 sec)

  1. istioctl/pkg/injector/injector-list.go

    				return fmt.Errorf("failed to create k8s client: %v", err)
    			}
    
    			nsList, err := getNamespaces(context.Background(), client, ctx.IstioNamespace())
    			if err != nil {
    				return err
    			}
    
    			if ctx.Namespace() != "" {
    				for _, namespace := range nsList {
    					if namespace.Name == ctx.Namespace() {
    						nsList = []corev1.Namespace{namespace}
    						break
    					}
    				}
    			}
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Oct 18 11:39:52 UTC 2024
    - 10.6K bytes
    - Viewed (0)
  2. cni/pkg/install/install_test.go

    			defer ticker.Stop()
    			readyChan := make(chan bool)
    			go func(ctx context.Context, tick <-chan time.Time) {
    				for {
    					select {
    					case <-ctx.Done():
    						return
    					case <-tick:
    						if isReady.Load().(bool) {
    							readyChan <- true
    						}
    					}
    				}
    			}(ctx, ticker.C)
    
    			// Listen to sleepWatchInstall return value
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Jan 26 20:34:28 UTC 2024
    - 11.1K bytes
    - Viewed (0)
  3. src/main/java/jcifs/smb/SmbSessionImpl.java

            }
    
            while ( true ) {
                Subject s = this.credentials.getSubject();
                if ( ctx == null ) {
                    ctx = createContext(trans, tdomain, negoResp, !anonymous, s);
                }
                token = createToken(ctx, token, s);
    
                if ( token != null ) {
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Nov 14 17:41:04 UTC 2021
    - 49K bytes
    - Viewed (0)
  4. src/test/java/jcifs/tests/KerberosTest.java

            Subject s = getInitiatorSubject(getTestUser(), getTestUserPassword(), getTestUserDomainRequired(), null);
            CIFSContext ctx = getContext().withCredentials(new Kerb5Authenticator(s, getTestUserDomainRequired(), getTestUser(), getTestUserPassword()));
            try ( SmbResource f = new SmbFile(getTestShareURL(), ctx) ) {
                f.exists();
            }
            catch ( SmbUnsupportedOperationException e ) {
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Mar 01 09:46:04 UTC 2020
    - 11.5K bytes
    - Viewed (0)
  5. src/main/java/org/codelibs/fess/helper/LanguageHelper.java

            final String code = Arrays.stream(langFields).map(s -> "ctx._source['" + s + "_'+ctx._source." + langField + "]=ctx._source." + s)
                    .collect(Collectors.joining(";"));
            if (logger.isDebugEnabled()) {
                logger.debug("reindex script: {}", code);
            }
            return "if(ctx._source." + langField + "!=null){" + code + "}";
        }
    
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:53:18 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  6. internal/http/dial_dnscache.go

    		}).DialContext
    	}
    
    	return func(ctx context.Context, network, addr string) (conn net.Conn, err error) {
    		host, port, err := net.SplitHostPort(addr)
    		if err != nil {
    			return nil, err
    		}
    
    		if net.ParseIP(host) != nil {
    			// For IP only setups there is no need for DNS lookups.
    			return baseDialCtx(ctx, "tcp", addr)
    		}
    
    		ips, err := lookupHost(ctx, host)
    		if err != nil {
    			return nil, err
    		}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 03 19:30:51 UTC 2023
    - 2.6K bytes
    - Viewed (0)
  7. cni/pkg/install/cniconfig.go

    		return "", err
    	}
    	marshalledJSON = append(marshalledJSON, "\n"...)
    
    	return writeCNIConfig(ctx, marshalledJSON, cfg)
    }
    
    // writeCNIConfig will
    // 1. read in the existing CNI config file
    // 2. append the `istio`-specific entry
    // 3. write the combined result back out to the same path, overwriting the original.
    func writeCNIConfig(ctx context.Context, pluginConfig []byte, cfg *config.InstallConfig) (string, error) {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Aug 01 18:38:14 UTC 2024
    - 8.2K bytes
    - Viewed (0)
  8. cmd/sftp-server_test.go

    	}
    }
    
    func (s *TestSuiteIAM) SFTPInvalidServiceAccountPassword(c *check) {
    	ctx, cancel := context.WithTimeout(context.Background(), testDefaultTimeout)
    	defer cancel()
    
    	accessKey, secretKey := mustGenerateCredentials(c)
    	err := s.adm.SetUser(ctx, accessKey, secretKey, madmin.AccountEnabled)
    	if err != nil {
    		c.Fatalf("Unable to set user: %v", err)
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 28 09:06:25 UTC 2024
    - 8.3K bytes
    - Viewed (0)
  9. internal/lsync/lrwmutex_test.go

    )
    
    func testSimpleWriteLock(t *testing.T, duration time.Duration) (locked bool) {
    	ctx := context.Background()
    	lrwm := NewLRWMutex()
    
    	if !lrwm.GetRLock(ctx, "", "object1", time.Second) {
    		panic("Failed to acquire read lock")
    	}
    	// fmt.Println("1st read lock acquired, waiting...")
    
    	if !lrwm.GetRLock(ctx, "", "object1", time.Second) {
    		panic("Failed to acquire read lock")
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Mar 05 04:57:35 UTC 2023
    - 7.9K bytes
    - Viewed (0)
  10. cmd/untar.go

    		dec, err := zstd.NewReader(bf, zstd.WithDecoderMaxWindow(16<<20))
    		if err != nil {
    			return err
    		}
    		defer dec.Close()
    		r = dec
    	case formatBZ2:
    		ctx, cancel := context.WithCancel(ctx)
    		defer cancel()
    		r = pbzip2.NewReader(ctx, bf, pbzip2.DecompressionOptions(
    			pbzip2.BZConcurrency((runtime.GOMAXPROCS(0)+1)/2),
    			pbzip2.BZConcurrencyPool(bz2Limiter)))
    	case formatLZ4:
    		r = lz4.NewReader(bf)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 22 00:33:43 UTC 2024
    - 6K bytes
    - Viewed (2)
Back to top