- Sort Score
- Result 10 results
- Languages All
Results 251 - 260 of 294 for callGet (0.14 sec)
-
internal/rest/client.go
// side-channel check has failed, we shall take // the client offline in such situations. // generally all implementations should simply return // 403, but in situations where there is a dependency // with the caller to take the client offline purpose // fully it should make sure to respond with '412' // instead, see cmd/storage-rest-server.go for ideas. if c.HealthCheckFn != nil && resp.StatusCode == http.StatusPreconditionFailed {
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Fri Jul 26 12:55:01 UTC 2024 - 14.7K bytes - Viewed (0) -
cmd/metrics-v2.go
} for k, v := range m.Histogram { metric.Histogram[k] = v } return metric } // Get - returns cached value always upton the configured TTL, // once the TTL expires "read()" registered function is called // to return the new values and updated. func (g *MetricsGroupV2) Get() (metrics []MetricV2) { m, _ := g.metricsCache.Get() if len(m) == 0 { return []MetricV2{} }
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Thu Aug 15 12:04:40 UTC 2024 - 131.9K bytes - Viewed (0) -
tensorflow/c/c_api.cc
#else mutex_lock l(api_def_map->lock); if (api_def_map->update_docs_called) { status->status = FailedPrecondition( "TF_ApiDefMapPut cannot be called after TF_ApiDefMapGet has been " "called."); return; } string api_def_text(text, text_len); status->status = api_def_map->api_def_map.LoadApiDef(api_def_text);
Registered: Tue Oct 29 12:39:09 UTC 2024 - Last Modified: Sat Oct 12 16:27:48 UTC 2024 - 102.3K bytes - Viewed (0) -
cmd/streaming-signature-v4.go
// so they are only valid until the next bufio read. func readChunkLine(b *bufio.Reader) ([]byte, []byte, error) { buf, err := b.ReadSlice('\n') if err != nil { // We always know when EOF is coming. // If the caller asked for a line, there should be a line. if err == io.EOF { err = io.ErrUnexpectedEOF } else if err == bufio.ErrBufferFull { err = errLineTooLong } return nil, nil, err }
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Thu May 16 23:13:47 UTC 2024 - 18.2K bytes - Viewed (0) -
src/bytes/buffer.go
slice, err := b.readSlice(delim) return string(slice), err } // NewBuffer creates and initializes a new [Buffer] using buf as its // initial contents. The new [Buffer] takes ownership of buf, and the // caller should not use buf after this call. NewBuffer is intended to // prepare a [Buffer] to read existing data. It can also be used to set // the initial size of the internal buffer for writing. To do that,
Registered: Tue Oct 29 11:13:09 UTC 2024 - Last Modified: Tue Jul 16 18:17:37 UTC 2024 - 15.7K bytes - Viewed (0) -
cmd/background-newdisks-heal-ops.go
h.ItemsFailed = h.ResumeItemsFailed h.ItemsSkipped = h.ResumeItemsSkipped h.BytesDone = h.ResumeBytesDone h.BytesFailed = h.ResumeBytesFailed h.BytesSkipped = h.ResumeBytesSkipped } // bucketDone should be called when a bucket is done healing. // Adds the bucket to the list of healed buckets and updates resume numbers. func (h *healingTracker) bucketDone(bucket string) { h.mu.Lock() defer h.mu.Unlock()
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Sat Oct 26 09:58:27 UTC 2024 - 16.6K bytes - Viewed (0) -
cmd/xl-storage.go
func (s *xlStorage) ReadAll(ctx context.Context, volume string, path string) (buf []byte, err error) { // Specific optimization to avoid re-read from the drives for `format.json` // in-case the caller is a network operation. if volume == minioMetaBucket && path == formatConfigFile { s.RLock() formatData := make([]byte, len(s.formatData)) copy(formatData, s.formatData) s.RUnlock()
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Sat Oct 26 09:58:27 UTC 2024 - 91.3K bytes - Viewed (2) -
docs/em/docs/alternatives.md
### <a href="https://marshmallow.readthedocs.io/en/stable/" class="external-link" target="_blank">🍭</a> 1️⃣ 👑 ⚒ 💪 🛠️ ⚙️ 📊 "<abbr title="also called marshalling, conversion">🛠️</abbr>" ❔ ✊ 📊 ⚪️➡️ 📟 (🐍) & 🏭 ⚫️ 🔘 🕳 👈 💪 📨 🔘 🕸. 🖼, 🏭 🎚 ⚗ 📊 ⚪️➡️ 💽 🔘 🎻 🎚. 🏭 `datetime` 🎚 🔘 🎻, ♒️.
Registered: Sun Oct 27 07:19:11 UTC 2024 - Last Modified: Sun Oct 20 19:20:23 UTC 2024 - 18.7K bytes - Viewed (0) -
tensorflow/c/c_api_function_test.cc
bool expect_failure = false) { DefineT(num_opers, opers, ToOutput(inputs), ToOutput(outputs), output_names, expect_failure); } // Caller must delete[] the returned value static const char** ToArray(const std::vector<string>& strs) { const char** ptr = nullptr; if (!strs.empty()) { ptr = new const char*[strs.size()];
Registered: Tue Oct 29 12:39:09 UTC 2024 - Last Modified: Thu Jul 20 22:08:54 UTC 2023 - 63.6K bytes - Viewed (0) -
src/archive/tar/writer.go
type fileWriter interface { io.Writer fileState ReadFrom(io.Reader) (int64, error) } // Flush finishes writing the current file's block padding. // The current file must be fully written before Flush can be called. // // This is unnecessary as the next call to [Writer.WriteHeader] or [Writer.Close] // will implicitly flush out the file's padding. func (tw *Writer) Flush() error { if tw.err != nil { return tw.err }
Registered: Tue Oct 29 11:13:09 UTC 2024 - Last Modified: Wed Oct 02 14:22:59 UTC 2024 - 19.6K bytes - Viewed (0)