- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 180 for Wall (0.16 sec)
-
cmd/storage-rest-client.go
_, err := storageWriteAllRPC.Call(ctx, client.gridConn, &WriteAllHandlerParams{ DiskID: *client.diskID.Load(), Volume: volume, FilePath: path, Buf: b, }) return toStorageErr(err) } // CheckParts - stat all file parts. func (client *storageRESTClient) CheckParts(ctx context.Context, volume string, path string, fi FileInfo) error {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 26.1K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealCall.kt
// the call, but they may be accessed by other threads for duplex requests. /** True if this call still has a request body open. */ private var requestBodyOpen = false /** True if this call still has a response body open. */ private var responseBodyOpen = false /** True if there are more exchanges expected for this call. */ private var expectMoreExchanges = true
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 17.9K bytes - Viewed (2) -
common/config/.golangci.yml
# with golangci-lint call it on a directory with the changed file. check-exported: false gci: sections: - standard # Captures all standard packages if they do not match another section. - default # Contains all imports that could not be matched to another section type. - prefix(istio.io/) # Groups all imports with the specified Prefix.
Others - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Mon Apr 22 19:22:39 GMT 2024 - 11K bytes - Viewed (0) -
cmd/storage-datatypes.go
NumVersions int `msg:"nv"` SuccessorModTime time.Time `msg:"smt"` Fresh bool `msg:"fr"` // indicates this is a first time call to write FileInfo. // Position of this version or object in a multi-object delete call, // no other caller must set this value other than multi-object delete call. // usage in other calls in undefined please avoid. Idx int `msg:"i"` // Combined checksum when object was uploaded.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 17:15:52 GMT 2024 - 15.3K bytes - Viewed (0) -
docs/en/docs/async.md
When you want to call an `async def` function, you have to "await" it. So, this won't work: ```Python # This won't work, because get_burgers was defined with: async def burgers = get_burgers(2) ``` ---
Plain Text - Registered: Sun May 05 07:19:11 GMT 2024 - Last Modified: Thu Apr 18 19:53:19 GMT 2024 - 23K bytes - Viewed (0) -
maven-core/src/main/java/org/apache/maven/ReactorReader.java
// and only for plain old jars. Not war files, not ear files, not anything else. return determineBuildOutputDirectoryForArtifact(project, artifact); } // The fall-through indicates that the artifact cannot be found; // for instance if package produced nothing or classifier problems. return null; }
Java - Registered: Sun May 05 03:35:11 GMT 2024 - Last Modified: Thu May 02 16:33:18 GMT 2024 - 21.3K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/ConnectPlan.kt
var retryTlsConnection: ConnectPlan? = null var success = false // Tell the call about the connecting call so async cancels work. user.addPlanToCancel(this) try { if (tunnelRequest != null) { val tunnelResult = connectTunnel() // Tunnel didn't work. Start it all again. if (tunnelResult.nextPlan != null || tunnelResult.throwable != null) { return tunnelResult
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 18.6K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/Iterables.java
* iterable supports it. Note that it is <i>not</i> possible to delete the last skipped element by * immediately calling {@code remove()} on that iterator, as the {@code Iterator} contract states * that a call to {@code remove()} before a call to {@code next()} will throw an {@link * IllegalStateException}. * * <p><b>{@code Stream} equivalent:</b> {@link Stream#skip} * * @since 3.0 */
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Apr 24 19:38:27 GMT 2024 - 42.8K bytes - Viewed (0) -
internal/rest/client.go
return } // Returns success. return } // ErrClientClosed returned when *Client is closed. var ErrClientClosed = errors.New("rest client is closed") // Call - make a REST call with context. func (c *Client) Call(ctx context.Context, method string, values url.Values, body io.Reader, length int64) (reply io.ReadCloser, err error) { switch atomic.LoadInt32(&c.connected) { case closed:
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 14.4K bytes - Viewed (0) -
cmd/object-api-interface.go
Speedtest bool // object call specifically meant for SpeedTest code, set to 'true' when invoked by SpeedtestHandler. // Use the maximum parity (N/2), used when saving server configuration files MaxParity bool // Provides a per object encryption function, allowing metadata encryption. EncryptFn objectMetaEncryptFn // SkipDecommissioned set to 'true' if the call requires skipping the pool being decommissioned.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 20:08:20 GMT 2024 - 17K bytes - Viewed (0)