hell - Code Search

guava/src/com/google/common/util/concurrent/Striped.java

     * for (Lock lock : locks) {
     *   lock.lock();
     * }
     * operation();
     * for (Lock lock : locks) {
     *   lock.unlock();
     * }
     *
     * If we only held the int[] stripes, translating it on the fly to L's, the original locks might
     * be garbage collected after locking them, ending up in a huge mess.
     */

Registered: Fri Nov 01 12:43:10 UTC 2024

- Last Modified: Wed Jun 26 12:58:35 UTC 2024

- 20.6K bytes

- Viewed (0)

github.com/minio/minio

cmd/bucket-replication-utils.go

			return Failed
		case Complete:
			completed++
		}
	}
	if completed == len(m) {
		return Complete
	}
	return Pending
}

// getHealReplicateObjectInfo returns info needed by heal replication in ReplicateObjectInfo
func getHealReplicateObjectInfo(oi ObjectInfo, rcfg replicationConfig) ReplicateObjectInfo {
	userDefined := cloneMSS(oi.UserDefined)
	if rcfg.Config != nil && rcfg.Config.RoleArn != "" {

Registered: Sun Nov 03 19:28:11 UTC 2024

- Last Modified: Mon Jun 10 15:31:51 UTC 2024

- 26.3K bytes

- Viewed (0)

github.com/minio/minio

internal/dsync/drwmutex.go

			time.Sleep(time.Duration(dm.rng.Float64() * float64(dm.lockRetryMinInterval)))
			if time.Since(started) > dm.clnt.Timeouts.UnlockCall {
				return
			}
		}
	}()
}

// RUnlock releases a read lock held on dm.
//
// It is a run-time error if dm is not locked on entry to RUnlock.
func (dm *DRWMutex) RUnlock(ctx context.Context) {
	dm.m.Lock()
	dm.cancelRefresh()
	dm.m.Unlock()

Registered: Sun Nov 03 19:28:11 UTC 2024

- Last Modified: Mon Sep 09 15:49:49 UTC 2024

- 20.4K bytes

- Viewed (0)

github.com/istio/istio

istioctl/pkg/dashboard/dashboard.go

	dashboardCmd.AddCommand(skywalking)

	envoy := envoyDashCmd(cliContext)
	envoy.Long += fmt.Sprintf("\n\n%s\n", "Note: envoy command is deprecated and can be replaced with proxy command, "+
		"e.g. `istioctl dashboard proxy --help`")
	envoy.PersistentFlags().StringVarP(&labelSelector, "selector", "l", "", "Label selector")
	envoy.PersistentFlags().IntVar(&proxyAdminPort, "ui-port", util.DefaultProxyAdminPort, "The component dashboard UI port.")

Registered: Wed Nov 06 22:53:10 UTC 2024

- Last Modified: Mon Apr 15 01:29:35 UTC 2024

- 20.5K bytes

- Viewed (0)

github.com/istio/istio

common-protos/k8s.io/api/flowcontrol/v1alpha1/generated.proto

  // well-known group names.
  // Required.
  optional string name = 1;
}

// LimitResponse defines how to handle requests that can not be executed right now.
// +union
message LimitResponse {
  // `type` is "Queue" or "Reject".
  // "Queue" means that requests that can not be executed upon arrival
  // are held in a queue until they can be executed or a queuing limit

Registered: Wed Nov 06 22:53:10 UTC 2024

- Last Modified: Mon Mar 11 18:43:24 UTC 2024

- 19.4K bytes

- Viewed (0)

github.com/istio/istio

common-protos/k8s.io/api/flowcontrol/v1beta2/generated.proto

  // well-known group names.
  // Required.
  optional string name = 1;
}

// LimitResponse defines how to handle requests that can not be executed right now.
// +union
message LimitResponse {
  // `type` is "Queue" or "Reject".
  // "Queue" means that requests that can not be executed upon arrival
  // are held in a queue until they can be executed or a queuing limit

Registered: Wed Nov 06 22:53:10 UTC 2024

- Last Modified: Mon Mar 11 18:43:24 UTC 2024

- 19.4K bytes

- Viewed (0)

github.com/codelibs/fess

src/main/webapp/css/bootstrap.min.css.map

See https://github.com/twbs/bootstrap/issues/26878\n  overflow: hidden;\n  vertical-align: middle;\n}\n\n\n//\n// Tables\n//\n\ntable {\n  border-collapse: collapse; // Prevent double borders\n}\n\ncaption {\n  padding-top: $table-cell-padding;\n  padding-bottom: $table-cell-padding;\n  color: $table-caption-color;\n  text-align: left;\n  caption-side: bottom;\n}\n\nth {\n  // Matches default `<td>` alignment by inheriting from the `<body>`, or the\n  // closest parent with a set `text-align`.\n  text-align:...

Registered: Thu Oct 31 13:40:30 UTC 2024

- Last Modified: Thu Feb 13 04:21:06 UTC 2020

- 626.8K bytes

- Viewed (0)

github.com/minio/minio

docs/metrics/prometheus/grafana/minio-dashboard.json

          "legendFormat": "",
          "metric": "process_start_time_seconds",
          "refId": "A",
          "step": 60
        }
      ],
      "title": "Time Since Last Heal",
      "type": "stat"
    },
    {
      "datasource": {
        "type": "prometheus",
        "uid": "${DS_PROMETHEUS}"
      },
      "description": "",
      "fieldConfig": {

Registered: Sun Nov 03 19:28:11 UTC 2024

- Last Modified: Wed Jul 24 14:51:03 UTC 2024

- 93K bytes

- Viewed (0)

github.com/minio/minio

cmd/iam-store.go

// Assumes that c.Lock is held by caller.
func (c *iamCache) buildUserGroupMemberships() {
	for group, gi := range c.iamGroupsMap {
		c.updateGroupMembershipsMap(group, &gi)
	}
}

// updateGroupMembershipsMap - updates the memberships map for a
// group. IMPORTANT: Assumes c.Lock() is held by caller.
func (c *iamCache) updateGroupMembershipsMap(group string, gi *GroupInfo) {

Registered: Sun Nov 03 19:28:11 UTC 2024

- Last Modified: Mon Oct 14 16:35:37 UTC 2024

- 83.2K bytes

- Viewed (0)

github.com/square/okhttp

docs/changelogs/changelog_3x.md

    when the URL is malformed instead of returning null. Use this to avoid checking for null in
    situations where the input is known to be well-formed. We've also added `MediaType.get(String)`
    which is an exception-throwing alternative to `MediaType.parse(String)`.
 *  New: The `EventListener` API previewed in OkHttp 3.9 has graduated to a stable API. Use this

Registered: Fri Nov 01 11:42:11 UTC 2024

- Last Modified: Sun Feb 06 14:55:54 UTC 2022

- 50.8K bytes

- Viewed (0)

Search Options