- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 75 for getSource (0.17 sec)
-
cmd/sftp-server-driver.go
Duration: time.Since(startTime), Path: s.Filepath, Error: errStr, } } func (m *sftpMetrics) log(s *sftp.Request, user string) func(err error) { startTime := time.Now() source := getSource(2) return func(err error) { globalTrace.Publish(sftpTrace(s, startTime, source, user, err)) } } // NewSFTPDriver initializes sftp.Handlers implementation of following interfaces // // - sftp.Fileread
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 19 12:23:42 GMT 2024 - 12.9K bytes - Viewed (0) -
cmd/ftp-server-driver.go
Duration: time.Since(startTime), Path: objPath, Error: errStr, } } func (m *ftpMetrics) log(s *ftp.Context, paths ...string) func(err error) { startTime := time.Now() source := getSource(2) return func(err error) { globalTrace.Publish(ftpTrace(s, startTime, source, strings.Join(paths, " "), err)) } } // Stat implements ftpDriver
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 19 12:23:42 GMT 2024 - 13.6K bytes - Viewed (0) -
internal/logger/logger.go
} func trimTrace(f string) string { for _, trimString := range trimStrings { f = strings.TrimPrefix(filepath.ToSlash(f), filepath.ToSlash(trimString)) } return filepath.FromSlash(f) } func getSource(level int) string { pc, file, lineNumber, ok := runtime.Caller(level) if ok { // Clean up the common prefixes file = trimTrace(file) _, funcName := filepath.Split(runtime.FuncForPC(pc).Name())
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat May 04 00:17:57 GMT 2024 - 12.4K bytes - Viewed (0) -
api/maven-api-model/src/main/mdo/maven.mdo
public void setSource(String source) { getDelegate().setSource(source); } public String getSource() { return getDelegate().getSource(); } /** * @see java.lang.Object#toString() */ public String toString() { return "Profile {id: " + getId() + ", source: " + getSource() + "}"; } ]]>
XML - Registered: Sun May 05 03:35:11 GMT 2024 - Last Modified: Tue Apr 23 13:29:46 GMT 2024 - 115.1K bytes - Viewed (0) -
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) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 15:54:03 GMT 2024 - 34.9K bytes - Viewed (1) -
okhttp/src/test/java/okhttp3/internal/cache/DiskLruCacheTest.kt
fun readingTheSameStreamMultipleTimes(parameters: Pair<FileSystem, Boolean>) { setUp(parameters.first, parameters.second) set("a", "a", "b") val snapshot = cache["a"]!! assertThat(snapshot.getSource(0)).isSameAs(snapshot.getSource(0)) snapshot.close() } @ParameterizedTest @ArgumentsSource(FileSystemParamProvider::class) fun rebuildJournalOnRepeatedReads(parameters: Pair<FileSystem, Boolean>) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 15 14:55:09 GMT 2024 - 75.8K bytes - Viewed (0) -
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
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 23.2K bytes - Viewed (1) -
maven-core/src/test/resources/apiv4-repo/org/codehaus/plexus/plexus-component-api/1.0-alpha-32/plexus-component-api-1.0-alpha-32.jar
String description; private String realmId; private boolean isolatedRealm; private java.util.List dependencies; private ComponentSetDescript componentSetDescript; private String source; public void ComponentDescriptor(); public void setSource(String); public String getSource(); public String getHumanReadableKey(); public String getAlias(); public void setAlias(String); public String getRole(); public void setRole(String); public String getRoleHint(); public void setRoleHint(String); public String getImplementation();...
Archive - Registered: Sun Apr 28 03:35:10 GMT 2024 - Last Modified: Sun Oct 02 08:41:25 GMT 2022 - 35.3K bytes - Viewed (0) -
maven-core/src/test/resources/org/apache/maven/extension/test-extension-repo/org/codehaus/plexus/plexus-component-api/1.0-alpha-32/plexus-component-api-1.0-alpha-32.jar
String description; private String realmId; private boolean isolatedRealm; private java.util.List dependencies; private ComponentSetDescript componentSetDescript; private String source; public void ComponentDescriptor(); public void setSource(String); public String getSource(); public String getHumanReadableKey(); public String getAlias(); public void setAlias(String); public String getRole(); public void setRole(String); public String getRoleHint(); public void setRoleHint(String); public String getImplementation();...
Archive - Registered: Sun Mar 31 03:35:09 GMT 2024 - Last Modified: Tue Oct 16 20:15:40 GMT 2007 - 35.3K 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,
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Mar 31 17:16:15 GMT 2024 - 37.4K bytes - Viewed (0)