- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 124 for respCh (0.21 sec)
-
cmd/background-heal-ops.go
if err != nil { bgSeq.countFailed(res) } else { bgSeq.countHeals(res.Type, false) } } if task.respCh != nil { task.respCh <- healResult{result: res, err: err} } case <-ctx.Done(): return } } } func newHealRoutine() *healRoutine { workers := runtime.GOMAXPROCS(0) / 2
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 4.6K bytes - Viewed (0) -
cmd/admin-heal-ops.go
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 25.1K bytes - Viewed (1) -
cmd/admin-handlers.go
} else { writeSuccessResponseJSON(w, respBytes) } return } respCh := make(chan healResp, 1) switch { case hip.forceStop: go func() { respBytes, apiErr := globalAllHealState.stopHealSequence(healPath) hr := healResp{respBytes: respBytes, apiErr: apiErr} respCh <- hr }() case hip.clientToken == "":
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Sun Apr 21 11:43:18 GMT 2024 - 97.3K bytes - Viewed (2) -
src/test/java/jcifs/tests/OplockTests.java
SmbComNTCreateAndX req2 = new SmbComNTCreateAndX(sess.getConfig(), uncPath, flags, access, sharing, attrs, options, null); req2.addFlags0(0x2); // REQUEST_OPLOCK req2.setOverrideTimeout(1000); req2.setResponse(resp2); try { resp2 = tree.send(req2); }
Java - Registered: Sun Apr 21 00:10:10 GMT 2024 - Last Modified: Thu Jan 05 13:09:03 GMT 2023 - 6.1K bytes - Viewed (0) -
internal/grid/muxclient.go
m.addErrorNonBlockingClose(respHandler, err) } return case resp, ok := <-respServer: if !ok { return } select { case respHandler <- resp: m.respMu.Lock() if !m.closed { gridLogIf(m.ctx, m.sendLocked(message{Op: OpUnblockSrvMux, MuxID: m.MuxID})) } m.respMu.Unlock() case <-m.ctx.Done(): // Client canceled. Don't block.
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 14.2K bytes - Viewed (0) -
cmd/lock-rest-server.go
func (l *lockRESTServer) RefreshHandler(args *dsync.LockArgs) (*dsync.LockResp, *grid.RemoteErr) { resp := lockRPCRefresh.NewResponse() refreshed, err := l.ll.Refresh(context.Background(), *args) if err != nil { return l.makeResp(resp, err) } if !refreshed { return l.makeResp(resp, errLockNotFound) } return l.makeResp(resp, err) } // LockHandler - Acquires a lock.
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Tue Nov 21 01:09:35 GMT 2023 - 5.9K bytes - Viewed (0) -
internal/grid/handlers.go
if r != h.nilResp { h.respPool.Put(r) } } // NewResponse creates a new response. // Handlers can use this to create a reusable response. func (h *StreamTypeHandler[Payload, Req, Resp]) NewResponse() Resp { return h.respPool.Get().(Resp) } func newStreamHandler[Payload, Req, Resp RoundTripper](h HandlerID) *StreamTypeHandler[Payload, Req, Resp] {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 26.9K bytes - Viewed (0) -
internal/grid/connection.go
case debugIsOutgoingClosed: // params: muxID uint64, isClosed func(bool) muxID := args[0].(uint64) resp := args[1].(func(b bool)) mid, ok := c.outgoing.Load(muxID) if !ok || mid == nil { resp(true) return } mid.respMu.Lock() resp(mid.closed) mid.respMu.Unlock() } } // wsWriter writes websocket messages. type wsWriter struct {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 42.6K bytes - Viewed (0) -
cmd/erasure-common.go
func readMultipleFiles(ctx context.Context, disks []StorageAPI, req ReadMultipleReq, readQuorum int) ([]ReadMultipleResp, error) { resps := make([]chan ReadMultipleResp, len(disks)) for i := range resps { resps[i] = make(chan ReadMultipleResp, len(req.Files)) } g := errgroup.WithNErrs(len(disks)) // Read files in parallel across disks. for index := range disks { index := index
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 4.6K bytes - Viewed (0) -
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 default: err = errors.New(r.Err) } return ok, err }
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Fri Nov 24 17:07:14 GMT 2023 - 3.3K bytes - Viewed (0)