- Sort Score
- Result 10 results
- Languages All
Results 1461 - 1470 of 2,206 for setI (0.05 sec)
-
guava-tests/test/com/google/common/eventbus/outside/OutsideEventBusTest.java
final AtomicInteger deliveries = new AtomicInteger(); EventBus bus = new EventBus(); bus.register( new Object() { @Subscribe public void accept(String str) { holder.set(str); deliveries.incrementAndGet(); } }); String EVENT = "Hello!"; bus.post(EVENT); assertEquals("Only one event should be delivered.", 1, deliveries.get());
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Mon Dec 04 17:37:03 UTC 2017 - 1.8K bytes - Viewed (0) -
guava/src/com/google/common/collect/SortedIterables.java
} else { return false; } return comparator.equals(comparator2); } @SuppressWarnings("unchecked") // if sortedSet.comparator() is null, the set must be naturally ordered public static <E extends @Nullable Object> Comparator<? super E> comparator( SortedSet<E> sortedSet) { Comparator<? super E> result = sortedSet.comparator(); if (result == null) {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Wed Jun 30 10:33:07 UTC 2021 - 2K bytes - Viewed (0) -
ci/official/utilities/cleanup_summary.sh
# See the License for the specific language governing permissions and # limitations under the License. # ============================================================================== set -euxo pipefail function resultstore_extract_fallback { # In case the main script fails somehow. cat <<EOF IMPORTANT: For bazel invocations that uploaded to ResultStore (e.g. RBE), you
Registered: Tue Nov 05 12:39:12 UTC 2024 - Last Modified: Wed Aug 07 23:01:25 UTC 2024 - 1.8K bytes - Viewed (0) -
cmd/ftp-server-driver.go
if err != nil { return nil, err } // Set the parent of the temporary access key, this is useful // in obtaining service accounts by this cred. cred.ParentUser = lookupResult.NormDN // Set this value to LDAP groups, LDAP user can be part // of large number of groups cred.Groups = targetGroups // Set the newly generated credentials, policyName is empty on purpose
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Aug 14 17:11:51 UTC 2024 - 14K bytes - Viewed (0) -
internal/event/target/mysql.go
key_name VARCHAR(3072) NOT NULL, key_hash CHAR(64) GENERATED ALWAYS AS (SHA2(key_name, 256)) STORED NOT NULL PRIMARY KEY, value JSON) CHARACTER SET = utf8mb4 COLLATE = utf8mb4_bin ROW_FORMAT = Dynamic;` mysqlCreateAccessTable = `CREATE TABLE %s (event_time DATETIME NOT NULL, event_data JSON) ROW_FORMAT = Dynamic;`
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Sep 06 23:06:30 UTC 2024 - 11.6K bytes - Viewed (0) -
tests/named_argument_test.go
t.Errorf("failed to update with named arg") } AssertEqual(t, result4, namedUser) if err := DB.Exec("UPDATE named_users SET name1 = @name, name2 = @name2, name3 = @name", sql.Named("name", "jinzhu-new"), sql.Named("name2", "jinzhu-new2")).Error; err != nil { t.Errorf("failed to update with named arg") } namedUser.Name1 = "jinzhu-new"
Registered: Sun Nov 03 09:35:10 UTC 2024 - Last Modified: Tue Dec 21 11:50:00 UTC 2021 - 2.7K bytes - Viewed (0) -
docs/iam/policies/pbac-tests.sh
#!/bin/bash if [ -n "$TEST_DEBUG" ]; then set -x fi pkill minio pkill kes rm -rf /tmp/xl go install -v github.com/minio/mc@master cp -a $(go env GOPATH)/bin/mc ./mc if [ ! -f ./kes ]; then wget --quiet -O kes https://github.com/minio/kes/releases/latest/download/kes-linux-amd64 && chmod +x kes fi if ! openssl version &>/dev/null; then apt install openssl || sudo apt install opensssl fi
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Jun 25 01:15:27 UTC 2024 - 2.5K bytes - Viewed (0) -
internal/config/drive/drive.go
cfg = Config{ MaxTimeout: 30 * time.Second, } if err = config.CheckValidKeys(config.DriveSubSys, kvs, DefaultKVS); err != nil { return cfg, err } // if not set. Get default value from environment d := env.Get(EnvMaxDriveTimeout, env.Get(EnvMaxDriveTimeoutLegacy, env.Get(EnvMaxDiskTimeoutLegacy, kvs.GetWithDefault(MaxTimeout, DefaultKVS)))) if d == "" { cfg.MaxTimeout = 30 * time.Second
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 3K bytes - Viewed (0) -
ci/official/upload.sh
# $TF_VER_FULL will resolve to e.g. "2.15.0-rc2". Since $TF_VER_FULL comes # from get_versions.sh, which must be run *after* update_version.py, FINAL_URI # can't be set inside the rest of the _upload envs. FINAL_URI="$TFCI_ARTIFACT_FINAL_GCS_URI/$TF_VER_FULL" gsutil -m rsync -d -r "$DOWNLOADS" "$FINAL_URI" # Also mirror the latest-uploaded folder to the "latest" directory.
Registered: Tue Nov 05 12:39:12 UTC 2024 - Last Modified: Wed Jan 24 20:52:12 UTC 2024 - 2.8K bytes - Viewed (0) -
internal/grid/grid.go
dialer.WriteBufferSize = writeBufferSize dialer.Timeout = defaultDialTimeout if dial != nil { dialer.NetDial = dial } header := make(http.Header, 2) header.Set("Authorization", "Bearer "+auth()) header.Set("X-Minio-Time", strconv.FormatInt(time.Now().UnixNano(), 10)) if len(header) > 0 { dialer.Header = ws.HandshakeHeaderHTTP(header) } dialer.TLSConfig = tls
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Jul 29 18:10:04 UTC 2024 - 6.9K bytes - Viewed (0)