Search Options

Results per page
Sort
Preferred Languages
Advance

Results 921 - 930 of 1,181 for rsync (0.02 sec)

  1. cmd/xl-storage_noatime_notsupported.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package cmd
    
    import (
    	"os"
    )
    
    var (
    	// No special option for reads on windows
    	readMode = os.O_RDONLY
    
    	// Write with sync no buffering only used only for `xl.meta` writes
    	writeMode = os.O_SYNC
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jul 23 16:36:24 UTC 2024
    - 1001 bytes
    - Viewed (0)
  2. cni/pkg/log/uds.go

    	"fmt"
    	"io"
    	"net/http"
    	"strings"
    	"sync"
    	"time"
    
    	"istio.io/istio/cni/pkg/constants"
    	"istio.io/istio/cni/pkg/scopes"
    	istiolog "istio.io/istio/pkg/log"
    	"istio.io/istio/pkg/network"
    	"istio.io/istio/pkg/uds"
    )
    
    var (
    	pluginLog = scopes.CNIPlugin
    	log       = scopes.CNIAgent
    )
    
    type UDSLogger struct {
    	mu            sync.Mutex
    	loggingServer *http.Server
    }
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Jun 28 19:12:54 UTC 2024
    - 4.7K bytes
    - Viewed (0)
  3. cmd/admin-handlers-site-replication.go

    		adminLogIf(ctx, err)
    		writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL)
    		return
    	}
    }
    
    // SiteReplicationResyncOp - PUT /minio/admin/v3/site-replication/resync/op
    func (a adminAPIHandlers) SiteReplicationResyncOp(w http.ResponseWriter, r *http.Request) {
    	ctx := r.Context()
    
    	objectAPI, _ := validateAdminReq(ctx, w, r, policy.SiteReplicationResyncAction)
    	if objectAPI == nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 19.4K bytes
    - Viewed (0)
  4. tests/test_regex_deprecated_params.py

    from typing_extensions import Annotated
    
    from .utils import needs_py310
    
    
    def get_client():
        app = FastAPI()
        with pytest.warns(DeprecationWarning):
    
            @app.get("/items/")
            async def read_items(
                q: Annotated[str | None, Query(regex="^fixedquery$")] = None,
            ):
                if q:
                    return f"Hello {q}"
                else:
                    return "Hello World"
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Thu Apr 18 19:40:57 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  5. internal/store/queuestore.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package store
    
    import (
    	"bytes"
    	"encoding/json"
    	"errors"
    	"os"
    	"path/filepath"
    	"sort"
    	"sync"
    	"time"
    
    	"github.com/google/uuid"
    	jsoniter "github.com/json-iterator/go"
    	"github.com/klauspost/compress/s2"
    	"github.com/valyala/bytebufferpool"
    )
    
    const (
    	defaultLimit = 100000 // Default store limit.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 8.6K bytes
    - Viewed (0)
  6. cmd/background-newdisks-heal-ops.go

    	}
    	h.disk = disk
    	h.ID = diskID
    	h.mu = &sync.RWMutex{}
    	return &h, nil
    }
    
    // newHealingTracker will create a new healing tracker for the disk.
    func newHealingTracker() *healingTracker {
    	return &healingTracker{
    		mu: &sync.RWMutex{},
    	}
    }
    
    func initHealingTracker(disk StorageAPI, healID string) *healingTracker {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 16.6K bytes
    - Viewed (0)
  7. src/main/webapp/js/admin/plugins/form-validator/jquery.form-validator.min.js

    n(this.$form),this.haltedFormValidation=!0,this.isRunning=!0,this.$input.attr("disabled","disabled").addClass("async-validation"),this.$form.addClass("async-validation"),b(function(a){this.done(a)}.bind(this)),null)},d.prototype.done=function(a){this.result=a,this.hasRun=!0,this.isRunning=!1,this.$input.removeAttr("disabled").removeClass("async-validation"),this.$form.removeClass("async-validation"),this.haltedFormValidation&&(g.unHaltValidation(this.$form),"submit"===f?this.$form.trigger("submi...
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Mon Jan 01 05:12:47 UTC 2018
    - 32.8K bytes
    - Viewed (0)
  8. internal/config/heal/heal.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package heal
    
    import (
    	"errors"
    	"fmt"
    	"strconv"
    	"strings"
    	"sync"
    	"time"
    
    	"github.com/minio/minio/internal/config"
    	"github.com/minio/pkg/v3/env"
    )
    
    // Compression environment variables
    const (
    	Bitrot       = "bitrotscan"
    	Sleep        = "max_sleep"
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 4.9K bytes
    - Viewed (0)
  9. internal/disk/stat_test.go

    		testCase := testCase
    		t.Run("", func(t *testing.T) {
    			tmpfile, err := os.CreateTemp("", "testfile")
    			if err != nil {
    				t.Error(err)
    			}
    			tmpfile.WriteString(testCase.stat)
    			tmpfile.Sync()
    			tmpfile.Close()
    
    			iostats, err := readDriveStats(tmpfile.Name())
    			if err != nil && !testCase.expectErr {
    				t.Fatalf("unexpected err; %v", err)
    			}
    			if testCase.expectErr && err == nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 3.5K bytes
    - Viewed (0)
  10. cmd/metacache-bucket.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package cmd
    
    import (
    	"context"
    	"errors"
    	"runtime/debug"
    	"sort"
    	"sync"
    	"time"
    
    	"github.com/minio/minio/internal/logger"
    	"github.com/minio/pkg/v3/console"
    )
    
    // a bucketMetacache keeps track of all caches generated
    // for a bucket.
    type bucketMetacache struct {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 6.6K bytes
    - Viewed (0)
Back to top