Search Options

Results per page
Sort
Preferred Languages
Advance

Results 381 - 390 of 467 for runnable (0.11 sec)

  1. cmd/xl-storage-disk-id-check.go

    				spent := time.Since(started)
    				goOffline(fmt.Errorf("unable to write+read for %v", spent.Round(time.Millisecond)), spent)
    			}
    		}()
    
    		func() {
    			defer dcancel()
    
    			err := p.storage.WriteAll(ctx, minioMetaTmpBucket, fn, toWrite)
    			if err != nil {
    				if osErrToFileErr(err) == errFaultyDisk {
    					goOffline(fmt.Errorf("unable to write: %w", err), 0)
    				}
    				return
    			}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:56:26 UTC 2024
    - 34.5K bytes
    - Viewed (0)
  2. okhttp/src/main/kotlin/okhttp3/internal/publicsuffix/PublicSuffixDatabase.kt

            Thread.currentThread().interrupt() // Retain interrupted status.
          }
        }
    
        check(::publicSuffixListBytes.isInitialized) {
          // May have failed with an IOException
          "Unable to load $PUBLIC_SUFFIX_RESOURCE resource from the classpath."
        }
    
        // Break apart the domain into UTF-8 labels, i.e. foo.bar.com turns into [foo, bar, com].
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 11.7K bytes
    - Viewed (0)
  3. internal/logger/target/kafka/kafka.go

    	queueDir := filepath.Join(h.kconfig.QueueDir, h.Name())
    	queueStore := store.NewQueueStore[interface{}](queueDir, uint64(h.kconfig.QueueSize), kafkaLoggerExtension)
    	if err = queueStore.Open(); err != nil {
    		return fmt.Errorf("unable to initialize the queue store of %s webhook: %w", h.Name(), err)
    	}
    	ctx, cancel := context.WithCancel(ctx)
    	h.store = queueStore
    	h.storeCtxCancel = cancel
    	store.StreamItems(h.store, h, ctx.Done(), h.kconfig.LogOnce)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 10.2K bytes
    - Viewed (0)
  4. tensorflow/c/eager/c_api_experimental.cc

      auto* function_def = tensorflow::unwrap(ctx)->FindFunctionDef(function_name);
      if (function_def == nullptr) {
        status->status = tensorflow::errors::NotFound(
            "Unable to find FunctionDef with name: ", function_name);
        return;
      }
      string str = function_def->SerializeAsString();
      void* data = tensorflow::port::Malloc(str.length());
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Sat Oct 12 05:11:17 UTC 2024
    - 35.9K bytes
    - Viewed (0)
  5. guava-tests/test/com/google/common/hash/HashingTest.java

              } else if (method.getParameterTypes()[i] == long.class) {
                params1[i] = random.nextLong();
                params2[i] = random.nextLong();
              } else {
                fail("Unable to create a random parameter for " + method.getParameterTypes()[i]);
              }
            }
            HashFunction hashFunction1a = (HashFunction) method.invoke(clazz, params1);
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Jul 09 17:40:09 UTC 2024
    - 26.3K bytes
    - Viewed (0)
  6. impl/maven-cli/src/main/java/org/apache/maven/cling/invoker/LookupInvoker.java

                            causes.add(e);
                        }
                    }
                }
                if (causes != null) {
                    InvokerException exception = new InvokerException("Unable to close context");
                    causes.forEach(exception::addSuppressed);
                    throw exception;
                }
            }
        }
    
        protected final ProtoLookup protoLookup;
    
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 38K bytes
    - Viewed (0)
  7. docs/en/docs/tutorial/path-params.md

    ```JSON
    {
      "detail": [
        {
          "type": "int_parsing",
          "loc": [
            "path",
            "item_id"
          ],
          "msg": "Input should be a valid integer, unable to parse string as an integer",
          "input": "foo",
          "url": "https://errors.pydantic.dev/2.1/v/int_parsing"
        }
      ]
    }
    ```
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 9.1K bytes
    - Viewed (0)
  8. internal/http/listener_test.go

    	return strconv.Itoa(int(atomic.AddUint32(&serverPort, 1)))
    }
    
    func getNonLoopBackIP(t *testing.T) string {
    	localIP4 := set.NewStringSet()
    	addrs, err := net.InterfaceAddrs()
    	if err != nil {
    		t.Fatalf("%s.  Unable to get IP addresses of this host.", err)
    	}
    
    	for _, addr := range addrs {
    		var ip net.IP
    		switch v := addr.(type) {
    		case *net.IPNet:
    			ip = v.IP
    		case *net.IPAddr:
    			ip = v.IP
    		}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 17:41:02 UTC 2024
    - 11.8K bytes
    - Viewed (0)
  9. docs/tr/docs/tutorial/path-params.md

    ```JSON
    {
      "detail": [
        {
          "type": "int_parsing",
          "loc": [
            "path",
            "item_id"
          ],
          "msg": "Input should be a valid integer, unable to parse string as an integer",
          "input": "foo",
          "url": "https://errors.pydantic.dev/2.1/v/int_parsing"
        }
      ]
    }
    ```
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 10.8K bytes
    - Viewed (0)
  10. internal/grid/manager.go

    			w.WriteHeader(http.StatusForbidden)
    			return
    		}
    		conn, _, _, err := ws.UpgradeHTTP(req, w)
    		if err != nil {
    			if debugPrint {
    				fmt.Printf("grid: Unable to upgrade: %v. http.ResponseWriter is type %T\n", err, w)
    			}
    			w.WriteHeader(http.StatusUpgradeRequired)
    			return
    		}
    		m.IncomingConn(ctx, conn)
    	}
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 10.6K bytes
    - Viewed (0)
Back to top