- Sort Score
- Result 10 results
- Languages All
Results 1 - 9 of 9 for remotePeer (0.16 sec)
-
cmd/notification.go
} } return reply } func (sys *NotificationSys) addNodeErr(nodeInfo madmin.NodeInfo, peerClient *peerRESTClient, err error) { addr := peerClient.host.String() reqInfo := (&logger.ReqInfo{}).AppendTags("remotePeer", addr) ctx := logger.SetReqInfo(GlobalContext, reqInfo) peersLogOnceIf(ctx, err, "add-node-err-"+addr) nodeInfo.SetAddr(addr) nodeInfo.SetError(err.Error()) } // GetSysErrors - Memory information
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 12 18:13:36 GMT 2024 - 44.5K bytes - Viewed (0) -
internal/grid/handlers.go
func NewRemoteErrString(msg string) *RemoteErr { r := RemoteErr(msg) return &r } func (r RemoteErr) Error() string { return string(r) } // Is returns if the string representation matches. func (r *RemoteErr) Is(other error) bool { if r == nil || other == nil { return r == other } var o RemoteErr if errors.As(other, &o) { return r == &o }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 17:15:52 GMT 2024 - 27.1K bytes - Viewed (0) -
internal/grid/grid_test.go
errFatal(local.RegisterSingleHandler(handlerTest, func(payload []byte) ([]byte, *RemoteErr) { t.Log("1: server payload: ", len(payload), "bytes.") return append([]byte{}, payload...), nil })) // 2: Return as error errFatal(local.RegisterSingleHandler(handlerTest2, func(payload []byte) ([]byte, *RemoteErr) { t.Log("2: server payload: ", len(payload), "bytes.") err := RemoteErr(payload) return nil, &err })) remote := grid.Managers[1]
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 30 15:03:35 GMT 2024 - 30.1K bytes - Viewed (0) -
cmd/storage-rest-server.go
if !s.checkID(p.DiskID) { return grid.NewNPErr(errDiskNotFound) } volume := p.Volume filePath := p.FilePath return grid.NewNPErr(s.getStorage().CheckParts(context.Background(), volume, filePath, p.FI)) } func (s *storageRESTServer) WriteAllHandler(p *WriteAllHandlerParams) (grid.NoPayload, *grid.RemoteErr) { if !s.checkID(p.DiskID) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 44.8K bytes - Viewed (0) -
internal/grid/benchmark_test.go
// Register a single handler which echos the payload. errFatal(remote.RegisterSingleHandler(handlerTest, func(payload []byte) ([]byte, *RemoteErr) { defer PutByteBuffer(payload) return append(GetByteBuffer()[:0], payload...), nil })) errFatal(rpc.Register(remote, func(req *testRequest) (resp *testResponse, err *RemoteErr) { return &testResponse{ OrgNum: req.Num, OrgString: req.String, Embedded: *req, }, nil }))
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Nov 21 01:09:35 GMT 2023 - 12.2K bytes - Viewed (0) -
internal/grid/connection.go
if v, ok := c.outgoing.Load(m.MuxID); ok { var cErr muxConnectError _, err := cErr.UnmarshalMsg(m.Payload) gridLogIf(ctx, err) v.error(RemoteErr(cErr.Error)) return } PutByteBuffer(m.Payload) } func (c *Connection) handleAckMux(ctx context.Context, m message) { PutByteBuffer(m.Payload) v, ok := c.outgoing.Load(m.MuxID)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 42.6K bytes - Viewed (0) -
cmd/endpoint_test.go
if err := zendpoints[0].Endpoints.UpdateIsLocal(); err != nil { t.Errorf("error: expected = <nil>, got = %v", err) } } remotePeers, local := zendpoints.peers() if !reflect.DeepEqual(remotePeers, testCase.expectedResult) { t.Errorf("expected: %v, got: %v", testCase.expectedResult, remotePeers) } if local != testCase.expectedLocal { t.Errorf("expected: %v, got: %v", testCase.expectedLocal, local) } }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Jan 13 07:53:03 GMT 2024 - 18.9K bytes - Viewed (1) -
cmd/metacache-walk.go
} // WalkDirHandler - remote caller to list files and folders in a requested directory path. func (s *storageRESTServer) WalkDirHandler(ctx context.Context, payload []byte, _ <-chan []byte, out chan<- []byte) (gerr *grid.RemoteErr) { var opts WalkDirOptions _, err := opts.UnmarshalMsg(payload) if err != nil { return grid.NewRemoteErr(err) } if !s.checkID(opts.DiskID) { return grid.NewRemoteErr(errDiskNotFound) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 15 08:25:46 GMT 2024 - 12.4K bytes - Viewed (0) -
internal/grid/muxclient.go
ok := m.addResponse(r) if !ok { PutByteBuffer(r.Msg) } } var errStreamEOF = errors.New("stream EOF") // error is a message from the server to disconnect. func (m *muxClient) error(err RemoteErr) { if debugPrint { fmt.Printf("mux %d: got remote err:%v\n", m.MuxID, string(err)) } m.addResponse(Response{Err: &err}) } func (m *muxClient) ack(seq uint32) { if !m.checkSeq(seq) { return
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 14.2K bytes - Viewed (0)