Search Options

Results per page
Sort
Preferred Languages
Advance

Results 161 - 170 of 358 for writeErr (0.13 sec)

  1. internal/crypto/sse.go

    	partKey := key.DerivePartKey(uint32(partID))
    	return EncryptSinglePart(r, ObjectKey(partKey))
    }
    
    // DecryptSinglePart decrypts an io.Writer which must an object
    // uploaded with the single-part PUT API. The offset and length
    // specify the requested range.
    func DecryptSinglePart(w io.Writer, offset, length int64, key ObjectKey) io.WriteCloser {
    	const PayloadSize = 1 << 16 // DARE 2.0
    	w = ioutil.LimitedWriter(w, offset%PayloadSize, length)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 30 15:26:43 UTC 2022
    - 4.4K bytes
    - Viewed (0)
  2. cmd/lock-rest-server-common_test.go

    	defer os.RemoveAll(testPath)
    
    	lockRequesterInfo1 := lockRequesterInfo{
    		Owner:           "owner",
    		Writer:          true,
    		UID:             "0123-4567",
    		Timestamp:       UTCNow().UnixNano(),
    		TimeLastRefresh: UTCNow().UnixNano(),
    	}
    	lockRequesterInfo2 := lockRequesterInfo{
    		Owner:           "owner",
    		Writer:          true,
    		UID:             "89ab-cdef",
    		Timestamp:       UTCNow().UnixNano(),
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jul 24 10:24:01 UTC 2024
    - 3.2K bytes
    - Viewed (0)
  3. istioctl/pkg/kubeinject/kubeinject.go

    						if err == nil {
    							err = errClose
    						}
    					}
    				}()
    			}
    
    			var writer io.Writer
    			if outFilename == "" {
    				writer = c.OutOrStdout()
    			} else {
    				var out *os.File
    				if out, err = os.Create(outFilename); err != nil {
    					return err
    				}
    				writer = out
    				defer func() {
    					if errClose := out.Close(); errClose != nil {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Aug 15 16:31:46 UTC 2024
    - 21K bytes
    - Viewed (0)
  4. internal/bucket/replication/datatypes_gen.go

    		if err != nil {
    			err = msgp.WrapError(err)
    			return
    		}
    		(*z) = StatusType(zb0001)
    	}
    	return
    }
    
    // EncodeMsg implements msgp.Encodable
    func (z StatusType) EncodeMsg(en *msgp.Writer) (err error) {
    	err = en.WriteString(string(z))
    	if err != nil {
    		err = msgp.WrapError(err)
    		return
    	}
    	return
    }
    
    // MarshalMsg implements msgp.Marshaler
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Mar 08 19:08:18 UTC 2024
    - 2.3K bytes
    - Viewed (0)
  5. guava/src/com/google/common/io/ByteSink.java

    import java.io.BufferedOutputStream;
    import java.io.IOException;
    import java.io.InputStream;
    import java.io.OutputStream;
    import java.io.OutputStreamWriter;
    import java.io.Writer;
    import java.nio.charset.Charset;
    
    /**
     * A destination to which bytes can be written, such as a file. Unlike an {@link OutputStream}, a
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Oct 28 16:55:09 UTC 2024
    - 5K bytes
    - Viewed (0)
  6. doc/next/6-stdlib/99-minor/archive/66831.md

    The `(*Writer).AddFS` implementations in both `archive/zip` and `archive/tar`
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Mon Sep 23 14:32:33 UTC 2024
    - 131 bytes
    - Viewed (0)
  7. src/main/java/org/codelibs/fess/app/service/ElevateWordService.java

            }
        }
    
        public void exportCsv(final Writer writer) {
            final PermissionHelper permissionHelper = ComponentUtil.getPermissionHelper();
            final CsvConfig cfg = new CsvConfig(',', '"', '"');
            cfg.setEscapeDisabled(false);
            cfg.setQuoteDisabled(false);
            @SuppressWarnings("resource")
            final CsvWriter csvWriter = new CsvWriter(writer, cfg);
            try {
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:53:18 UTC 2024
    - 15.5K bytes
    - Viewed (0)
  8. istioctl/pkg/proxystatus/proxystatus.go

    	"istio.io/istio/istioctl/pkg/clioptions"
    	"istio.io/istio/istioctl/pkg/completion"
    	"istio.io/istio/istioctl/pkg/multixds"
    	"istio.io/istio/istioctl/pkg/util/ambient"
    	"istio.io/istio/istioctl/pkg/writer/compare"
    	"istio.io/istio/istioctl/pkg/writer/pilot"
    	pilotxds "istio.io/istio/pilot/pkg/xds"
    	"istio.io/istio/pkg/log"
    )
    
    var configDumpFile string
    
    func readConfigFile(filename string) ([]byte, error) {
    	file := os.Stdin
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Sat Apr 13 05:23:38 UTC 2024
    - 6.2K bytes
    - Viewed (0)
  9. guava-tests/test/com/google/common/io/ResourcesTest.java

        // loader, even if it is not visible to the loader of the Resources class.
    
        File tempFile = createTempFile();
        PrintWriter writer = new PrintWriter(tempFile, "UTF-8");
        writer.println("rud a chur ar an méar fhada");
        writer.close();
    
        // First check that we can't find it without setting the context loader.
        // This is a sanity check that the test doesn't spuriously pass because
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Jul 23 14:22:54 UTC 2024
    - 6.8K bytes
    - Viewed (0)
  10. guava/src/com/google/common/io/package-info.java

     * or implied. See the License for the specific language governing permissions and limitations under
     * the License.
     */
    
    /**
     * Utility methods and classes for I/O; for example input streams, output streams, readers, writers,
     * and files.
     *
     * <p>At the core of this package are the Source/Sink types: {@link ByteSource ByteSource}, {@link
     * CharSource CharSource}, {@link ByteSink ByteSink} and {@link CharSink CharSink}. They are
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Jun 23 19:57:03 UTC 2023
    - 1.5K bytes
    - Viewed (0)
Back to top