- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 35 for ps (0.13 sec)
-
internal/pubsub/pubsub.go
totalSubs := atomic.AddInt32(&ps.numSubscribers, 1) if ps.maxSubscribers > 0 && totalSubs > ps.maxSubscribers { atomic.AddInt32(&ps.numSubscribers, -1) return fmt.Errorf("the limit of `%d` subscribers is reached", ps.maxSubscribers) } ps.Lock() defer ps.Unlock() sub := &Sub[T]{ch: subCh, types: Mask(mask.Mask()), filter: filter} ps.subs = append(ps.subs, sub) // We hold a lock, so we are safe to update
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Feb 06 16:57:30 GMT 2024 - 5.2K bytes - Viewed (0) -
src/main/java/org/codelibs/core/sql/PreparedStatementUtil.java
* 更新を実行します。 * * @param ps * {@link PreparedStatement}。{@literal null}であってはいけません * @return 更新した結果の行数 * @throws SQLRuntimeException * {@link SQLException}が発生した場合 */ public static int executeUpdate(final PreparedStatement ps) throws SQLRuntimeException { assertArgumentNotNull("ps", ps); try { return ps.executeUpdate();
Java - Registered: Fri May 03 20:58:11 GMT 2024 - Last Modified: Thu Mar 07 01:59:08 GMT 2024 - 3.9K bytes - Viewed (0) -
internal/pubsub/pubsub_test.go
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) ch2 := make(chan Maskable, 1) doneCh := make(chan struct{}) defer close(doneCh) if err := ps.Subscribe(Mask(1), ch1, doneCh, nil); err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 5.8K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/net/InternetDomainNameTest.java
private static final ImmutableSet<String> PS_NOT_RS = ImmutableSet.of("blogspot.com", "blogspot.co.uk", "uk.com"); private static final ImmutableSet<String> PS = ImmutableSet.<String>builder().addAll(RS).addAll(PS_NOT_RS).build(); private static final ImmutableSet<String> NO_PS = ImmutableSet.of("www", "foo.ihopethiswillneverbeapublicsuffix", "x.y.z"); /**
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Tue Mar 05 13:16:00 GMT 2024 - 17.3K bytes - Viewed (0) -
cmd/rebalance-admin.go
totalBytesToRebal := float64(ps.InitCapacity)*meta.PercentFreeGoal - float64(ps.InitFreeSpace) elapsed := time.Since(ps.Info.StartTime) eta := time.Duration(totalBytesToRebal * float64(elapsed) / float64(ps.Bytes)) if !ps.Info.EndTime.IsZero() { stopTime = ps.Info.EndTime } if !stopTime.IsZero() { // rebalance is stopped or completed elapsed = stopTime.Sub(ps.Info.StartTime) eta = 0 }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Dec 22 00:56:43 GMT 2023 - 3.8K bytes - Viewed (0) -
maven-core/src/main/java/org/apache/maven/plugin/DefaultBuildPluginManager.java
ByteArrayOutputStream os = new ByteArrayOutputStream(1024); PrintStream ps = new PrintStream(os); ps.println( "A required class was missing while executing " + mojoDescriptor.getId() + ": " + e.getMessage()); pluginRealm.display(ps); Exception wrapper = new PluginContainerException(mojoDescriptor, pluginRealm, os.toString(), e);
Java - Registered: Sun May 05 03:35:11 GMT 2024 - Last Modified: Mon Mar 25 10:50:01 GMT 2024 - 10.9K bytes - Viewed (0) -
internal/arn/arn.go
func Parse(arnStr string) (arn ARN, err error) { ps := strings.Split(arnStr, ":") if len(ps) != 6 || ps[0] != string(arnPrefixArn) { err = errors.New("invalid ARN string format") return } if ps[1] != string(arnPartitionMinio) { err = errors.New("invalid ARN - bad partition field") return } if ps[2] != string(arnServiceIAM) { err = errors.New("invalid ARN - bad service field")
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 08:31:34 GMT 2024 - 3.5K bytes - Viewed (0) -
cmd/erasure-server-pool-rebalance.go
z.rebalMu.Lock() defer z.rebalMu.Unlock() ps := z.rebalMeta.PoolStats[poolIdx] if ps == nil { return } for i, b := range ps.Buckets { if b == bucket { ps.Buckets = append(ps.Buckets[:i], ps.Buckets[i+1:]...) ps.RebalancedBuckets = append(ps.RebalancedBuckets, bucket) break } } } func (r *rebalanceMeta) load(ctx context.Context, store objectIO) error {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 26 19:29:28 GMT 2024 - 27.2K bytes - Viewed (0) -
guava-tests/test/com/google/common/net/InternetDomainNameTest.java
private static final ImmutableSet<String> PS_NOT_RS = ImmutableSet.of("blogspot.com", "blogspot.co.uk", "uk.com"); private static final ImmutableSet<String> PS = ImmutableSet.<String>builder().addAll(RS).addAll(PS_NOT_RS).build(); private static final ImmutableSet<String> NO_PS = ImmutableSet.of("www", "foo.ihopethiswillneverbeapublicsuffix", "x.y.z"); /**
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Tue Mar 05 13:16:00 GMT 2024 - 17.3K bytes - Viewed (0) -
build-logic/cleanup/src/main/java/gradlebuild/cleanup/services/KillLeakingJavaProcesses.java
} private static List<String> ps() { return run(determinePsCommand()).assertZeroExit().stdout.lines().collect(Collectors.toList()); } private static String[] determinePsCommand() { if (isWindows()) { return new String[]{"wmic", "process", "get", "processid,commandline"}; } else if (isMacOS()) { return new String[]{"ps", "x", "-o", "pid,command"}; } else {
Java - Registered: Wed May 01 11:36:15 GMT 2024 - Last Modified: Fri Apr 26 09:46:00 GMT 2024 - 11.3K bytes - Viewed (0)