Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 547 for sock (0.02 sec)

  1. 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)
  2. 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)
  3. 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)
  4. CHANGELOG/CHANGELOG-1.14.md

    * kubelet: fixes cadvisor internal error when "--container-runtime-endpoint" is set to "unix:///var/run/crio/crio.sock". ([#72340](https://github.com/kubernetes/kubernetes/pull/72340), [@makocchi-git](https://github.com/makocchi-git))
    Registered: Fri Nov 01 09:05:11 UTC 2024
    - Last Modified: Mon Jun 14 22:06:39 UTC 2021
    - 271.5K bytes
    - Viewed (0)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top