- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 42 for resync (0.41 sec)
-
cmd/untar.go
r = bf default: return fmt.Errorf("Unsupported format %s", f) } tarReader := tar.NewReader(r) n := 0 asyncWriters := make(chan struct{}, 16) var wg sync.WaitGroup var asyncErr error var asyncErrMu sync.Mutex for { if !o.ignoreErrs { asyncErrMu.Lock() err := asyncErr asyncErrMu.Unlock() if err != nil { return err } }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 6K bytes - Viewed (0) -
cmd/bootstrap-peer-server.go
clnts := newBootstrapRESTClients(endpointServerPools, gm) var onlineServers int var offlineEndpoints []error var incorrectConfigs []error var retries int var mu sync.Mutex for onlineServers < len(clnts)/2 { var wg sync.WaitGroup wg.Add(len(clnts)) onlineServers = 0 for _, clnt := range clnts { go func(clnt *bootstrapRESTClient) { defer wg.Done()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 7.5K bytes - Viewed (0) -
internal/dsync/dsync-server_test.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package dsync import ( "fmt" "io" "net/http" "net/http/httptest" "sync" "sync/atomic" "time" "github.com/minio/mux" ) const numberOfNodes = 5 var ( ds *Dsync nodes = make([]*httptest.Server, numberOfNodes) // list of node IP addrs or hostname with ports.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Jan 23 16:46:37 GMT 2023 - 8.3K bytes - Viewed (0) -
internal/dsync/dsync-client_test.go
// GNU Affero General Public License for more details. // // 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 ( "bytes" "context" "errors" "net/http" "net/url" "time" xhttp "github.com/minio/minio/internal/http" "github.com/minio/minio/internal/rest" )
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 20 17:36:09 GMT 2022 - 4.4K bytes - Viewed (0) -
cmd/lock-rest-client_test.go
} // Attempt all calls. _, err = lkClient.RLock(context.Background(), dsync.LockArgs{}) if err == nil { t.Fatal("Expected for Rlock to fail") } _, err = lkClient.Lock(context.Background(), dsync.LockArgs{}) if err == nil { t.Fatal("Expected for Lock to fail") } _, err = lkClient.RUnlock(context.Background(), dsync.LockArgs{}) if err == nil { t.Fatal("Expected for RUnlock to fail") }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Nov 21 01:09:35 GMT 2023 - 2K bytes - Viewed (0) -
internal/dsync/lock-args.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 //go:generate msgp -file $GOFILE // LockArgs is minimal required values for any dsync compatible lock operation. type LockArgs struct { // Unique ID of lock/unlock request. UID string // Resources contains single or multiple entries to be locked/unlocked.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 04:34:26 GMT 2024 - 1.7K bytes - Viewed (0) -
internal/event/targetlist.go
eventsSkipped atomic.Int64 eventsErrorsTotal atomic.Int64 sync.RWMutex targets map[TargetID]Target queue chan asyncEvent ctx context.Context statLock sync.RWMutex targetStats map[TargetID]targetStat } type targetStat struct { // The number of concurrent async Send calls per targets currentSendCalls int64 // The number of total events per target totalEvents int64
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 9.2K bytes - Viewed (0) -
internal/lsync/lrwmutex.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package lsync import ( "context" "math" "math/rand" "sync" "time" ) // A LRWMutex is a mutual exclusion lock with timeouts. type LRWMutex struct { id string source string isWriteLock bool ref int mu sync.Mutex // Mutex to prevent multiple simultaneous locks }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Jan 02 17:15:06 GMT 2022 - 4.8K bytes - Viewed (0) -
internal/disk/fdatasync_linux.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package disk import ( "os" "syscall" "golang.org/x/sys/unix" ) // Fdatasync - fdatasync() is similar to fsync(), but does not flush modified metadata // unless that metadata is needed in order to allow a subsequent data retrieval // to be correctly handled. For example, changes to st_atime or st_mtime
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Sep 29 23:40:28 GMT 2021 - 1.8K bytes - Viewed (0) -
internal/ioutil/append-file_nix.go
package ioutil import ( "io" "os" ) // AppendFile - appends the file "src" to the file "dst" func AppendFile(dst string, src string, osync bool) error { flags := os.O_WRONLY | os.O_APPEND | os.O_CREATE if osync { flags |= os.O_SYNC } appendFile, err := os.OpenFile(dst, flags, 0o666) if err != nil { return err } defer appendFile.Close() srcFile, err := os.Open(src)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Jan 02 17:15:06 GMT 2022 - 1.3K bytes - Viewed (0)