Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 114 for subs (0.24 sec)

  1. internal/pubsub/pubsub_test.go

    		t.Fatalf("unexpected error: %v", err)
    	}
    	if err := ps.Subscribe(MaskAll, ch2, doneCh, nil); err != nil {
    		t.Fatalf("unexpected error: %v", err)
    	}
    	ps.Lock()
    	defer ps.Unlock()
    
    	if len(ps.subs) != 2 || ps.NumSubscribers(MaskAll) != 2 || ps.Subscribers() != 2 {
    		t.Fatalf("expected 2 subscribers")
    	}
    }
    
    func TestNumSubscribersMask(t *testing.T) {
    	ps := New[Maskable, Mask](2)
    	ch1 := make(chan Maskable, 1)
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 5.8K bytes
    - Viewed (0)
  2. internal/pubsub/pubsub.go

    	go func() {
    		<-doneCh
    
    		ps.Lock()
    		defer ps.Unlock()
    		var remainTypes Mask
    		for i, s := range ps.subs {
    			if s == sub {
    				ps.subs = append(ps.subs[:i], ps.subs[i+1:]...)
    			} else {
    				remainTypes.Merge(s.types)
    			}
    		}
    		atomic.StoreUint64(&ps.types, uint64(remainTypes))
    		atomic.AddInt32(&ps.numSubscribers, -1)
    	}()
    
    	return nil
    }
    
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Tue Feb 06 16:57:30 GMT 2024
    - 5.2K bytes
    - Viewed (0)
  3. src/cmd/asm/internal/asm/testdata/arm64error.s

    	SUBS	$0xff, R6, RSP                                   // ERROR "illegal destination register"
    	SUBS	$0xffff0, R6, RSP                                // ERROR "illegal destination register"
    	SUBS	$0x1000100010001000, R6, RSP                     // ERROR "illegal destination register"
    	SUBS	$0x10001000100011, R6, RSP                       // ERROR "illegal destination register"
    Others
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Fri Dec 08 03:28:17 GMT 2023
    - 37.8K bytes
    - Viewed (0)
  4. src/cmd/asm/internal/asm/testdata/arm64enc.s

    	SUBS R21.UXTX<<2, R27, R4                  // 646b35eb
    	SUBSW $(44<<12), R6, R9                    // SUBSW $180224, R6, R9         // c9b04071
    	SUBS $(1804<<12), R13, R9                  // SUBS $7389184, R13, R9        // a9315cf1
    	SUBSW R22->28, R6, R7                      // c770966b
    	SUBSW R22>>28, R6, R7                      // c770566b
    	SUBS R26<<15, R6, R16                      // d03c1aeb
    Others
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Mon Jul 24 01:11:41 GMT 2023
    - 43.9K bytes
    - Viewed (1)
  5. src/cmd/asm/internal/asm/testdata/arm64.s

    	SUB	$0x000aaa, R2, R3               // SUB $2730, R2, R3                      // 43a82ad1
    	SUB	$0x000aaa, R2                   // SUB $2730, R2                          // 42a82ad1
    	SUB	$0xaaa000, R2, R3               // SUB $11182080, R2, R3                  // 43a86ad1
    	SUB	$0xaaa000, R2                   // SUB $11182080, R2                      // 42a86ad1
    Others
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Fri Dec 08 03:28:17 GMT 2023
    - 94.9K bytes
    - Viewed (0)
  6. .idea/runConfigurations/Decompiled_Stubs_Tests.xml

    <component name="ProjectRunConfigurationManager">
      <configuration default="false" name="Decompiled Stubs Tests" type="GradleRunConfiguration" factoryName="Gradle" folderName="Analysis">
        <ExternalSystemSettings>
          <option name="executionName" />
          <option name="externalProjectPath" value="$PROJECT_DIR$" />
          <option name="externalSystemIdString" value="GRADLE" />
          <option name="scriptParameters" value="" />
          <option name="taskDescriptions">
    XML
    - Registered: Fri May 03 08:18:13 GMT 2024
    - Last Modified: Fri Mar 01 17:29:07 GMT 2024
    - 1.1K bytes
    - Viewed (0)
  7. src/cmd/cgo/internal/test/cgo_stubs_android_test.go

    // Copyright 2012 The Go Authors. All rights reserved.
    // Use of this source code is governed by a BSD-style
    // license that can be found in the LICENSE file.
    
    package cgotest
    
    import "testing"
    
    // Stubs for tests that fails to build on Android
    func test6997(t *testing.T)        {}
    func test8694(t *testing.T)        {}
    Go
    - Registered: Tue Apr 23 11:13:09 GMT 2024
    - Last Modified: Fri May 12 12:00:02 GMT 2023
    - 359 bytes
    - Viewed (0)
  8. android/guava-tests/test/com/google/common/collect/TreeRangeMapTest.java

        RangeMap<Integer, Integer> sub1 = rangeMap.subRangeMap(Range.closed(5, 11));
        assertEquals(
            ImmutableMap.of(Range.closedOpen(5, 7), 1, Range.closed(9, 10), 2), sub1.asMapOfRanges());
        RangeMap<Integer, Integer> sub2 = sub1.subRangeMap(Range.open(6, 15));
        assertEquals(
            ImmutableMap.of(Range.open(6, 7), 1, Range.closed(9, 10), 2), sub2.asMapOfRanges());
      }
    
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Thu Feb 22 20:09:59 GMT 2024
    - 28K bytes
    - Viewed (0)
  9. src/cmd/asm/internal/asm/testdata/ppc64.s

    	SUBMEVCC R3, R4                 // 7c8305d1
    	SUBV R3, R4, R5                 // 7ca32450
    	SUBE R3, R4, R5                 // 7ca32110
    	SUBECC R3, R4, R5               // 7ca32111
    	SUBEV R3, R4, R5                // 7ca32510
    	SUBEVCC R3, R4, R5              // 7ca32511
    	SUBC R3, $65536, R4             // 3fe00001600000007c83f810
    	SUBC R3, $65537, R4             // 3fe0000163ff00017c83f810
    
    Others
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Wed Apr 24 15:53:25 GMT 2024
    - 49K bytes
    - Viewed (0)
  10. guava-tests/test/com/google/common/collect/TreeRangeMapTest.java

        RangeMap<Integer, Integer> sub1 = rangeMap.subRangeMap(Range.closed(5, 11));
        assertEquals(
            ImmutableMap.of(Range.closedOpen(5, 7), 1, Range.closed(9, 10), 2), sub1.asMapOfRanges());
        RangeMap<Integer, Integer> sub2 = sub1.subRangeMap(Range.open(6, 15));
        assertEquals(
            ImmutableMap.of(Range.open(6, 7), 1, Range.closed(9, 10), 2), sub2.asMapOfRanges());
      }
    
    Java
    - Registered: Fri Apr 19 12:43:09 GMT 2024
    - Last Modified: Thu Feb 22 20:09:59 GMT 2024
    - 33.2K bytes
    - Viewed (0)
Back to top