Search Options

Results per page
Sort
Preferred Languages
Advance

Results 221 - 230 of 391 for ctx_ (0.06 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. internal/hash/reader.go

    // does not send more content than specified size.
    func NewReader(ctx context.Context, src io.Reader, size int64, md5Hex, sha256Hex string, actualSize int64) (*Reader, error) {
    	return newReader(ctx, src, size, md5Hex, sha256Hex, actualSize, false, nil)
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 19 12:59:07 UTC 2024
    - 10.9K bytes
    - Viewed (0)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top