Search Options

Results per page
Sort
Preferred Languages
Advance

Results 951 - 960 of 1,178 for rsync (0.03 sec)

  1. docs/site-replication/run-multi-site-minio-idp.sh

    	echo "expected 'bucket2' delete and 'newbucket2' creation to have replicated, exiting..."
    	exit_1
    fi
    
    # force a resync after removing all site replication
    ./mc admin replicate rm --all --force minio1
    ./mc rb minio2 --force --dangerous
    ./mc admin replicate add minio1 minio2
    ./mc admin replicate resync start minio1 minio2
    sleep 30
    
    ./mc ls -r --versions minio1/newbucket >/tmp/minio1.txt
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 24 08:03:58 UTC 2024
    - 12.1K bytes
    - Viewed (0)
  2. cmd/naughty-disk_test.go

    //
    // You should have received a copy of the GNU Affero General Public License
    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package cmd
    
    import (
    	"context"
    	"io"
    	"sync"
    	"time"
    
    	"github.com/minio/madmin-go/v3"
    )
    
    // naughtyDisk wraps a POSIX disk and returns programmed errors
    // specified by the developer. The purpose is to simulate errors
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Aug 12 08:38:15 UTC 2024
    - 10.1K bytes
    - Viewed (0)
  3. cmd/tier.go

    // TierConfigMgr holds the collection of remote tiers configured in this deployment.
    type TierConfigMgr struct {
    	sync.RWMutex `msg:"-"`
    	drivercache  map[string]WarmBackend `msg:"-"`
    
    	Tiers           map[string]madmin.TierConfig `json:"tiers"`
    	lastRefreshedAt time.Time                    `msg:"-"`
    }
    
    type tierMetrics struct {
    	sync.RWMutex  // protects requestsCount only
    	requestsCount map[string]struct {
    		success int64
    		failure int64
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 12 20:44:05 UTC 2024
    - 15.7K bytes
    - Viewed (0)
  4. internal/s3select/select.go

    func init() {
    	parquetSupport = env.Get("MINIO_API_SELECT_PARQUET", config.EnableOff) == config.EnableOn
    }
    
    var bufPool = sync.Pool{
    	New: func() interface{} {
    		// make a buffer with a reasonable capacity.
    		return bytes.NewBuffer(make([]byte, 0, maxRecordSize))
    	},
    }
    
    var bufioWriterPool = sync.Pool{
    	New: func() interface{} {
    		// io.Discard is just used to create the writer. Actual destination
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 22 00:33:43 UTC 2024
    - 21.2K bytes
    - Viewed (0)
  5. internal/kms/kes.go

    //
    // You should have received a copy of the GNU Affero General Public License
    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package kms
    
    import (
    	"context"
    	"errors"
    	"net/http"
    	"sync"
    	"time"
    
    	"github.com/minio/kms-go/kes"
    	"github.com/minio/madmin-go/v3"
    )
    
    type kesConn struct {
    	defaultKeyID string
    	client       *kes.Client
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Aug 18 06:43:03 UTC 2024
    - 7.3K bytes
    - Viewed (0)
  6. docs/metrics/v3.md

    |-----------------------------------------------|-------------------------------------------------------------------------------------------------------|----------|
    | `minio_notification_current_send_in_progress` | Number of concurrent async Send calls active to all targets. <br><br>Type: counter                    | `server` |
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Aug 02 22:30:11 UTC 2024
    - 45.2K bytes
    - Viewed (0)
  7. internal/rest/rpc-stats.go

    //
    // You should have received a copy of the GNU Affero General Public License
    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package rest
    
    import (
    	"net/http"
    	"net/http/httptrace"
    	"sync/atomic"
    	"time"
    )
    
    var globalStats = struct {
    	errs uint64
    
    	tcpDialErrs                 uint64
    	tcpDialCount                uint64
    	tcpDialTotalDur             uint64
    	tcpTimeForFirstByteTotalDur uint64
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 13 18:21:34 UTC 2024
    - 2.6K bytes
    - Viewed (0)
  8. internal/config/identity/plugin/config.go

    package plugin
    
    import (
    	"bytes"
    	"context"
    	"crypto/sha1"
    	"encoding/base64"
    	"encoding/json"
    	"fmt"
    	"io"
    	"net/http"
    	"net/url"
    	"regexp"
    	"sync"
    	"time"
    
    	"github.com/minio/minio/internal/arn"
    	"github.com/minio/minio/internal/config"
    	"github.com/minio/minio/internal/logger"
    	"github.com/minio/pkg/v3/env"
    	xnet "github.com/minio/pkg/v3/net"
    )
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  9. tensorflow/c/eager/parallel_device/parallel_device_test.cc

      return TensorHandlePtr(result_handle);
    }
    
    void TestCollective(bool async) {
      std::unique_ptr<TF_Status, decltype(&TF_DeleteStatus)> status(
          TF_NewStatus(), TF_DeleteStatus);
      std::unique_ptr<TFE_ContextOptions, decltype(&TFE_DeleteContextOptions)> opts(
          TFE_NewContextOptions(), TFE_DeleteContextOptions);
      TFE_ContextOptionsSetAsync(opts.get(), async);
      std::unique_ptr<TF_Buffer, decltype(&TF_DeleteBuffer)> config(
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Tue Aug 06 23:56:17 UTC 2024
    - 29.4K bytes
    - Viewed (0)
  10. cmd/prepare-storage.go

    package cmd
    
    import (
    	"context"
    	"errors"
    	"fmt"
    	"net/http"
    	"net/url"
    	"path/filepath"
    	"sync"
    	"time"
    
    	"github.com/dustin/go-humanize"
    	xhttp "github.com/minio/minio/internal/http"
    	"github.com/minio/minio/internal/logger"
    )
    
    var printEndpointError = func() func(Endpoint, error, bool) {
    	var mutex sync.Mutex
    	printOnce := make(map[Endpoint]map[string]int)
    
    	return func(endpoint Endpoint, err error, once bool) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 12 20:51:54 UTC 2024
    - 11.1K bytes
    - Viewed (0)
Back to top