qhold - Code Search

internal/bucket/object/lock/lock.go

func ParseObjectLockLegalHoldHeaders(h http.Header) (lhold ObjectLegalHold, err error) {
	holdStatus, ok := h[AmzObjectLockLegalHold]
	if ok {
		lh := parseLegalHoldStatus(holdStatus[0])
		if !lh.Valid() {
			return lhold, ErrUnknownWORMModeDirective
		}
		lhold = ObjectLegalHold{XMLNS: "http://s3.amazonaws.com/doc/2006-03-01/", Status: lh}
	}
	return lhold, nil
}

// ObjectLegalHold specified in

Go

- Registered: Sun Apr 28 19:28:10 GMT 2024

- Last Modified: Thu Apr 04 12:04:40 GMT 2024

- 17.1K bytes

- Viewed (0)

github.com/minio/minio

cmd/bucket-object-lock.go

func enforceRetentionForDeletion(ctx context.Context, objInfo ObjectInfo) (locked bool) {
	if objInfo.DeleteMarker {
		return false
	}

	lhold := objectlock.GetObjectLegalHoldMeta(objInfo.UserDefined)
	if lhold.Status.Valid() && lhold.Status == objectlock.LegalHoldOn {
		return true
	}

	ret := objectlock.GetObjectRetentionMeta(objInfo.UserDefined)

Go

- Registered: Sun Apr 28 19:28:10 GMT 2024

- Last Modified: Mon Apr 22 17:49:30 GMT 2024

- 13.2K bytes

- Viewed (0)

github.com/square/okhttp

okhttp-testing-support/src/main/kotlin/okhttp3/internal/concurrent/TaskFaker.kt

      throw AssertionError("Thread ${Thread.currentThread().name} MUST hold lock on $this")
    }
  }

  @Suppress("NOTHING_TO_INLINE")
  internal inline fun Any.assertThreadDoesntHoldLock() {
    if (assertionsEnabled && taskRunner.lock.isHeldByCurrentThread) {
      throw AssertionError("Thread ${Thread.currentThread().name} MUST NOT hold lock on $this")
    }
  }

Plain Text

- Registered: Fri Apr 26 11:42:10 GMT 2024

- Last Modified: Thu Apr 11 22:09:35 GMT 2024

- 12.5K bytes

- Viewed (0)

github.com/istio/istio

cni/pkg/nodeagent/pod_cache.go

	"istio.io/istio/pkg/zdsapi"
)

var ErrPodNotFound = errors.New("netns not provided, but is needed as pod is not in cache")

type PodNetnsCache interface {
	ReadCurrentPodSnapshot() map[string]WorkloadInfo
}

// Hold a cache of node local pods with their netns
// if we don't know the netns, the pod will still be here with a nil netns.
type podNetnsCache struct {
	openNetns func(nspath string) (NetnsCloser, error)

Go

- Registered: Wed May 01 22:53:12 GMT 2024

- Last Modified: Fri Apr 12 21:47:31 GMT 2024

- 4.5K bytes

- Viewed (0)

github.com/minio/minio

internal/logger/audit.go

		entry.API.HeaderBytes = headerBytes
		entry.API.TimeToResponse = strconv.FormatInt(timeToResponse.Nanoseconds(), 10) + "ns"
		entry.API.TimeToResponseInNS = strconv.FormatInt(timeToResponse.Nanoseconds(), 10)
		// We hold the lock, so we cannot call reqInfo.GetTagsMap().
		tags := make(map[string]interface{}, len(reqInfo.tags))
		for _, t := range reqInfo.tags {
			tags[t.Key] = t.Val
		}
		entry.Tags = tags

Go

- Registered: Sun Apr 21 19:28:08 GMT 2024

- Last Modified: Thu Apr 04 12:04:40 GMT 2024

- 4.6K bytes

- Viewed (0)

github.com/golang/go

src/builtin/builtin.go

type int int

// uint is an unsigned integer type that is at least 32 bits in size. It is a
// distinct type, however, and not an alias for, say, uint32.
type uint uint

// uintptr is an integer type that is large enough to hold the bit pattern of
// any pointer.
type uintptr uintptr

// byte is an alias for uint8 and is equivalent to uint8 in all ways. It is
// used, by convention, to distinguish byte values from 8-bit unsigned
// integer values.

Go

- Registered: Tue Apr 30 11:13:12 GMT 2024

- Last Modified: Thu Apr 11 20:22:45 GMT 2024

- 12.7K bytes

- Viewed (0)

github.com/codelibs/fess

src/main/webapp/WEB-INF/view/admin/upgrade/admin_upgrade.jsp

	<title><la:message key="labels.admin_brand_title" /> | <la:message
			key="labels.upgrade_title_configuration" /></title>
	<jsp:include page="/WEB-INF/view/common/admin/head.jsp"></jsp:include>
</head>
<body class="hold-transition sidebar-mini">
	<div class="wrapper">
		<jsp:include page="/WEB-INF/view/common/admin/header.jsp"></jsp:include>
		<jsp:include page="/WEB-INF/view/common/admin/sidebar.jsp">

Others

- Registered: Mon Apr 29 08:04:11 GMT 2024

- Last Modified: Sat Apr 13 11:43:03 GMT 2024

- 4.1K bytes

- Viewed (0)

github.com/minio/minio

cmd/erasure-multipart.go

	if err != nil {
		if errors.Is(err, errVolumeNotFound) {
			return pi, toObjectErr(err, bucket)
		}
		return pi, toObjectErr(err, bucket, object, uploadID)
	}

	// Write lock for this part ID, only hold it if we are planning to read from the
	// streamto avoid any concurrent updates.
	//
	// Must be held throughout this call.
	partIDLock := er.NewNSLock(bucket, pathJoin(object, uploadID, strconv.Itoa(partID)))

Go

- Registered: Sun Apr 28 19:28:10 GMT 2024

- Last Modified: Sun Apr 28 17:53:50 GMT 2024

- 43K bytes

- Viewed (0)

github.com/minio/minio

cmd/config-current.go

// found, otherwise use default parameters
func newSrvConfig(objAPI ObjectLayer) error {
	// Initialize server config.
	srvCfg := newServerConfig()

	// hold the mutex lock before a new config is assigned.
	globalServerConfigMu.Lock()
	globalServerConfig = srvCfg
	globalServerConfigMu.Unlock()

	// Save config into file.

Go

- Registered: Sun Apr 28 19:28:10 GMT 2024

- Last Modified: Tue Apr 23 11:33:28 GMT 2024

- 30.7K bytes

- Viewed (0)

github.com/apache/maven

maven-api-impl/src/main/java/org/apache/maven/internal/impl/model/DefaultProfileInjector.java

    private static final Map<Model, Map<List<Profile>, Model>> CACHE = Collections.synchronizedMap(new WeakHashMap<>());

    // In order for the weak hash map to work correctly, we must not hold any reference to
    // the model used as the key.  So we use a dummy model as a placeholder to indicate that
    // we want to store the model used as they key.
    private static final Model KEY = Model.newInstance();

Java

- Registered: Sun Apr 28 03:35:10 GMT 2024

- Last Modified: Fri Apr 12 10:50:18 GMT 2024

- 9.5K bytes

- Viewed (0)

Search Options