Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for Pwrite (0.14 sec)

  1. cmd/bucket-handlers.go

    	// Get current region.
    	region := globalSite.Region()
    	if region != globalMinioDefaultRegion {
    		encodedSuccessResponse = encodeResponse(LocationResponse{
    			Location: region,
    		})
    	}
    
    	// Write success response.
    	writeSuccessResponseXML(w, encodedSuccessResponse)
    }
    
    // ListMultipartUploadsHandler - GET Bucket (List Multipart uploads)
    // -------------------------
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri Jun 14 13:28:35 UTC 2024
    - 61.2K bytes
    - Viewed (0)
  2. cmd/object-multipart-handlers.go

    	if res.ChecksumAlgo != "" {
    		w.Header().Set(xhttp.AmzChecksumAlgo, res.ChecksumAlgo)
    	}
    	encodedSuccessResponse := encodeResponse(response)
    
    	// Write success response.
    	writeSuccessResponseXML(w, encodedSuccessResponse)
    }
    
    // CopyObjectPartHandler - uploads a part by copying data from an existing object as data source.
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri Jun 14 13:28:35 UTC 2024
    - 38.8K bytes
    - Viewed (0)
  3. pilot/pkg/config/kube/gateway/conversion.go

    				Rewrite: *filter.Path.ReplaceFullPath,
    			}
    		}
    	}
    	if filter.Hostname != nil {
    		rewrite.Authority = string(*filter.Hostname)
    	}
    	// Nothing done
    	if rewrite.Uri == "" && rewrite.UriRegexRewrite == nil && rewrite.Authority == "" {
    		return nil
    	}
    	return rewrite
    }
    
    func createRedirectFilter(filter *k8s.HTTPRequestRedirectFilter) *istio.HTTPRedirect {
    	if filter == nil {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Jun 14 04:34:37 UTC 2024
    - 84.7K bytes
    - Viewed (0)
  4. pkg/kubelet/kubelet_pods.go

    	if err != nil {
    		return err
    	}
    
    	// Do a zero-byte write to stdout before handing off to the container runtime.
    	// This ensures at least one Write call is made to the writer when copying starts,
    	// even if we then block waiting for log output from the container.
    	if _, err := stdout.Write([]byte{}); err != nil {
    		return err
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 101.2K bytes
    - Viewed (0)
  5. pilot/pkg/config/kube/crdclient/client.go

    	if err != nil {
    		return "", err
    	}
    	return meta.GetResourceVersion(), nil
    }
    
    // Patch applies only the modifications made in the PatchFunc rather than doing a full replace. Useful to avoid
    // read-modify-write conflicts when there are many concurrent-writers to the same resource.
    func (cl *Client) Patch(orig config.Config, patchFn config.PatchFunc) (string, error) {
    	modified, patchType := patchFn(orig.DeepCopy())
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Jun 14 00:12:28 UTC 2024
    - 13.7K bytes
    - Viewed (0)
  6. cmd/object-handlers.go

    		if !httpWriter.HasWritten() && !statusCodeWritten {
    			// write error response only if no data or headers has been written to client yet
    			writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    			return
    		}
    		return
    	}
    
    	if err = httpWriter.Close(); err != nil {
    		if !httpWriter.HasWritten() && !statusCodeWritten { // write error response only if no data or headers has been written to client yet
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri Jun 14 13:28:35 UTC 2024
    - 124.2K bytes
    - Viewed (0)
  7. pilot/pkg/xds/delta.go

    		removed := subscribed.DeleteAll(currentResources...)
    		resp.RemovedResources = sets.SortedList(removed)
    	}
    	var newResourceNames []string
    	if shouldSetWatchedResources(w) {
    		// Set the new watched resources. Do not write to w directly, as it can be a copy from the 'filtered' logic above
    		if usedDelta {
    			// Apply the delta
    			newResourceNames = sets.SortedList(sets.New(w.ResourceNames...).
    				DeleteAll(resp.RemovedResources...).
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Jun 14 04:34:37 UTC 2024
    - 25.6K bytes
    - Viewed (0)
  8. pkg/kubelet/kubelet.go

    //
    // If any step of this workflow errors, the error is returned, and is repeated
    // on the next SyncPod call.
    //
    // This operation writes all events that are dispatched in order to provide
    // the most accurate information possible about an error situation to aid debugging.
    // Callers should not write an event if this operation returns an error.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 126.1K bytes
    - Viewed (0)
  9. docs/en/docs/release-notes.md

    ### Internal
    
    * ✏️ Update Pydantic links to dotenv support. PR [#10511](https://github.com/tiangolo/fastapi/pull/10511) by [@White-Mask](https://github.com/White-Mask).
    * ✏️ Update links in `docs/en/docs/async.md` and `docs/zh/docs/async.md` to make them relative. PR [#10498](https://github.com/tiangolo/fastapi/pull/10498) by [@hasnatsajid](https://github.com/hasnatsajid).
    Registered: Mon Jun 17 08:32:26 UTC 2024
    - Last Modified: Fri Jun 14 15:07:37 UTC 2024
    - 395.4K bytes
    - Viewed (0)
Back to top