Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 1,181 for rsync (0.04 sec)

  1. src/main/java/jcifs/internal/smb2/ServerMessageBlock2.java

         *            the readSize to set
         */
        public void setReadSize ( int readSize ) {
            this.readSize = readSize;
        }
    
    
        /**
         * @return the async
         */
        public boolean isAsync () {
            return this.async;
        }
    
    
        /**
         * @param command
         *            the command to set
         */
        @Override
        public final void setCommand ( int command ) {
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Sep 30 10:47:31 UTC 2018
    - 19.9K bytes
    - Viewed (0)
  2. internal/grid/muxserver.go

    		LastPing:           time.Now().Unix(),
    		BaseFlags:          c.baseFlags,
    		clientPingInterval: c.clientPingInterval,
    	}
    	// Acknowledge Mux created.
    	// Send async.
    	var wg sync.WaitGroup
    	wg.Add(1)
    	go func() {
    		defer wg.Done()
    		var ack message
    		ack.Op = OpAckMux
    		ack.Flags = m.BaseFlags
    		ack.MuxID = m.ID
    		m.send(ack)
    		if debugPrint {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 9.7K bytes
    - Viewed (0)
  3. cmd/bucket-replication.go

    	default:
    		return brs, fmt.Errorf("unexpected resync meta version: %d", brs.Version)
    	}
    	return brs, nil
    }
    
    // save resync status to resync.bin
    func saveResyncStatus(ctx context.Context, bucket string, brs BucketReplicationResyncStatus, objectAPI ObjectLayer) error {
    	data := make([]byte, 4, brs.Msgsize()+4)
    
    	// Initialize the resync meta header.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 10 06:49:55 UTC 2024
    - 116.1K bytes
    - Viewed (0)
  4. cmd/globals.go

    	// Only needed for tracking
    	globalServiceFreezeCnt int32
    	globalServiceFreezeMu  sync.Mutex // Updates.
    
    	// Map of local drives to this node, this is set during server startup,
    	// disk reconnect and mutated by HealFormat. Hold globalLocalDrivesMu to access.
    	globalLocalDrivesMap map[string]StorageAPI
    	globalLocalDrivesMu  sync.RWMutex
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 03 18:23:41 UTC 2024
    - 16.2K bytes
    - Viewed (1)
  5. cmd/iam-etcd-store.go

    	return ies.loadMappedPolicy(ctx, name, userType, isGroup, m)
    }
    
    func (ies *IAMEtcdStore) loadMappedPolicy(ctx context.Context, name string, userType IAMUserType, isGroup bool, m *xsync.MapOf[string, MappedPolicy]) error {
    	var p MappedPolicy
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 01:29:20 UTC 2024
    - 14K bytes
    - Viewed (0)
  6. internal/s3select/json/preader.go

    	err         error           // global error state, only touched by Reader.Read
    	bufferPool  sync.Pool       // pool of []byte objects for input
    	kvDstPool   sync.Pool       // pool of []jstream.KV used for output
    	close       chan struct{}   // used for shutting down the splitter before end of stream
    	readerWg    sync.WaitGroup  // used to keep track of async reader.
    }
    
    // queueItem is an item in the queue.
    type queueItem struct {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 6.5K bytes
    - Viewed (0)
  7. cmd/mrf.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    //go:generate msgp -file=$GOFILE
    
    package cmd
    
    import (
    	"context"
    	"encoding/binary"
    	"errors"
    	"fmt"
    	"io"
    	"sync"
    	"sync/atomic"
    	"time"
    
    	"github.com/google/uuid"
    	"github.com/minio/madmin-go/v3"
    	"github.com/minio/pkg/v3/wildcard"
    	"github.com/tinylib/msgp/msgp"
    )
    
    const (
    	mrfOpsQueueSize = 100000
    )
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 13 22:26:05 UTC 2024
    - 6.5K bytes
    - Viewed (0)
  8. internal/lsync/lrwmutex_test.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package lsync_test
    
    import (
    	"context"
    	"fmt"
    	"runtime"
    	"sync"
    	"sync/atomic"
    	"testing"
    	"time"
    
    	. "github.com/minio/minio/internal/lsync"
    )
    
    func testSimpleWriteLock(t *testing.T, duration time.Duration) (locked bool) {
    	ctx := context.Background()
    	lrwm := NewLRWMutex()
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Mar 05 04:57:35 UTC 2023
    - 7.9K bytes
    - Viewed (0)
  9. internal/dsync/drwmutex_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 dsync
    
    import (
    	"context"
    	"fmt"
    	"runtime"
    	"sync/atomic"
    	"testing"
    	"time"
    )
    
    const (
    	id     = "1234-5678"
    	source = "main.go"
    )
    
    func testSimpleWriteLock(t *testing.T, duration time.Duration) (locked bool) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Dec 24 03:49:07 UTC 2022
    - 9.7K bytes
    - Viewed (0)
  10. internal/s3select/csv/reader.go

    	err          error            // global error state, only touched by Reader.Read
    	bufferPool   sync.Pool        // pool of []byte objects for input
    	csvDstPool   sync.Pool        // pool of [][]string used for output
    	close        chan struct{}    // used for shutting down the splitter before end of stream
    	readerWg     sync.WaitGroup   // used to keep track of async reader.
    }
    
    // queueItem is an item in the queue.
    type queueItem struct {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Feb 22 06:26:06 UTC 2024
    - 8.9K bytes
    - Viewed (0)
Back to top