- Sort Score
- Result 10 results
- Languages All
Results 51 - 57 of 57 for getSources (0.1 sec)
-
cmd/server-main.go
func bootstrapTraceMsg(msg string) { info := madmin.TraceInfo{ TraceType: madmin.TraceBootstrap, Time: UTCNow(), NodeName: globalLocalNodeName, FuncName: "BOOTSTRAP", Message: fmt.Sprintf("%s %s", getSource(2), msg), } globalBootstrapTracer.Record(info) if serverDebugLog { fmt.Println(time.Now().Round(time.Millisecond).Format(time.RFC3339), " bootstrap: ", msg) }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Sep 24 21:50:11 UTC 2024 - 35.2K bytes - Viewed (1) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Stream.kt
this.sink.trailers = trailers } } fun readTimeout(): Timeout = readTimeout fun writeTimeout(): Timeout = writeTimeout /** Returns a source that reads data from the peer. */ fun getSource(): Source = source /** * Returns a sink that can be used to write data to the peer. * * @throws IllegalStateException if this stream was initiated by the peer and a [writeHeaders] has
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 23.2K bytes - Viewed (0) -
compat/maven-model-builder/src/main/java/org/apache/maven/model/building/DefaultModelBuilder.java
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 83.6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/cache/DiskLruCache.kt
*/ @Throws(IOException::class) fun edit(): Editor? = ******@****.***(key, sequenceNumber) /** Returns the unbuffered stream with the value for [index]. */ fun getSource(index: Int): Source = sources[index] /** Returns the byte length of the value for [index]. */ fun getLength(index: Int): Long = lengths[index] override fun close() { for (source in sources) {
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 34.7K bytes - Viewed (0) -
api/maven-api-settings/src/main/mdo/settings.mdo
<codeSegment> <version>2.0.0+</version> <code> @Override public String toString() { return getLineNumber() + " : " + getColumnNumber() + ", " + getSource(); } </code> </codeSegment> </codeSegments> </class> <class sourceTracker="source"> <name>InputSource</name> <version>2.0.0+</version>
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Tue Oct 08 13:46:42 UTC 2024 - 33.5K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/MockWebServer.kt
expectedByteCount = contentLengthString?.toLong() ?: Long.MAX_VALUE, socket = socket, ).buffer() requestBodySink.use { it.writeAll(stream.getSource()) } } catch (e: IOException) { exception = e } } return RecordedRequest( requestLine = requestLine, headers = headers,
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sun Mar 31 17:16:15 UTC 2024 - 37.4K bytes - Viewed (0) -
cmd/bucket-lifecycle.go
Time: startTime, NodeName: globalLocalNodeName, FuncName: event, Duration: duration, Path: pathJoin(oi.Bucket, oi.Name), Bytes: sz, Error: err, Message: getSource(4), Custom: metadata, } } func (sys *LifecycleSys) trace(oi ObjectInfo) func(event string, metadata map[string]string, err error) { startTime := time.Now()
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Oct 23 15:35:37 UTC 2024 - 33.7K bytes - Viewed (0)