Search Options

Results per page
Sort
Preferred Languages
Advance

Results 421 - 430 of 454 for Buckets (0.03 sec)

  1. src/archive/tar/common.go

    			h.Typeflag = TypeChar
    		} else {
    			h.Typeflag = TypeBlock
    		}
    	case fm&fs.ModeNamedPipe != 0:
    		h.Typeflag = TypeFifo
    	case fm&fs.ModeSocket != 0:
    		return nil, fmt.Errorf("archive/tar: sockets not supported")
    	default:
    		return nil, fmt.Errorf("archive/tar: unknown file mode %v", fm)
    	}
    	if fm&fs.ModeSetuid != 0 {
    		h.Mode |= c_ISUID
    	}
    	if fm&fs.ModeSetgid != 0 {
    		h.Mode |= c_ISGID
    	}
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Fri Sep 13 21:03:27 UTC 2024
    - 24.5K bytes
    - Viewed (0)
  2. doc/godebug.md

    for reparse points, which can be controlled with the `winsymlink` setting.
    As of Go 1.23 (`winsymlink=1`), mount points no longer have [`os.ModeSymlink`](/pkg/os#ModeSymlink)
    set, and reparse points that are not symlinks, Unix sockets, or dedup files now
    always have [`os.ModeIrregular`](/pkg/os#ModeIrregular) set. As a result of these changes,
    [`filepath.EvalSymlinks`](/pkg/path/filepath#EvalSymlinks) no longer evaluates
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Tue Jul 08 18:30:38 UTC 2025
    - 22.9K bytes
    - Viewed (0)
  3. cmd/iam.go

    	return updatedAt, nil
    }
    
    // ListBucketUsers - list all users who can access this 'bucket'
    func (sys *IAMSys) ListBucketUsers(ctx context.Context, bucket string) (map[string]madmin.UserInfo, error) {
    	if !sys.Initialized() {
    		return nil, errServerNotInitialized
    	}
    
    	select {
    	case <-sys.configLoaded:
    		return sys.store.GetBucketUsers(bucket)
    	case <-ctx.Done():
    		return nil, ctx.Err()
    	}
    }
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 75.3K bytes
    - Viewed (0)
  4. guava/src/com/google/common/io/ByteStreams.java

       * <ol>
       *   <li>Use sendfile(2) or equivalent. Requires that both the input channel and the output
       *       channel have their own file descriptors. Generally this only happens when both channels
       *       are files or sockets. This performs zero copies - the bytes never enter userspace.
       *   <li>Use mmap(2) or equivalent. Requires that either the input channel or the output channel
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Jul 17 15:26:41 UTC 2025
    - 31.1K bytes
    - Viewed (0)
  5. cmd/xl-storage-format-v2.go

    	"time"
    
    	"github.com/cespare/xxhash/v2"
    	"github.com/google/uuid"
    	jsoniter "github.com/json-iterator/go"
    	"github.com/minio/minio/internal/bpool"
    	"github.com/minio/minio/internal/bucket/lifecycle"
    	"github.com/minio/minio/internal/bucket/replication"
    	"github.com/minio/minio/internal/config/storageclass"
    	xhttp "github.com/minio/minio/internal/http"
    	"github.com/tinylib/msgp/msgp"
    )
    
    var (
    	// XL header specifies the format
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 65.6K bytes
    - Viewed (1)
  6. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/ws/RealWebSocket.kt

      private var minimumDeflateSize: Long,
      private val webSocketCloseTimeout: Long,
    ) : WebSocket,
      WebSocketReader.FrameCallback,
      Lockable {
      private val key: String
    
      /** Non-null for client web sockets. These can be canceled. */
      internal var call: Call? = null
    
      /** This task processes the outgoing queues. Call [runWriter] to after enqueueing. */
      private var writerTask: Task? = null
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 21.6K bytes
    - Viewed (0)
  7. okhttp/src/jvmTest/kotlin/okhttp3/URLConnectionTest.kt

      /** Confirm that an unacknowledged write times out.  */
      @Test
      fun writeTimeouts() {
        val server = MockWebServer()
        // Sockets on some platforms can have large buffers that mean writes do not block when
        // required. These socket factories explicitly set the buffer sizes on sockets created.
        val socketBufferSize = 4 * 1024
        server.serverSocketFactory =
          object : DelegatingServerSocketFactory(getDefault()) {
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sat Jun 21 20:36:35 UTC 2025
    - 133.2K bytes
    - Viewed (0)
  8. src/main/resources/fess_label.properties

    labels.notification_login=Login Page
    labels.notification_search_top=Search Top Page
    labels.storage_endpoint=Endpoint
    labels.storage_access_key=Access Key
    labels.storage_secret_key=Secret Key
    labels.storage_bucket=Bucket
    labels.send_testmail=Send Test Mail
    labels.backup_configuration=Backup
    labels.backup_name=Name
    labels.backup_bulk_file=Bulk File
    labels.backup_button_upload=Upload
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Sat Jun 28 08:40:50 UTC 2025
    - 40.7K bytes
    - Viewed (0)
  9. CHANGELOG.md

        of unacknowledged data per stream and no per-connection limit.
    
     *  Fix: Don't close a `Deflater` while we're still using it to compress a web socket message. We
        had a severe bug where web sockets were closed on the wrong thread, which caused
        `NullPointerException` crashes in `Deflater`.
    
     *  Fix: Don't crash after a web socket fails its connection upgrade. We incorrectly released
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Mon Jul 07 19:32:33 UTC 2025
    - 31.6K bytes
    - Viewed (1)
  10. okhttp/src/commonJvmAndroid/kotlin/okhttp3/OkHttpClient.kt

         *   failure to reach any individual IP address doesn't fail the overall request. This can
         *   increase availability of multi-homed services.
         *
         * * **Stale pooled connections.** The [ConnectionPool] reuses sockets
         *   to decrease request latency, but these connections will occasionally time out.
         *
         * * **Unreachable proxy servers.** A [ProxySelector] can be used to
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Mon May 05 16:01:00 UTC 2025
    - 51.7K bytes
    - Viewed (0)
Back to top