Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1031 - 1040 of 1,104 for Async (0.07 seconds)

  1. internal/s3select/jstream/decoder.go

    package jstream
    
    import (
    	"bytes"
    	"encoding/json"
    	"io"
    	"strconv"
    	"sync/atomic"
    	"unicode/utf16"
    )
    
    // ValueType - defines the type of each JSON value
    type ValueType int
    
    // Different types of JSON value
    const (
    	Unknown ValueType = iota
    	Null
    	String
    	Number
    	Boolean
    	Array
    	Object
    )
    
    // MetaValue wraps a decoded interface value with the document
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 13.4K bytes
    - Click Count (0)
  2. guava-tests/benchmark/com/google/common/util/concurrent/MonitorBasedArrayBlockingQueue.java

          else {
            nextIndex = takeIndex;
            nextItem = items[takeIndex];
          }
        }
    
        @Override
        public boolean hasNext() {
          /*
           * No sync. We can return true by mistake here
           * only if this iterator passed across threads,
           * which we don't support anyway.
           */
          return nextIndex >= 0;
        }
    
        /**
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 23 21:06:42 GMT 2026
    - 22.4K bytes
    - Click Count (0)
  3. .teamcity/performance-test-durations.json

      "durations" : [ {
        "testProject" : "largeAndroidBuild",
        "linux" : 427
      } ]
    }, {
      "scenario" : "org.gradle.performance.regression.android.RealLifeAndroidStudioPerformanceTest.run Android Studio sync",
      "durations" : [ {
        "testProject" : "largeAndroidBuild",
        "linux" : 742
      }, {
        "testProject" : "nowInAndroidBuild",
        "linux" : 1163
      }, {
        "testProject" : "santaTrackerAndroidBuild",
    Created: Wed Apr 01 11:36:16 GMT 2026
    - Last Modified: Mon Mar 23 04:45:09 GMT 2026
    - 26.1K bytes
    - Click Count (0)
  4. cmd/admin-handlers-users.go

    	"github.com/minio/minio/internal/config/dns"
    	"github.com/minio/minio/internal/logger"
    	"github.com/minio/mux"
    	xldap "github.com/minio/pkg/v3/ldap"
    	"github.com/minio/pkg/v3/policy"
    	"github.com/puzpuzpuz/xsync/v3"
    )
    
    // RemoveUser - DELETE /minio/admin/v3/remove-user?accessKey=<access_key>
    func (a adminAPIHandlers) RemoveUser(w http.ResponseWriter, r *http.Request) {
    	ctx := r.Context()
    
    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)
  5. cmd/admin-handlers-site-replication.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package cmd
    
    import (
    	"bytes"
    	"context"
    	"encoding/gob"
    	"encoding/json"
    	"errors"
    	"io"
    	"net/http"
    	"strings"
    	"sync/atomic"
    	"time"
    
    	"github.com/dustin/go-humanize"
    	"github.com/minio/madmin-go/v3"
    	xioutil "github.com/minio/minio/internal/ioutil"
    	"github.com/minio/mux"
    	"github.com/minio/pkg/v3/policy"
    )
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 19.4K bytes
    - Click Count (0)
  6. cmd/update.go

    package cmd
    
    import (
    	"bufio"
    	"crypto"
    	"crypto/tls"
    	"encoding/hex"
    	"errors"
    	"fmt"
    	"io"
    	"net/http"
    	"net/url"
    	"os"
    	"path"
    	"path/filepath"
    	"runtime"
    	"strings"
    	"sync/atomic"
    	"time"
    
    	"github.com/klauspost/compress/zstd"
    	xhttp "github.com/minio/minio/internal/http"
    	"github.com/minio/minio/internal/logger"
    	"github.com/minio/pkg/v3/env"
    	xnet "github.com/minio/pkg/v3/net"
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 18.9K bytes
    - Click Count (0)
  7. internal/config/config.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package config
    
    import (
    	"bufio"
    	"fmt"
    	"io"
    	"maps"
    	"regexp"
    	"slices"
    	"sort"
    	"strings"
    	"sync"
    
    	"github.com/minio/madmin-go/v3"
    	"github.com/minio/minio-go/v7/pkg/set"
    	"github.com/minio/minio/internal/auth"
    	"github.com/minio/pkg/v3/env"
    )
    
    // ErrorConfig holds the config error types
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 37.7K bytes
    - Click Count (0)
  8. android/guava/src/com/google/common/collect/ImmutableBiMap.java

       * as implementation details.
       *
       * <p>Since the bimap is immutable, ImmutableBiMap doesn't require special logic for keeping the
       * bimap and its inverse in sync during serialization, the way AbstractBiMap does.
       */
      @J2ktIncompatible // serialization
      private static final class SerializedForm<K, V> extends ImmutableMap.SerializedForm<K, V> {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Aug 07 16:05:33 GMT 2025
    - 22.2K bytes
    - Click Count (0)
  9. scripts/general-llm-prompt.md

    $ cd code
    // Erstelle ein Verzeichnis für dieses Projekt
    $ mkdir awesome-project
    // Gehe in dieses Projektverzeichnis
    $ cd awesome-project
    ```
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Wed Mar 18 10:55:36 GMT 2026
    - 14.6K bytes
    - Click Count (0)
  10. cmd/bucket-replication-handlers.go

    		writeErrorResponseJSON(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    }
    
    // ResetBucketReplicationStartHandler - starts a replication reset for all objects in a bucket which
    // qualify for replication and re-sync the object(s) to target, provided ExistingObjectReplication is
    // enabled for the qualifying rule. This API is a MinIO only extension provided for situations where
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Thu Aug 15 12:04:40 GMT 2024
    - 23.3K bytes
    - Click Count (0)
Back to Top