Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 72 for respCh (1.74 sec)

  1. cmd/background-heal-ops.go

    				} else {
    					res, err = objAPI.HealObject(ctx, task.bucket, task.object, task.versionID, task.opts)
    				}
    			}
    
    			if task.respCh != nil {
    				task.respCh <- healResult{result: res, err: err}
    				continue
    			}
    
    			// when respCh is not set caller is not waiting but we
    			// update the relevant metrics for them
    			if bgSeq != nil {
    				if err == nil {
    					bgSeq.countHealed(res.Type)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  2. 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 == "":
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 04 11:32:32 UTC 2024
    - 99.7K bytes
    - Viewed (0)
  3. cmd/admin-heal-ops.go

    			return nil
    		}
    		// Don't wait for result
    		return nil
    	}
    
    	// respCh must be set to wait for result.
    	// We make it size 1, so a result can always be written
    	// even if we aren't listening.
    	task.respCh = make(chan healResult, 1)
    	select {
    	case globalBackgroundHealRoutine.tasks <- task:
    		if serverDebugLog {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 25.6K bytes
    - Viewed (0)
  4. internal/grid/muxclient.go

    				m.addErrorNonBlockingClose(respHandler, err)
    			}
    			return
    		case resp, ok := <-respServer:
    			if !ok {
    				return
    			}
    		sendResp:
    			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.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 15.9K bytes
    - Viewed (0)
  5. 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.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 5.8K bytes
    - Viewed (0)
  6. internal/grid/handlers.go

    // If no deadline is set, a 1-minute deadline is added.
    func (h *SingleHandler[Req, Resp]) Call(ctx context.Context, c Requester, req Req) (resp Resp, err error) {
    	if c == nil {
    		if h.ignoreNilConn {
    			return resp, nil
    		}
    		return resp, ErrDisconnected
    	}
    	payload, err := req.MarshalMsg(GetByteBufferCap(req.Msgsize()))
    	if err != nil {
    		return resp, err
    	}
    	switch any(req).(type) {
    	case *MSS, *URLValues:
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 09 16:58:30 UTC 2024
    - 27.7K bytes
    - Viewed (0)
  7. 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()
    	case debugBlockInboundMessages:
    		c.connMu.Lock()
    		block := (<-chan struct{})(args[0].(chan struct{}))
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 46.7K bytes
    - Viewed (0)
  8. 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
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 3.3K bytes
    - Viewed (0)
  9. cmd/peer-rest-client.go

    	resp, err := getLocksRPC.Call(ctx, client.gridConn(), grid.NewMSS())
    	if err != nil || resp == nil {
    		return nil, err
    	}
    	return *resp, nil
    }
    
    // LocalStorageInfo - fetch server information for a remote node.
    func (client *peerRESTClient) LocalStorageInfo(ctx context.Context, metrics bool) (info StorageInfo, err error) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 09 16:58:30 UTC 2024
    - 26.1K bytes
    - Viewed (0)
  10. cni/pkg/nodeagent/ztunnelserver.go

    			}
    			log.Debugf("got update to send to ztunnel")
    			resp, err := conn.sendDataAndWaitForAck(update.Update, update.Fd)
    			if err != nil {
    				log.Errorf("ztunnel acked error: err %v ackErr %s", err, resp.GetAck().GetError())
    			}
    			log.Debugf("ztunnel acked")
    			// Safety: Resp is buffered, so this will not block
    			update.Resp <- updateResponse{
    				err:  err,
    				resp: resp,
    			}
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Jul 29 16:08:35 UTC 2024
    - 13.2K bytes
    - Viewed (0)
Back to top