- Sort Score
- Result 10 results
- Languages All
Results 1 - 4 of 4 for sendZero (0.37 sec)
-
internal/grid/muxserver.go
go func() { wg.Wait() defer xioutil.SafeClose(send) err := m.handleRequests(ctx, msg, send, handler, handlerIn) if err != nil { handlerErr.Store(err) } }() // Response sender goroutine... go func(outBlock <-chan struct{}) { wg.Wait() defer m.parent.deleteMux(true, m.ID) m.sendResponses(ctx, send, c, &handlerErr, outBlock) }(m.outBlock) // Remote aliveness check if needed.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 9.7K bytes - Viewed (0) -
internal/grid/muxclient.go
} if !m.respMu.TryLock() { // Cancel before locking - will unblock any pending sends. if m.cancelFn != nil { m.cancelFn(context.Canceled) } // Wait for senders to release. m.respMu.Lock() } defer m.respMu.Unlock() m.closeLocked() } func (m *muxClient) closeLocked() { if m.closed { return }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 15.9K bytes - Viewed (0) -
internal/grid/connection.go
// Returning error here is too noisy. return nil case c.outQueue <- msg: return nil } } // queueMsg queues a message, with an optional payload. // sender should not reference msg.Payload func (c *Connection) queueMsg(msg message, payload sender) error { // Add baseflags. msg.Flags.Set(c.baseFlags) // This cannot encode subroute. msg.Flags.Clear(FlagSubroute) if payload != nil {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 44.8K bytes - Viewed (0) -
cmd/bucket-handlers.go
writeSuccessResponseXML(w, encodedSuccessResponse) } // ListBucketsHandler - GET Service. // ----------- // This implementation of the GET operation returns a list of all buckets // owned by the authenticated sender of the request. func (api objectAPIHandlers) ListBucketsHandler(w http.ResponseWriter, r *http.Request) { ctx := newContext(r, w, "ListBuckets") defer logger.AuditLog(ctx, w, r, mustGetClaimsFromToken(r))
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 14 13:28:35 UTC 2024 - 61.2K bytes - Viewed (0)