- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 327 for Palmer (0.22 sec)
-
internal/bucket/bandwidth/reader.go
if r.throttle == nil { return r.r.Read(buf) } if r.lastErr != nil { err = r.lastErr return } b := r.throttle.Burst() // maximum available tokens need := len(buf) // number of bytes requested by caller hdr := r.opts.HeaderSize // remaining header bytes var tokens int // number of tokens to request if hdr > 0 { // available tokens go towards header first if hdr < b { // all of header can be accommodated
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Wed Sep 06 03:21:59 GMT 2023 - 3.1K bytes - Viewed (0) -
internal/grid/connection.go
if err != nil { return nil, err } cl.subroute = &c.subID return cl, nil } // Request allows to do a single remote request. // 'req' will not be used after the call and caller can reuse. // If no deadline is set on ctx, a 1-minute deadline will be added. func (c *Connection) Request(ctx context.Context, h HandlerID, req []byte) ([]byte, error) { if !h.valid() { return nil, ErrUnknownHandler
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 42.6K bytes - Viewed (0) -
okhttp-sse/src/main/kotlin/okhttp3/sse/EventSource.kt
/** * Creates a new event source and immediately returns it. Creating an event source initiates an * asynchronous process to connect the socket. Once that succeeds or fails, `listener` will be * notified. The caller must cancel the returned event source when it is no longer in use. */ fun newEventSource( request: Request, listener: EventSourceListener, ): EventSource }
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 1.4K bytes - Viewed (0) -
tensorflow/c/experimental/next_pluggable_device/c_api.h
// invokes create_func to create the resource. `delete_func` is needed for // ResourceMgr to clean up the resource. `status` will be set. If `status` is // not OK, `*result_plugin_resource` will be set as nullptr. // // Caller does not take ownership of the `plugin_resource`. TF_CAPI_EXPORT extern void TF_LookupOrCreatePluginResource( TF_OpKernelContext* ctx, const char* container_name,
C - Registered: Tue Feb 27 12:39:08 GMT 2024 - Last Modified: Wed Dec 20 20:01:06 GMT 2023 - 7.2K bytes - Viewed (0) -
common-protos/k8s.io/api/admission/v1beta1/generated.proto
// e.g. `meta.k8s.io/v1.DeleteOptions` or `meta.k8s.io/v1.CreateOptions`. This may be // different than the options the caller provided. e.g. for a patch request the performed // Operation might be a CREATE, in which case the Options will a // `meta.k8s.io/v1.CreateOptions` even though the caller provided `meta.k8s.io/v1.PatchOptions`. // +optional optional k8s.io.apimachinery.pkg.runtime.RawExtension options = 12; }
Plain Text - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Mon Mar 11 18:43:24 GMT 2024 - 8.1K bytes - Viewed (0) -
tensorflow/c/c_api.h
// allocated to size `ninputs`. The caller should build `cond_graph` and // `body_graph` starting from the inputs, and store the final outputs in // `cond_output` and `body_outputs`. // // If `status` is OK, the caller must call either TF_FinishWhile or // TF_AbortWhile on the returned TF_WhileParams. If `status` isn't OK, the // returned TF_WhileParams is not valid, and the caller should not call
C - Registered: Tue Apr 23 12:39:09 GMT 2024 - Last Modified: Thu Oct 26 21:08:15 GMT 2023 - 82.3K bytes - Viewed (3) -
maven-api-impl/src/main/java/org/apache/maven/internal/impl/resolver/PluginsMetadataGenerator.java
* processes one artifact at a time and hence cannot associate the artifacts from the same project to use the * same version index. Allowing the caller to pass in metadata from a previous deployment allows to re-establish * the association between the artifacts of the same project. */
Java - Registered: Sun Apr 28 03:35:10 GMT 2024 - Last Modified: Fri Apr 12 10:50:18 GMT 2024 - 6.2K bytes - Viewed (0) -
maven-core/src/main/java/org/apache/maven/lifecycle/internal/DefaultLifecycleMappingDelegate.java
MojoNotFoundException, InvalidPluginDescriptorException { /* * Initialize mapping from lifecycle phase to bound mojos. The key set of this map denotes the phases the caller * is interested in, i.e. all phases up to and including the specified phase. */ Map<String, Map<Integer, List<MojoExecution>>> mappings = new LinkedHashMap<>();
Java - Registered: Sun Apr 28 03:35:10 GMT 2024 - Last Modified: Wed Jan 10 12:55:54 GMT 2024 - 6.5K bytes - Viewed (0) -
soft_delete.go
) type DeletedAt sql.NullTime // Scan implements the Scanner interface. func (n *DeletedAt) Scan(value interface{}) error { return (*sql.NullTime)(n).Scan(value) } // Value implements the driver Valuer interface. func (n DeletedAt) Value() (driver.Value, error) { if !n.Valid { return nil, nil } return n.Time, nil } func (n DeletedAt) MarshalJSON() ([]byte, error) { if n.Valid {
Go - Registered: Sun Apr 28 09:35:09 GMT 2024 - Last Modified: Wed Feb 01 06:40:55 GMT 2023 - 4.5K bytes - Viewed (0) -
maven-builder-support/src/main/java/org/apache/maven/building/Source.java
* */ public interface Source { /** * Gets a byte stream to the source contents. Closing the returned stream is the responsibility of the caller. * * @return A byte stream to the source contents, never {@code null}. * @throws IOException in case of IO issue */ InputStream getInputStream() throws IOException; /**
Java - Registered: Sun Apr 28 03:35:10 GMT 2024 - Last Modified: Wed Sep 06 08:39:32 GMT 2023 - 1.7K bytes - Viewed (0)