Search Options

Results per page
Sort
Preferred Languages
Advance

Results 261 - 270 of 1,339 for contextos (0.06 sec)

  1. internal/http/dial_dnscache.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package http
    
    import (
    	"context"
    	"net"
    	"time"
    )
    
    // LookupHost is a function to make custom lookupHost for optional cached DNS requests
    type LookupHost func(ctx context.Context, host string) (addrs []string, err error)
    
    // DialContextWithLookupHost is a helper function which returns `net.DialContext` function.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 03 19:30:51 UTC 2023
    - 2.6K bytes
    - Viewed (0)
  2. cni/cmd/install-cni/main.go

    // limitations under the License.
    
    package main
    
    import (
    	"context"
    	"os"
    	"os/signal"
    	"syscall"
    
    	"istio.io/istio/cni/pkg/cmd"
    	"istio.io/istio/pkg/log"
    )
    
    func main() {
    	// Create context that cancels on termination signal
    	ctx, cancel := context.WithCancel(context.Background())
    	sigChan := make(chan os.Signal, 1)
    	signal.Notify(sigChan, os.Interrupt, syscall.SIGTERM)
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Tue May 23 17:08:31 UTC 2023
    - 1.2K bytes
    - Viewed (0)
  3. impl/maven-cli/src/main/java/org/apache/maven/cling/invoker/mvn/BaseMavenParser.java

        @Override
        protected List<O> parseCliOptions(LocalContext context) throws ParserException, IOException {
            ArrayList<O> result = new ArrayList<>();
            // CLI args
            result.add(parseMavenCliOptions(context.parserRequest.args()));
            // maven.config; if exists
            Path mavenConfig = context.rootDirectory != null ? context.rootDirectory.resolve(".mvn/maven.config") : null;
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 2.9K bytes
    - Viewed (0)
  4. cmd/metacache-server-pool.go

    			c = &resp
    		} else {
    			rctx, cancel := context.WithTimeout(ctx, 5*time.Second)
    			c, err = rpc.GetMetacacheListing(rctx, *o)
    			cancel()
    		}
    		if err != nil {
    			if errors.Is(err, context.Canceled) {
    				// Context is canceled, return at once.
    				// request canceled, no entries to return
    				return entries, io.EOF
    			}
    			if !IsErr(err, context.DeadlineExceeded, grid.ErrDisconnected) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 12 16:23:16 UTC 2024
    - 12.7K bytes
    - Viewed (0)
  5. istioctl/pkg/kubeinject/google.go

    package kubeinject
    
    import (
    	"context"
    	"fmt"
    	"net/http"
    	"strings"
    
    	"golang.org/x/oauth2"
    	"golang.org/x/oauth2/google"
    )
    
    func isMCPAddr(addr string) bool {
    	// A bit inexact but should be good enough.
    	return strings.Contains(addr, ".googleapis.com/") || strings.Contains(addr, ".googleapis.com:443/")
    }
    
    func mcpTransport(ctx context.Context, tr http.RoundTripper) (http.RoundTripper, error) {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Jun 15 15:02:17 UTC 2023
    - 1.2K bytes
    - Viewed (0)
  6. cmd/generic-handlers.go

    			}
    		}
    		sr, err := globalDNSConfig.Get(bucket)
    		if err != nil {
    			defer logger.AuditLog(r.Context(), w, r, mustGetClaimsFromToken(r))
    			if err == dns.ErrNoEntriesFound {
    				writeErrorResponse(r.Context(), w, errorCodes.ToAPIErr(ErrNoSuchBucket), r.URL)
    			} else {
    				writeErrorResponse(r.Context(), w, toAPIError(r.Context(), err), r.URL)
    			}
    			return
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 20.5K bytes
    - Viewed (0)
  7. okhttp-android/src/androidTest/kotlin/okhttp3/android/AndroidAsyncDnsTest.kt

        assertThat(allAddresses).isEmpty()
      }
    
      @Test
      fun testRequestOnNetwork() {
        assumeNetwork()
    
        val context = InstrumentationRegistry.getInstrumentation().context
        val connectivityManager =
          context.getSystemService(Context.CONNECTIVITY_SERVICE) as ConnectivityManager
    
        val network =
          connectivityManager.activeNetwork ?: throw AssumptionViolatedException("No active network")
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 5.7K bytes
    - Viewed (0)
  8. cmd/auth-handler.go

    	_, _, s3Err = checkRequestAuthTypeCredential(ctx, r, action)
    	return s3Err
    }
    
    func authenticateRequest(ctx context.Context, r *http.Request, action policy.Action) (s3Err APIErrorCode) {
    	if logger.GetReqInfo(ctx) == nil {
    		bugLogIf(ctx, errors.New("unexpected context.Context does not have a logger.ReqInfo"), logger.ErrorKind)
    		return ErrAccessDenied
    	}
    
    	var cred auth.Credentials
    	var owner bool
    	switch getRequestAuthType(r) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 17 16:45:46 UTC 2024
    - 26.1K bytes
    - Viewed (0)
  9. test-site/app/models/SuggestIndex.java

    package models;
    
    import components.*;
    import org.codelibs.fess.suggest.Suggester;
    import org.codelibs.fess.suggest.exception.SuggesterException;
    import org.codelibs.fess.suggest.index.contents.document.DocumentReader;
    import org.codelibs.fess.suggest.index.contents.document.ESSourceReader;
    import org.codelibs.fess.suggest.request.suggest.SuggestResponse;
    
    public class SuggestIndex {
        public SuggestResponse suggest(String query) {
    Registered: Fri Nov 08 09:08:12 UTC 2024
    - Last Modified: Fri Nov 06 08:48:32 UTC 2015
    - 964 bytes
    - Viewed (0)
  10. tensorflow/c/eager/parallel_device/parallel_device_remote_test.cc

                      .ok());
      ASSERT_TRUE(worker_server2->Start().ok());
    
      TFE_ContextSetServerDef(context.get(), 0, serialized.data(),
                              serialized.size(), status.get());
      EXPECT_EQ(TF_OK, TF_GetCode(status.get())) << TF_Message(status.get());
    
      BasicTestsForTwoDevices(context.get(),
                              "/job:worker/replica:0/task:1/device:CPU:0",
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Wed Jul 10 07:18:05 UTC 2024
    - 6.8K bytes
    - Viewed (0)
Back to top