Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 27 of 27 for Subrouter (0.31 sec)

  1. internal/grid/msg.go

    	FlagPayloadIsErr
    
    	// FlagPayloadIsZero means that payload is 0-length slice and not nil.
    	FlagPayloadIsZero
    
    	// FlagSubroute indicates that the message has subroute.
    	// Subroute will be 32 bytes long and added before any CRC.
    	FlagSubroute
    )
    
    // This struct cannot be changed and retain backwards compatibility.
    // If changed, endpoint version must be bumped.
    //
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jul 25 21:07:21 UTC 2024
    - 7.6K bytes
    - Viewed (0)
  2. internal/grid/muxclient.go

    	if err != nil {
    		return err
    	}
    	if msg.Flags&FlagSubroute != 0 {
    		if m.subroute == nil {
    			return fmt.Errorf("internal error: subroute not defined on client")
    		}
    		hid := m.subroute.withHandler(msg.Handler)
    		before := len(dst)
    		dst = append(dst, hid[:]...)
    		if debugPrint {
    			fmt.Println("Added subroute", hid.String(), "to message", msg, "len", len(dst)-before)
    		}
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 15.9K bytes
    - Viewed (0)
  3. internal/grid/muxserver.go

    }
    
    func newMuxStream(ctx context.Context, msg message, c *Connection, handler StreamHandler) *muxServer {
    	var cancel context.CancelFunc
    	ctx = setCaller(ctx, c.remote)
    	if len(handler.Subroute) > 0 {
    		ctx = setSubroute(ctx, handler.Subroute)
    	}
    	if msg.DeadlineMS > 0 {
    		ctx, cancel = context.WithTimeout(ctx, time.Duration(msg.DeadlineMS)*time.Millisecond+c.addDeadline)
    	} else {
    		ctx, cancel = context.WithCancel(ctx)
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 9.7K bytes
    - Viewed (0)
  4. internal/grid/grid_test.go

    					Embedded:  *i,
    				}
    				n++
    			}
    			return nil
    		}, "subroute", "1"))
    	}
    	register(local)
    	register(remote)
    
    	// local to remote
    	remoteConn := local.Connection(remoteHost)
    	const testPayload = "Hello Grid World!"
    	// Add subroute
    	remoteSub := remoteConn.Subroute(strings.Join([]string{"subroute", "1"}, "/"))
    
    	start := time.Now()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 36.4K bytes
    - Viewed (0)
  5. cmd/storage-rest-client.go

    		return errDiskNotFound
    	}
    	return err
    }
    
    // Abstracts a remote disk.
    type storageRESTClient struct {
    	endpoint   Endpoint
    	restClient *rest.Client
    	gridConn   *grid.Subroute
    	diskID     atomic.Pointer[string]
    
    	diskInfoCache *cachevalue.Cache[DiskInfo]
    }
    
    // Retrieve location indexes.
    func (client *storageRESTClient) GetDiskLoc() (poolIdx, setIdx, diskIdx int) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Oct 13 13:07:21 UTC 2024
    - 30.2K bytes
    - Viewed (0)
  6. android/guava-tests/test/com/google/common/reflect/TypeTokenTest.java

      }
    
      private abstract static class ToReproduceGenericSignatureFormatError<V> {
        private abstract class BaseOuter {
          abstract class BaseInner {}
        }
    
        private abstract class SubOuter extends BaseOuter {
          private abstract class SubInner extends BaseInner {}
        }
      }
    
      // For Guava bug https://github.com/google/guava/issues/1025
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Oct 21 21:13:09 UTC 2024
    - 89.1K bytes
    - Viewed (0)
  7. guava-tests/test/com/google/common/reflect/TypeTokenTest.java

      }
    
      private abstract static class ToReproduceGenericSignatureFormatError<V> {
        private abstract class BaseOuter {
          abstract class BaseInner {}
        }
    
        private abstract class SubOuter extends BaseOuter {
          private abstract class SubInner extends BaseInner {}
        }
      }
    
      // For Guava bug https://github.com/google/guava/issues/1025
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Oct 21 21:13:09 UTC 2024
    - 89.1K bytes
    - Viewed (0)
Back to top