Status - Code Search

.ci/jobs.t/elastic+elasticsearch+pull-request+part-2-fips.yml

          org-list:
            - elastic
          allow-whitelist-orgs-as-admins: true
          trigger-phrase: '.*run\W+elasticsearch-ci/part-2-fips.*'
          github-hooks: true
          status-context: elasticsearch-ci/part-2-fips
          cancel-builds-on-update: true
          black-list-target-branches:
            - 6.8
          excluded-regions:
            - ^docs/.*
          white-list-labels:

Created: Wed Apr 08 16:19:15 GMT 2026

- Last Modified: Thu Sep 16 01:16:48 GMT 2021

- 1.4K bytes

- Click Count (0)

github.com/codelibs/jcifs

src/main/java/jcifs/smb1/netbios/NodeStatusResponse.java

        System.arraycopy(src, srcIndex + namesLength, macAddress, 0, 6);
        srcIndex += readNodeNameArray(src, srcIndex);
        stats = new byte[statsLength];
        System.arraycopy(src, srcIndex, stats, 0, statsLength);
        srcIndex += statsLength;
        return srcIndex - start;
    }

    private int readNodeNameArray(final byte[] src, int srcIndex) {

Created: Sun Apr 05 00:10:12 GMT 2026

- Last Modified: Thu Aug 14 07:14:38 GMT 2025

- 5.8K bytes

- Click Count (0)

github.com/minio/minio

docs/bucket/lifecycle/DESIGN.md

Extra metadata maintained internally in `xl.meta` for a transitioned object

```
...
        "MetaSys": {
          "x-minio-internal-transition-status": "Y29tcGxldGU=",
          "x-minio-internal-transition-tier": "R0NTVElFUjE=",
          "x-minio-internal-transitioned-object": "ZDIvN2MvZDI3Y2MwYWMtZGIzNC00ZGM1LWIxNDUtYjI5MGNjZjU1MjY5"
        },
```

Created: Sun Apr 05 19:28:12 GMT 2026

- Last Modified: Tue Aug 12 18:20:36 GMT 2025

- 4.2K bytes

- Click Count (0)

github.com/tiangolo/fastapi

docs_src/websockets_/tutorial002_py310.py

from fastapi import (
    Cookie,
    Depends,
    FastAPI,
    Query,
    WebSocket,
    WebSocketException,
    status,
)
from fastapi.responses import HTMLResponse

app = FastAPI()

html = """
<!DOCTYPE html>
<html>
    <head>
        <title>Chat</title>
    </head>
    <body>
        <h1>WebSocket Chat</h1>
        <form action="" onsubmit="sendMessage(event)">

Created: Sun Apr 05 07:19:11 GMT 2026

- Last Modified: Fri Feb 27 12:34:37 GMT 2026

- 2.7K bytes

- Click Count (0)

github.com/minio/minio

internal/config/dns/operator_dns.go

		if resp.StatusCode == http.StatusConflict {
			return ErrBucketConflict(Error{bucket, errors.New(errorString)})
		}
		return newError(bucket, fmt.Errorf("service create for bucket %s, failed with status %s, error %s", bucket, resp.Status, errorString))
	}
	return nil
}

func newError(bucket string, err error) error {
	e := Error{bucket, err}
	if strings.Contains(err.Error(), "invalid bucket name") {

Created: Sun Apr 05 19:28:12 GMT 2026

- Last Modified: Mon Nov 11 14:51:43 GMT 2024

- 6.6K bytes

- Click Count (0)

github.com/minio/minio

internal/bucket/lifecycle/evaluator_test.go

		for i := range retainVersions {
			ruleID := fmt.Sprintf("rule-%d", i)
			tag := Tag{
				Key:   tagKeys[i],
				Value: "minio",
			}
			lc.Rules = append(lc.Rules, Rule{
				ID:     ruleID,
				Status: "Enabled",
				Filter: Filter{
					Tag: tag,
					set: true,
				},
				NoncurrentVersionExpiration: NoncurrentVersionExpiration{
					NewerNoncurrentVersions: retainVersions[i],
					set:                     true,

Created: Sun Apr 05 19:28:12 GMT 2026

- Last Modified: Tue Apr 08 15:41:24 GMT 2025

- 5K bytes

- Click Count (0)

github.com/minio/minio

helm-releases/minio-5.1.0.tgz

server: $SCHEME://$MINIO_ENDPOINT:$MINIO_PORT" MC_COMMAND="${MC} alias set myminio $SCHEME://$MINIO_ENDPOINT:$MINIO_PORT $ACCESS $SECRET" $MC_COMMAND STATUS=$? until [ $STATUS = 0 ]; do ATTEMPTS=$(expr $ATTEMPTS + 1) echo \"Failed attempts: $ATTEMPTS\" if [ $ATTEMPTS -gt $LIMIT ]; then exit 1 fi sleep 2 # 1 second intervals between attempts $MC_COMMAND STATUS=$? done set -e # reset `e` as active return 0 } # checkBucketExists ($bucket) # Check if the bucket exists, by using the exit code of `mc ls` checkBucketExists()...

Created: Sun Apr 05 19:28:12 GMT 2026

- Last Modified: Sun Mar 03 18:49:37 GMT 2024

- 21.3K bytes

- Click Count (0)

github.com/google/guava

guava/src/com/google/common/cache/CacheLoader.java

   * @throws InterruptedException if this method is interrupted. {@code InterruptedException} is
   *     treated like any other {@code Exception} in all respects except that, when it is caught,
   *     the thread's interrupted status is set
   */
  public abstract V load(K key) throws Exception;

  /**
   * Computes or retrieves a replacement value corresponding to an already-cached {@code key}. This

Created: Fri Apr 03 12:43:13 GMT 2026

- Last Modified: Wed Jan 28 22:39:02 GMT 2026

- 9.5K bytes

- Click Count (0)

github.com/minio/minio

internal/kms/secret-key.go

func (secretKey) APIs(ctx context.Context) ([]madmin.KMSAPI, error) {
	return nil, ErrNotSupported
}

// Status returns a set of endpoints and their KMS status. Since, the builtin KMS is not
// external it returns "127.0.0.1: online".
func (secretKey) Status(context.Context) (map[string]madmin.ItemState, error) {
	return map[string]madmin.ItemState{
		"127.0.0.1": madmin.ItemOnline,
	}, nil
}

Created: Sun Apr 05 19:28:12 GMT 2026

- Last Modified: Mon Apr 21 16:23:51 GMT 2025

- 8.4K bytes

- Click Count (0)

github.com/minio/minio

cmd/admin-handlers-users.go

}

// SetGroupStatus - PUT /minio/admin/v3/set-group-status?group=mygroup1&status=enabled
func (a adminAPIHandlers) SetGroupStatus(w http.ResponseWriter, r *http.Request) {
	ctx := r.Context()

	objectAPI, _ := validateAdminReq(ctx, w, r, policy.EnableGroupAdminAction)
	if objectAPI == nil {
		return
	}

	vars := mux.Vars(r)
	group := vars["group"]
	status := vars["status"]

	var (
		err       error

Created: Sun Apr 05 19:28:12 GMT 2026

- Last Modified: Fri Aug 29 02:39:48 GMT 2025

- 90.6K bytes

- Click Count (0)

Search Options