Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 1,181 for rsync (0.1 sec)

  1. cmd/iam-object-store.go

    	"errors"
    	"fmt"
    	"path"
    	"strings"
    	"sync"
    	"time"
    	"unicode/utf8"
    
    	jsoniter "github.com/json-iterator/go"
    	"github.com/minio/madmin-go/v3"
    	"github.com/minio/minio/internal/config"
    	xioutil "github.com/minio/minio/internal/ioutil"
    	"github.com/minio/minio/internal/kms"
    	"github.com/minio/minio/internal/logger"
    	"github.com/minio/pkg/v3/sync/errgroup"
    	"github.com/puzpuzpuz/xsync/v3"
    )
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 10 23:40:37 UTC 2024
    - 26.6K bytes
    - Viewed (0)
  2. internal/grid/connection.go

    		id:                 o.id,
    		ctx:                o.ctx,
    		outgoing:           xsync.NewMapOfPresized[uint64, *muxClient](1000),
    		inStream:           xsync.NewMapOfPresized[uint64, *muxServer](1000),
    		outQueue:           make(chan []byte, defaultOutQueue),
    		side:               ws.StateServerSide,
    		connChange:         &sync.Cond{L: &sync.Mutex{}},
    		handlers:           o.handlers,
    		remote:             &RemoteClient{Name: o.remote},
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 46.7K bytes
    - Viewed (0)
  3. cmd/metacache-server-pool.go

    // The result channel is closed when no more results are expected.
    func (z *erasureServerPools) listMerged(ctx context.Context, o listPathOptions, results chan<- metaCacheEntry) error {
    	var mu sync.Mutex
    	var wg sync.WaitGroup
    	var errs []error
    	allAtEOF := true
    	var inputs []chan metaCacheEntry
    	mu.Lock()
    	// Ask all sets and merge entries.
    	listCtx, cancelList := context.WithCancel(ctx)
    	defer cancelList()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 12 16:23:16 UTC 2024
    - 12.7K bytes
    - Viewed (0)
  4. lib/wasm/wasm_exec.js

    			close(fd, callback) { callback(enosys()); },
    			fchmod(fd, mode, callback) { callback(enosys()); },
    			fchown(fd, uid, gid, callback) { callback(enosys()); },
    			fstat(fd, callback) { callback(enosys()); },
    			fsync(fd, callback) { callback(null); },
    			ftruncate(fd, length, callback) { callback(enosys()); },
    			lchown(path, uid, gid, callback) { callback(enosys()); },
    			link(path, link, callback) { callback(enosys()); },
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Fri Aug 30 19:15:21 UTC 2024
    - 16.5K bytes
    - Viewed (0)
  5. internal/grid/muxclient.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package grid
    
    import (
    	"context"
    	"encoding/binary"
    	"errors"
    	"fmt"
    	"sync"
    	"sync/atomic"
    	"time"
    
    	xioutil "github.com/minio/minio/internal/ioutil"
    	"github.com/zeebo/xxh3"
    )
    
    // muxClient is a stateful connection to a remote.
    type muxClient struct {
    	MuxID              uint64
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 15.9K bytes
    - Viewed (0)
  6. tests/test_dependency_class.py

    @app.get("/callable-dependency")
    async def get_callable_dependency(value: str = Depends(callable_dependency)):
        return value
    
    
    @app.get("/callable-gen-dependency")
    async def get_callable_gen_dependency(value: str = Depends(callable_gen_dependency)):
        return value
    
    
    @app.get("/async-callable-dependency")
    async def get_async_callable_dependency(
        value: str = Depends(async_callable_dependency),
    ):
        return value
    
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Aug 09 10:54:05 UTC 2020
    - 3.3K bytes
    - Viewed (0)
  7. android/guava-tests/test/com/google/common/util/concurrent/SettableFutureTest.java

        async.setFuture(inner);
        async.cancel(false);
        assertTrue(inner.isCancelled());
        assertFalse(inner.wasInterrupted());
        assertThrows(CancellationException.class, () -> inner.get());
      }
    
      public void testCancel_beforeSet() throws Exception {
        SettableFuture<Object> async = SettableFuture.create();
        async.cancel(true);
        assertFalse(async.set(42));
      }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 7.3K bytes
    - Viewed (0)
  8. guava-tests/test/com/google/common/util/concurrent/SettableFutureTest.java

        async.setFuture(inner);
        async.cancel(false);
        assertTrue(inner.isCancelled());
        assertFalse(inner.wasInterrupted());
        assertThrows(CancellationException.class, () -> inner.get());
      }
    
      public void testCancel_beforeSet() throws Exception {
        SettableFuture<Object> async = SettableFuture.create();
        async.cancel(true);
        assertFalse(async.set(42));
      }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 7.3K bytes
    - Viewed (0)
  9. cmd/lock-rest-client.go

    	r, err := h.Call(ctx, c.connection, args)
    	if err != nil {
    		return false, err
    	}
    	defer h.PutResponse(r)
    	ok = r.Code == dsync.RespOK
    	switch r.Code {
    	case dsync.RespLockConflict, dsync.RespLockNotFound, dsync.RespOK:
    	// no error
    	case dsync.RespLockNotInitialized:
    		err = errLockNotInitialized
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 3.3K bytes
    - Viewed (0)
  10. tensorflow/c/eager/c_api_test.cc

      if (forward_input) {
        TFE_DeleteTensorHandle(n);
      }
    
      int num_retvals = 1;
      if (async) {
        // Enqueue dummy ops so we backlog async execution & actually test async.
        // This is usually unnecessary, but we've experienced the occasional test
        // failure when testing async mode with no explicit forwarding.
        for (int i = 0; i < 100000; ++i) {
          TFE_Op* add_op_dummy = AddOp(ctx, m, m);
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Thu Aug 03 20:50:20 UTC 2023
    - 94.6K bytes
    - Viewed (0)
Back to top