Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 57 of 57 for getSources (0.1 sec)

  1. 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)
  2. 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)
  3. compat/maven-model-builder/src/main/java/org/apache/maven/model/building/DefaultModelBuilder.java

                // we pass a cloned model, so that resolving the parent version does not affect the returned model
                ModelData parentData = readParent(new Model(modelv4), currentData.getSource(), request, problems);
    
                if (parentData == null) {
                    currentData = superData;
                } else if (!parentIds.add(parentData.getId())) {
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 83.6K bytes
    - Viewed (0)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
Back to top