- Sort Score
- Result 10 results
- Languages All
Results 221 - 230 of 391 for ctx_ (0.03 sec)
-
src/main/java/jcifs/smb/SmbTreeConnectionTrace.java
*/ package jcifs.smb; import jcifs.CIFSContext; /** * @author mbechler * */ class SmbTreeConnectionTrace extends SmbTreeConnection { SmbTreeConnectionTrace ( CIFSContext ctx ) { super(ctx); } SmbTreeConnectionTrace ( SmbTreeConnection conn ) { super(conn); } @Override protected void finalize () throws Throwable { checkRelease();
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Sat Jul 20 08:41:19 UTC 2019 - 1.1K bytes - Viewed (0) -
cmd/server-rlimit.go
logger.Info("WARNING: maximum virtual memory limit (%s) is too small for 'go runtime', please consider setting `ulimit -v` to unlimited", humanize.IBytes(vssLimit)) } if ctx.MemLimit > 0 { debug.SetMemoryLimit(int64(ctx.MemLimit)) } // Do not use RLIMIT_AS as that is not useful and at times on systems < 4Gi // this can crash the Go runtime if the value is smaller refer
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Jul 02 15:09:36 UTC 2024 - 2.8K bytes - Viewed (0) -
src/cmd/asm/internal/asm/parse.go
errorWriter io.Writer } type Patch struct { addr *obj.Addr label string } func NewParser(ctxt *obj.Link, ar *arch.Arch, lexer lex.TokenReader) *Parser { pkgPrefix := obj.UnlinkablePkg if ctxt != nil { pkgPrefix = objabi.PathToPrefix(ctxt.Pkgpath) } return &Parser{ ctxt: ctxt, arch: ar, lex: lexer, labels: make(map[string]*obj.Prog),
Registered: Tue Nov 05 11:13:11 UTC 2024 - Last Modified: Wed Sep 04 18:16:59 UTC 2024 - 36.9K bytes - Viewed (0) -
cmd/api-response.go
// Similar check to http.checkWriteHeaderCode if err.HTTPStatusCode < 100 || err.HTTPStatusCode > 999 { bugLogIf(ctx, fmt.Errorf("invalid WriteHeader code %v from %v", err.HTTPStatusCode, err.Code)) err.HTTPStatusCode = http.StatusInternalServerError } // Generate error response. errorResponse := getAPIErrorResponse(ctx, err, reqURL.Path, w.Header().Get(xhttp.AmzRequestID), w.Header().Get(xhttp.AmzRequestHostID))
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Oct 31 19:27:06 UTC 2024 - 33.4K bytes - Viewed (0) -
internal/hash/reader.go
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Sep 19 12:59:07 UTC 2024 - 10.9K bytes - Viewed (0) -
cmd/server-startup-msg_test.go
t.Fatalf("Expected %#v, got %#v", apiEndpoints, newAPIEndpoints) } } // Test printing server common message. func TestPrintServerCommonMessage(t *testing.T) { ctx, cancel := context.WithCancel(context.Background()) defer cancel() obj, fsDir, err := prepareFS(ctx) if err != nil { t.Fatal(err) } defer os.RemoveAll(fsDir) if err = newTestConfig(globalMinioDefaultRegion, obj); err != nil { t.Fatal(err) }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Jul 12 20:51:54 UTC 2024 - 3K bytes - Viewed (0) -
cmd/metacache-stream.go
// The context allows the operation to be canceled. func (r *metacacheReader) readAll(ctx context.Context, dst chan<- metaCacheEntry) error { r.checkInit() if r.err != nil { return r.err } defer xioutil.SafeClose(dst) if r.current.name != "" { select { case <-ctx.Done(): r.err = ctx.Err() return ctx.Err() case dst <- r.current: } r.current.name = "" r.current.metadata = nil
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Apr 04 12:04:40 UTC 2024 - 19.5K bytes - Viewed (0) -
cmd/metrics-v3-cluster-config.go
) // loadClusterConfigMetrics - `MetricsLoaderFn` for cluster config // such as standard and RRS parity. func loadClusterConfigMetrics(ctx context.Context, m MetricValues, c *metricsCache) error { clusterDriveMetrics, err := c.clusterDriveMetrics.Get() if err != nil { metricsLogIf(ctx, err) } else { m.Set(configStandardParity, float64(clusterDriveMetrics.storageInfo.Backend.StandardSCParity))
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri May 24 12:50:46 UTC 2024 - 1.5K bytes - Viewed (0) -
cmd/peer-rest-server.go
return np, grid.NewRemoteErr(err) } subSys := vars.Get(peerRESTSubSys) // Apply dynamic values. ctx, cancel := context.WithTimeout(context.Background(), 30*time.Second) defer cancel() if subSys == "" { err = applyDynamicConfig(ctx, objAPI, srvCfg) } else { err = applyDynamicConfigForSubSys(ctx, objAPI, srvCfg, subSys) } if err != nil { return np, grid.NewRemoteErr(err) } default:
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Oct 04 11:32:32 UTC 2024 - 53.2K bytes - Viewed (0) -
internal/grid/README.md
Sample handler: ```go handler := func(ctx context.Context, payload []byte, in <-chan []byte, out chan<- []byte) *RemoteErr { fmt.Println("Got request with initial payload", p, "from", GetCaller(ctx context.Context)) fmt.Println("Subroute:", GetSubroute(ctx)) for { select { case <-ctx.Done(): return nil case req, ok := <-in:
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Jan 18 07:03:17 UTC 2024 - 9.4K bytes - Viewed (0)