- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 284 for guid (0.32 sec)
-
internal/grid/grid.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 grid provides single-connection two-way grid communication. package grid import ( "context" "errors" "fmt" "io" "sync" "time" "github.com/gobwas/ws/wsutil" )
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 02 15:56:18 GMT 2024 - 4.8K bytes - Viewed (0) -
cmd/grid.go
"sync/atomic" "github.com/minio/minio/internal/fips" "github.com/minio/minio/internal/grid" xhttp "github.com/minio/minio/internal/http" "github.com/minio/minio/internal/rest" ) // globalGrid is the global grid manager. var globalGrid atomic.Pointer[grid.Manager] // globalGridStart is a channel that will block startup of grid connections until closed. var globalGridStart = make(chan struct{})
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Mar 26 15:00:38 GMT 2024 - 2K bytes - Viewed (0) -
internal/grid/grid_test.go
errFatal := func(err error) { t.Helper() if err != nil { t.Fatal(err) } } grid, err := SetupTestGrid(2) errFatal(err) t.Cleanup(grid.Cleanup) local := grid.Managers[0] localHost := grid.Hosts[0] remote := grid.Managers[1] remoteHost := grid.Hosts[1] connLocalToRemote := local.Connection(remoteHost) connRemoteLocal := remote.Connection(localHost)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 30 15:03:35 GMT 2024 - 30.1K bytes - Viewed (0) -
internal/grid/manager.go
RoutePath = "/minio/grid/" + apiVersion ) // Manager will contain all the connections to the grid. // It also handles incoming requests and routes them to the appropriate connection. type Manager struct { // ID is an instance ID, that will change whenever the server restarts. // This allows remotes to keep track of whether state is preserved. ID uuid.UUID // Immutable after creation, so no locks.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 9.5K bytes - Viewed (0) -
src/archive/tar/stat_unix.go
} // userMap and groupMap caches UID and GID lookups for performance reasons. // The downside is that renaming uname or gname by the OS never takes effect. var userMap, groupMap sync.Map // map[int]string func statUnix(fi fs.FileInfo, h *Header, doNameLookups bool) error { sys, ok := fi.Sys().(*syscall.Stat_t) if !ok { return nil } h.Uid = int(sys.Uid) h.Gid = int(sys.Gid) if doNameLookups {
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Fri Mar 15 16:01:50 GMT 2024 - 3.2K bytes - Viewed (0) -
internal/grid/connection.go
LastPong int64 // State of the connection (atomic) state State // Non-atomic Remote string Local string // ID of this connection instance. id uuid.UUID // Remote uuid, if we have been connected. remoteID *uuid.UUID reconnectMu sync.Mutex // Context for the server. ctx context.Context // Active mux connections. outgoing *xsync.MapOf[uint64, *muxClient] // Incoming streams
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 42.6K bytes - Viewed (0) -
src/archive/tar/tar_test.go
} if got, want := h2.Size, v.h.Size; got != want { t.Errorf("i=%d: Size: got %v, want %v", i, got, want) } if got, want := h2.Uid, v.h.Uid; got != want { t.Errorf("i=%d: Uid: got %d, want %d", i, got, want) } if got, want := h2.Gid, v.h.Gid; got != want { t.Errorf("i=%d: Gid: got %d, want %d", i, got, want) } if got, want := h2.Uname, v.h.Uname; got != want {
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Fri Mar 15 16:01:50 GMT 2024 - 24K bytes - Viewed (0) -
cmd/erasure-healing.go
driveState = madmin.DriveStateCorrupt } result.Before.Drives = append(result.Before.Drives, madmin.HealDriveInfo{ UUID: "", Endpoint: storageEndpoints[i].String(), State: driveState, }) result.After.Drives = append(result.After.Drives, madmin.HealDriveInfo{ UUID: "", Endpoint: storageEndpoints[i].String(), State: driveState, })
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 26 06:32:14 GMT 2024 - 33.1K bytes - Viewed (0) -
src/archive/tar/reader.go
hdr.Name = p.parseString(v7.name()) hdr.Linkname = p.parseString(v7.linkName()) hdr.Size = p.parseNumeric(v7.size()) hdr.Mode = p.parseNumeric(v7.mode()) hdr.Uid = int(p.parseNumeric(v7.uid())) hdr.Gid = int(p.parseNumeric(v7.gid())) hdr.ModTime = time.Unix(p.parseNumeric(v7.modTime()), 0) // Unpack format specific fields. if format > formatV7 { ustar := tr.blk.toUSTAR()
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Fri Mar 08 01:59:14 GMT 2024 - 26.8K bytes - Viewed (0) -
cmd/storage-datatypes.go
buf := grid.GetByteBufferCap(32 + 16<<10) return &RenameDataInlineHandlerParams{RenameDataHandlerParams{FI: FileInfo{Data: buf[:0]}}} } // Recycle will reuse the memory allocated for the FileInfo data. func (r *RenameDataInlineHandlerParams) Recycle() { if r == nil { return } if cap(r.FI.Data) >= xioutil.SmallBlock { grid.PutByteBuffer(r.FI.Data) r.FI.Data = nil }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 17:15:52 GMT 2024 - 15.3K bytes - Viewed (0)