- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 547 for sock (0.03 sec)
-
internal/dsync/lock-args_gen.go
Harshavardhana <******@****.***> 1721816641 -0700
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Jul 24 10:24:01 UTC 2024 - 10.2K bytes - Viewed (0) -
manifests/addons/dashboards/jsonnetfile.lock.json
John Howard <******@****.***> 1717524306 -0700
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Tue Jun 04 18:05:06 UTC 2024 - 1.2K bytes - Viewed (0) -
build-logic/documentation/src/test/groovy/gradlebuild/docs/dsl/docbook/BasicJavadocLexerTest.groovy
* limitations under the License. */ package gradlebuild.docs.dsl.docbook import spock.lang.Specification class BasicJavadocLexerTest extends Specification { final BasicJavadocLexer lexer = new BasicJavadocLexer(new JavadocScanner("")) final visitor = Mock(JavadocLexer.TokenVisitor) def parsesHtmlElements() { when: lexer.pushText("<p> text </p>")
Registered: Wed Nov 06 11:36:14 UTC 2024 - Last Modified: Wed Dec 09 08:14:05 UTC 2020 - 6K bytes - Viewed (0) -
CHANGELOG/CHANGELOG-1.14.md
Registered: Fri Nov 01 09:05:11 UTC 2024 - Last Modified: Mon Jun 14 22:06:39 UTC 2021 - 271.5K bytes - Viewed (0) -
compat/maven-embedder/src/test/java/org/apache/maven/cli/event/ExecutionEventLoggerTest.java
} @Test void testTerminalWidth() { // prepare Logger logger = mock(Logger.class); when(logger.isInfoEnabled()).thenReturn(true); ExecutionEvent event = mock(ExecutionEvent.class); MavenProject project = mock(MavenProject.class); when(project.getGroupId()).thenReturn("org.apache.maven.plugins.overflow");
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 12.2K bytes - Viewed (0) -
internal/lsync/lrwmutex_test.go
panic("Failed to acquire read lock") } // fmt.Println("1st read lock acquired, waiting...") if !lrwm.GetRLock(ctx, "", "object1", time.Second) { panic("Failed to acquire read lock") } // fmt.Println("2nd read lock acquired, waiting...") go func() { time.Sleep(2 * time.Second) lrwm.RUnlock() // fmt.Println("1st read lock released, waiting...") }() go func() {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sun Mar 05 04:57:35 UTC 2023 - 7.9K bytes - Viewed (0) -
internal/dsync/locker.go
type NetLocker interface { // Do read lock for given LockArgs. It should return // * a boolean to indicate success/failure of the operation // * an error on failure of lock request operation. RLock(ctx context.Context, args LockArgs) (bool, error) // Do write lock for given LockArgs. It should return // * a boolean to indicate success/failure of the operation // * an error on failure of lock request operation.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Jan 18 20:44:38 UTC 2022 - 2.7K bytes - Viewed (0) -
cmd/local-locker.go
Source string // Contains line, function and filename requesting the lock. Group bool // indicates if it was a group lock. Owner string // Owner represents the UUID of the owner who originally requested the lock. Quorum int // Quorum represents the quorum required for this lock to be active. idx int `msg:"-"` // index of the lock in the lockMap. }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Jul 24 10:24:01 UTC 2024 - 10.7K bytes - Viewed (0) -
internal/dsync/dsync-server_test.go
// and positive values indicating number of read locks lockMap map[string]int64 // Refresh returns lock not found if set to true lockNotFound bool // Set to true if you want peers servers to do not respond responseDelay int64 } func (l *lockServer) setRefreshReply(refreshed bool) { l.mutex.Lock() defer l.mutex.Unlock()
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Jan 23 16:46:37 UTC 2023 - 8.3K bytes - Viewed (0) -
internal/dsync/drwmutex.go
} } // Lock holds a write lock on dm. // // If the lock is already in use, the calling go routine // blocks until the mutex is available. func (dm *DRWMutex) Lock(id, source string) { isReadLock := false dm.lockBlocking(context.Background(), nil, id, source, isReadLock, Options{ Timeout: drwMutexInfinite, }) } // Options lock options. type Options struct {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Sep 09 15:49:49 UTC 2024 - 20.4K bytes - Viewed (0)