- Sort Score
- Result 10 results
- Languages All
Results 261 - 270 of 1,339 for contextos (0.06 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)