- Sort Score
- Result 10 results
- Languages All
Results 21 - 27 of 27 for Subrouter (0.31 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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)