- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 81 for newWriter (0.71 sec)
-
cmd/notification.go
func (sys *NotificationSys) DownloadProfilingData(ctx context.Context, writer io.Writer) (profilingDataFound bool) { // Initialize a zip writer which will provide a zipped content // of profiling data of all nodes zipWriter := zip.NewWriter(writer) defer zipWriter.Close() for _, client := range sys.peerClients { if client == nil { continue } data, err := client.DownloadProfileData() if err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 12 18:13:36 GMT 2024 - 44.5K bytes - Viewed (0) -
cmd/storage-rest-server.go
var req ReadMultipleReq mr := msgpNewReader(r.Body) defer readMsgpReaderPoolPut(mr) err := req.DecodeMsg(mr) if err != nil { rw.CloseWithError(err) return } mw := msgp.NewWriter(rw) responses := make(chan ReadMultipleResp, len(req.Files)) var wg sync.WaitGroup wg.Add(1) go func() { defer wg.Done() for resp := range responses { err := resp.EncodeMsg(mw)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 44.8K bytes - Viewed (0) -
maven-core/src/test/resources/apiv4-repo/org/codehaus/plexus/plexus-utils/1.4.5/plexus-utils-1.4.5.jar
java.io.IOException; public static java.io.Writer newPlatformWriter(java.io.OutputStream); public static java.io.Writer newPlatformWriter(java.io.File) throws java.io.IOException; public static java.io.Writer newWriter(java.io.OutputStream, String) throws java.io.UnsupportedEncodingE; public static java.io.Writer newWriter(java.io.File, String) throws java.io.UnsupportedEncodingE, java.io.FileNotFoundExceptio; static void <clinit>(); } org/codehaus/plexus/util/xml/CompactXMLWriter.class package org.codehaus.plexus.util.xml;...
Archive - Registered: Sun Apr 21 03:35:09 GMT 2024 - Last Modified: Sun Oct 02 08:41:25 GMT 2022 - 200.2K bytes - Viewed (0) -
cmd/admin-handlers-users.go
objectAPI, _ := validateAdminReq(ctx, w, r, policy.ExportIAMAction) if objectAPI == nil { return } // Initialize a zip writer which will provide a zipped content // of bucket metadata zipWriter := zip.NewWriter(w) defer zipWriter.Close() rawDataFn := func(r io.Reader, filename string, sz int) error { header, zerr := zip.FileInfoHeader(dummyFileInfo{ name: filename, size: int64(sz), mode: 0o600,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 12:41:13 GMT 2024 - 77.5K bytes - Viewed (0) -
cmd/sts-handlers_test.go
`, } exportContent := map[string][]byte{} for k, v := range exportContentStrings { exportContent[k] = []byte(v) } var importContent []byte { var b bytes.Buffer zipWriter := zip.NewWriter(&b) rawDataFn := func(r io.Reader, filename string, sz int) error { header, zerr := zip.FileInfoHeader(dummyFileInfo{ name: filename, size: int64(sz), mode: 0o600, modTime: time.Now(),
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 25 15:50:16 GMT 2024 - 85.7K bytes - Viewed (0) -
cmd/bucket-replication.go
go func() { // Initialize MRF meta header. var data [4]byte binary.LittleEndian.PutUint16(data[0:2], mrfMetaFormat) binary.LittleEndian.PutUint16(data[2:4], mrfMetaVersion) mw := msgp.NewWriter(w) n, err := mw.Write(data[:]) if err != nil { w.CloseWithError(err) return } if n != len(data) { w.CloseWithError(io.ErrShortWrite) return }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 112.2K bytes - Viewed (1) -
internal/handlers/forwarder.go
Logger func(error) ErrorHandler func(http.ResponseWriter, *http.Request, error) // internal variables rewriter *headerRewriter } // NewForwarder creates an instance of Forwarder based on the provided list of configuration options func NewForwarder(f *Forwarder) *Forwarder { f.rewriter = &headerRewriter{} if f.RoundTripper == nil { f.RoundTripper = http.DefaultTransport } return f }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 07 05:42:10 GMT 2023 - 5.6K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/LinkedHashMultimap.java
* lying about the fields below on the grounds that we always initialize them just after the * constructor -- an example of the kind of lying that our hypothetical bytecode rewriter would * already have to deal with, thanks to DI frameworks that perform field and method injection, * frameworks like Android that define post-construct hooks like Activity.onCreate, etc. */
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Thu Feb 22 21:19:52 GMT 2024 - 23.6K bytes - Viewed (0) -
tensorflow/c/eager/c_api_test_util.cc
#include "tensorflow/core/platform/test.h" #include "tensorflow/core/platform/tstring.h" #include "tensorflow/core/protobuf/cluster.pb.h" #include "tensorflow/core/protobuf/config.pb.h" #include "tensorflow/core/protobuf/rewriter_config.pb.h" #include "tensorflow/core/util/port.h" using tensorflow::string; using tensorflow::tstring; TFE_TensorHandle* TestScalarTensorHandle(TFE_Context* ctx, float value) { float data[] = {value};
C++ - Registered: Tue Apr 30 12:39:09 GMT 2024 - Last Modified: Wed Feb 21 22:37:46 GMT 2024 - 23.5K bytes - Viewed (2) -
tensorflow/c/eager/c_api_test.cc
#include "tensorflow/core/platform/test.h" #include "tensorflow/core/platform/test_benchmark.h" #include "tensorflow/core/protobuf/cluster.pb.h" #include "tensorflow/core/protobuf/config.pb.h" #include "tensorflow/core/protobuf/rewriter_config.pb.h" #include "tensorflow/core/protobuf/tensorflow_server.pb.h" using tensorflow::string; namespace { void BM_InitOp(::testing::benchmark::State& state) { TF_Status* status = TF_NewStatus();
C++ - Registered: Tue Apr 30 12:39:09 GMT 2024 - Last Modified: Thu Aug 03 20:50:20 GMT 2023 - 94.6K bytes - Viewed (1)