Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for respCh (0.03 sec)

  1. cmd/admin-handlers.go

    		} else {
    			writeSuccessResponseJSON(w, respBytes)
    		}
    		return
    	}
    
    	respCh := make(chan healResp, 1)
    	switch {
    	case hip.forceStop:
    		go func() {
    			respBytes, apiErr := globalAllHealState.stopHealSequence(healPath)
    			hr := healResp{respBytes: respBytes, apiErr: apiErr}
    			respCh <- hr
    		}()
    	case hip.clientToken == "":
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 99.7K bytes
    - Viewed (0)
  2. src/main/java/jcifs/smb1/smb1/SmbFile.java

            }
            resp = new NetServerEnum2Response();
    
            boolean more;
            do {
                int n;
    
                send(req, resp);
    
                if (resp.status != WinError.ERROR_SUCCESS && resp.status != WinError.ERROR_MORE_DATA) {
                    throw new SmbException(resp.status, true);
                }
                more = resp.status == WinError.ERROR_MORE_DATA;
    
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 112.2K bytes
    - Viewed (0)
  3. src/main/java/jcifs/smb/SmbFile.java

                    customizeCreate(req, resp);
    
                    h.send(req, resp);
                    info = resp;
                    fileSize = resp.getEndOfFile();
                    this.fileLocator.updateType(resp.getFileType());
                    fh = new SmbFileHandleImpl(config, resp.getFid(), h, uncPath, flags, access, attrs, options, resp.getEndOfFile());
                } else {
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 103.2K bytes
    - Viewed (0)
  4. cmd/bucket-replication.go

    	}
    
    	client := &http.Client{
    		Transport: globalRemoteTargetTransport,
    		Timeout:   10 * time.Second,
    	}
    
    	resp, err := client.Do(req)
    	if err != nil {
    		return err
    	}
    	if err == nil {
    		// Drain the connection.
    		xhttp.DrainBody(resp.Body)
    	}
    	if resp != nil {
    		amzid := resp.Header.Get(xhttp.AmzRequestHostID)
    		if _, ok := globalNodeNamesHex[amzid]; ok {
    			return BucketRemoteIdenticalToSource{
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 118.2K bytes
    - Viewed (0)
  5. cmd/object-handlers_test.go

    		}
    
    		resp := &CopyObjectPartResponse{}
    		if err = xmlDecoder(rec.Body, resp, rec.Result().ContentLength); err != nil {
    			t.Fatalf("Test failed to decode XML response: <ERROR> %v", err)
    		}
    
    		parts = append(parts, CompletePart{
    			PartNumber: partNumber,
    			ETag:       canonicalizeETag(resp.ETag),
    		})
    	}
    
    	var completeBytes []byte
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 163.1K bytes
    - Viewed (0)
Back to top