1
2
3
4 package bpfki
5
6 import (
7 context "context"
8 fmt "fmt"
9 math "math"
10
11 proto "github.com/golang/protobuf/proto"
12 grpc "google.golang.org/grpc"
13 codes "google.golang.org/grpc/codes"
14 status "google.golang.org/grpc/status"
15 )
16
17
18 var _ = proto.Marshal
19 var _ = fmt.Errorf
20 var _ = math.Inf
21
22
23
24
25
26 const _ = proto.ProtoPackageIsVersion3
27
28 type FailKernRequest_FAILTYPE int32
29
30 const (
31 FailKernRequest_SLAB FailKernRequest_FAILTYPE = 0
32 FailKernRequest_PAGE FailKernRequest_FAILTYPE = 1
33 FailKernRequest_BIO FailKernRequest_FAILTYPE = 2
34 )
35
36 var FailKernRequest_FAILTYPE_name = map[int32]string{
37 0: "SLAB",
38 1: "PAGE",
39 2: "BIO",
40 }
41
42 var FailKernRequest_FAILTYPE_value = map[string]int32{
43 "SLAB": 0,
44 "PAGE": 1,
45 "BIO": 2,
46 }
47
48 func (x FailKernRequest_FAILTYPE) String() string {
49 return proto.EnumName(FailKernRequest_FAILTYPE_name, int32(x))
50 }
51
52 func (FailKernRequest_FAILTYPE) EnumDescriptor() ([]byte, []int) {
53 return fileDescriptor_62eed357eb71de0e, []int{1, 0}
54 }
55
56 type BumpTimeRequest struct {
57 Pid uint32 `protobuf:"varint,1,opt,name=pid,proto3" json:"pid,omitempty"`
58 Tid uint32 `protobuf:"varint,2,opt,name=tid,proto3" json:"tid,omitempty"`
59 Second int32 `protobuf:"varint,3,opt,name=second,proto3" json:"second,omitempty"`
60 Subsecond int32 `protobuf:"varint,4,opt,name=subsecond,proto3" json:"subsecond,omitempty"`
61 Probability float32 `protobuf:"fixed32,5,opt,name=probability,proto3" json:"probability,omitempty"`
62 XXX_NoUnkeyedLiteral struct{} `json:"-"`
63 XXX_unrecognized []byte `json:"-"`
64 XXX_sizecache int32 `json:"-"`
65 }
66
67 func (m *BumpTimeRequest) Reset() { *m = BumpTimeRequest{} }
68 func (m *BumpTimeRequest) String() string { return proto.CompactTextString(m) }
69 func (*BumpTimeRequest) ProtoMessage() {}
70 func (*BumpTimeRequest) Descriptor() ([]byte, []int) {
71 return fileDescriptor_62eed357eb71de0e, []int{0}
72 }
73
74 func (m *BumpTimeRequest) XXX_Unmarshal(b []byte) error {
75 return xxx_messageInfo_BumpTimeRequest.Unmarshal(m, b)
76 }
77 func (m *BumpTimeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
78 return xxx_messageInfo_BumpTimeRequest.Marshal(b, m, deterministic)
79 }
80 func (m *BumpTimeRequest) XXX_Merge(src proto.Message) {
81 xxx_messageInfo_BumpTimeRequest.Merge(m, src)
82 }
83 func (m *BumpTimeRequest) XXX_Size() int {
84 return xxx_messageInfo_BumpTimeRequest.Size(m)
85 }
86 func (m *BumpTimeRequest) XXX_DiscardUnknown() {
87 xxx_messageInfo_BumpTimeRequest.DiscardUnknown(m)
88 }
89
90 var xxx_messageInfo_BumpTimeRequest proto.InternalMessageInfo
91
92 func (m *BumpTimeRequest) GetPid() uint32 {
93 if m != nil {
94 return m.Pid
95 }
96 return 0
97 }
98
99 func (m *BumpTimeRequest) GetTid() uint32 {
100 if m != nil {
101 return m.Tid
102 }
103 return 0
104 }
105
106 func (m *BumpTimeRequest) GetSecond() int32 {
107 if m != nil {
108 return m.Second
109 }
110 return 0
111 }
112
113 func (m *BumpTimeRequest) GetSubsecond() int32 {
114 if m != nil {
115 return m.Subsecond
116 }
117 return 0
118 }
119
120 func (m *BumpTimeRequest) GetProbability() float32 {
121 if m != nil {
122 return m.Probability
123 }
124 return 0
125 }
126
127 type FailKernRequest struct {
128 Pid uint32 `protobuf:"varint,1,opt,name=pid,proto3" json:"pid,omitempty"`
129 Tid uint32 `protobuf:"varint,2,opt,name=tid,proto3" json:"tid,omitempty"`
130 Ftype FailKernRequest_FAILTYPE `protobuf:"varint,3,opt,name=ftype,proto3,enum=bpfki.FailKernRequest_FAILTYPE" json:"ftype,omitempty"`
131 Headers []string `protobuf:"bytes,4,rep,name=headers,proto3" json:"headers,omitempty"`
132 Callchain []*FailKernRequestFrame `protobuf:"bytes,5,rep,name=callchain,proto3" json:"callchain,omitempty"`
133 Probability float32 `protobuf:"fixed32,6,opt,name=probability,proto3" json:"probability,omitempty"`
134 Times uint32 `protobuf:"varint,7,opt,name=times,proto3" json:"times,omitempty"`
135 XXX_NoUnkeyedLiteral struct{} `json:"-"`
136 XXX_unrecognized []byte `json:"-"`
137 XXX_sizecache int32 `json:"-"`
138 }
139
140 func (m *FailKernRequest) Reset() { *m = FailKernRequest{} }
141 func (m *FailKernRequest) String() string { return proto.CompactTextString(m) }
142 func (*FailKernRequest) ProtoMessage() {}
143 func (*FailKernRequest) Descriptor() ([]byte, []int) {
144 return fileDescriptor_62eed357eb71de0e, []int{1}
145 }
146
147 func (m *FailKernRequest) XXX_Unmarshal(b []byte) error {
148 return xxx_messageInfo_FailKernRequest.Unmarshal(m, b)
149 }
150 func (m *FailKernRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
151 return xxx_messageInfo_FailKernRequest.Marshal(b, m, deterministic)
152 }
153 func (m *FailKernRequest) XXX_Merge(src proto.Message) {
154 xxx_messageInfo_FailKernRequest.Merge(m, src)
155 }
156 func (m *FailKernRequest) XXX_Size() int {
157 return xxx_messageInfo_FailKernRequest.Size(m)
158 }
159 func (m *FailKernRequest) XXX_DiscardUnknown() {
160 xxx_messageInfo_FailKernRequest.DiscardUnknown(m)
161 }
162
163 var xxx_messageInfo_FailKernRequest proto.InternalMessageInfo
164
165 func (m *FailKernRequest) GetPid() uint32 {
166 if m != nil {
167 return m.Pid
168 }
169 return 0
170 }
171
172 func (m *FailKernRequest) GetTid() uint32 {
173 if m != nil {
174 return m.Tid
175 }
176 return 0
177 }
178
179 func (m *FailKernRequest) GetFtype() FailKernRequest_FAILTYPE {
180 if m != nil {
181 return m.Ftype
182 }
183 return FailKernRequest_SLAB
184 }
185
186 func (m *FailKernRequest) GetHeaders() []string {
187 if m != nil {
188 return m.Headers
189 }
190 return nil
191 }
192
193 func (m *FailKernRequest) GetCallchain() []*FailKernRequestFrame {
194 if m != nil {
195 return m.Callchain
196 }
197 return nil
198 }
199
200 func (m *FailKernRequest) GetProbability() float32 {
201 if m != nil {
202 return m.Probability
203 }
204 return 0
205 }
206
207 func (m *FailKernRequest) GetTimes() uint32 {
208 if m != nil {
209 return m.Times
210 }
211 return 0
212 }
213
214 type FailKernRequestFrame struct {
215 Funcname string `protobuf:"bytes,1,opt,name=funcname,proto3" json:"funcname,omitempty"`
216 Parameters string `protobuf:"bytes,2,opt,name=parameters,proto3" json:"parameters,omitempty"`
217 Predicate string `protobuf:"bytes,3,opt,name=predicate,proto3" json:"predicate,omitempty"`
218 XXX_NoUnkeyedLiteral struct{} `json:"-"`
219 XXX_unrecognized []byte `json:"-"`
220 XXX_sizecache int32 `json:"-"`
221 }
222
223 func (m *FailKernRequestFrame) Reset() { *m = FailKernRequestFrame{} }
224 func (m *FailKernRequestFrame) String() string { return proto.CompactTextString(m) }
225 func (*FailKernRequestFrame) ProtoMessage() {}
226 func (*FailKernRequestFrame) Descriptor() ([]byte, []int) {
227 return fileDescriptor_62eed357eb71de0e, []int{1, 0}
228 }
229
230 func (m *FailKernRequestFrame) XXX_Unmarshal(b []byte) error {
231 return xxx_messageInfo_FailKernRequestFrame.Unmarshal(m, b)
232 }
233 func (m *FailKernRequestFrame) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
234 return xxx_messageInfo_FailKernRequestFrame.Marshal(b, m, deterministic)
235 }
236 func (m *FailKernRequestFrame) XXX_Merge(src proto.Message) {
237 xxx_messageInfo_FailKernRequestFrame.Merge(m, src)
238 }
239 func (m *FailKernRequestFrame) XXX_Size() int {
240 return xxx_messageInfo_FailKernRequestFrame.Size(m)
241 }
242 func (m *FailKernRequestFrame) XXX_DiscardUnknown() {
243 xxx_messageInfo_FailKernRequestFrame.DiscardUnknown(m)
244 }
245
246 var xxx_messageInfo_FailKernRequestFrame proto.InternalMessageInfo
247
248 func (m *FailKernRequestFrame) GetFuncname() string {
249 if m != nil {
250 return m.Funcname
251 }
252 return ""
253 }
254
255 func (m *FailKernRequestFrame) GetParameters() string {
256 if m != nil {
257 return m.Parameters
258 }
259 return ""
260 }
261
262 func (m *FailKernRequestFrame) GetPredicate() string {
263 if m != nil {
264 return m.Predicate
265 }
266 return ""
267 }
268
269 type FailSyscallRequest struct {
270 Pid uint32 `protobuf:"varint,1,opt,name=pid,proto3" json:"pid,omitempty"`
271 Tid uint32 `protobuf:"varint,2,opt,name=tid,proto3" json:"tid,omitempty"`
272 Methods []string `protobuf:"bytes,3,rep,name=methods,proto3" json:"methods,omitempty"`
273 Err uint32 `protobuf:"varint,4,opt,name=err,proto3" json:"err,omitempty"`
274 Probability float32 `protobuf:"fixed32,5,opt,name=probability,proto3" json:"probability,omitempty"`
275 XXX_NoUnkeyedLiteral struct{} `json:"-"`
276 XXX_unrecognized []byte `json:"-"`
277 XXX_sizecache int32 `json:"-"`
278 }
279
280 func (m *FailSyscallRequest) Reset() { *m = FailSyscallRequest{} }
281 func (m *FailSyscallRequest) String() string { return proto.CompactTextString(m) }
282 func (*FailSyscallRequest) ProtoMessage() {}
283 func (*FailSyscallRequest) Descriptor() ([]byte, []int) {
284 return fileDescriptor_62eed357eb71de0e, []int{2}
285 }
286
287 func (m *FailSyscallRequest) XXX_Unmarshal(b []byte) error {
288 return xxx_messageInfo_FailSyscallRequest.Unmarshal(m, b)
289 }
290 func (m *FailSyscallRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
291 return xxx_messageInfo_FailSyscallRequest.Marshal(b, m, deterministic)
292 }
293 func (m *FailSyscallRequest) XXX_Merge(src proto.Message) {
294 xxx_messageInfo_FailSyscallRequest.Merge(m, src)
295 }
296 func (m *FailSyscallRequest) XXX_Size() int {
297 return xxx_messageInfo_FailSyscallRequest.Size(m)
298 }
299 func (m *FailSyscallRequest) XXX_DiscardUnknown() {
300 xxx_messageInfo_FailSyscallRequest.DiscardUnknown(m)
301 }
302
303 var xxx_messageInfo_FailSyscallRequest proto.InternalMessageInfo
304
305 func (m *FailSyscallRequest) GetPid() uint32 {
306 if m != nil {
307 return m.Pid
308 }
309 return 0
310 }
311
312 func (m *FailSyscallRequest) GetTid() uint32 {
313 if m != nil {
314 return m.Tid
315 }
316 return 0
317 }
318
319 func (m *FailSyscallRequest) GetMethods() []string {
320 if m != nil {
321 return m.Methods
322 }
323 return nil
324 }
325
326 func (m *FailSyscallRequest) GetErr() uint32 {
327 if m != nil {
328 return m.Err
329 }
330 return 0
331 }
332
333 func (m *FailSyscallRequest) GetProbability() float32 {
334 if m != nil {
335 return m.Probability
336 }
337 return 0
338 }
339
340 type StatusResponse struct {
341 Ret int32 `protobuf:"varint,1,opt,name=ret,proto3" json:"ret,omitempty"`
342 Msg string `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
343 XXX_NoUnkeyedLiteral struct{} `json:"-"`
344 XXX_unrecognized []byte `json:"-"`
345 XXX_sizecache int32 `json:"-"`
346 }
347
348 func (m *StatusResponse) Reset() { *m = StatusResponse{} }
349 func (m *StatusResponse) String() string { return proto.CompactTextString(m) }
350 func (*StatusResponse) ProtoMessage() {}
351 func (*StatusResponse) Descriptor() ([]byte, []int) {
352 return fileDescriptor_62eed357eb71de0e, []int{3}
353 }
354
355 func (m *StatusResponse) XXX_Unmarshal(b []byte) error {
356 return xxx_messageInfo_StatusResponse.Unmarshal(m, b)
357 }
358 func (m *StatusResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
359 return xxx_messageInfo_StatusResponse.Marshal(b, m, deterministic)
360 }
361 func (m *StatusResponse) XXX_Merge(src proto.Message) {
362 xxx_messageInfo_StatusResponse.Merge(m, src)
363 }
364 func (m *StatusResponse) XXX_Size() int {
365 return xxx_messageInfo_StatusResponse.Size(m)
366 }
367 func (m *StatusResponse) XXX_DiscardUnknown() {
368 xxx_messageInfo_StatusResponse.DiscardUnknown(m)
369 }
370
371 var xxx_messageInfo_StatusResponse proto.InternalMessageInfo
372
373 func (m *StatusResponse) GetRet() int32 {
374 if m != nil {
375 return m.Ret
376 }
377 return 0
378 }
379
380 func (m *StatusResponse) GetMsg() string {
381 if m != nil {
382 return m.Msg
383 }
384 return ""
385 }
386
387 func init() {
388 proto.RegisterEnum("bpfki.FailKernRequest_FAILTYPE", FailKernRequest_FAILTYPE_name, FailKernRequest_FAILTYPE_value)
389 proto.RegisterType((*BumpTimeRequest)(nil), "bpfki.BumpTimeRequest")
390 proto.RegisterType((*FailKernRequest)(nil), "bpfki.FailKernRequest")
391 proto.RegisterType((*FailKernRequestFrame)(nil), "bpfki.FailKernRequest.frame")
392 proto.RegisterType((*FailSyscallRequest)(nil), "bpfki.FailSyscallRequest")
393 proto.RegisterType((*StatusResponse)(nil), "bpfki.StatusResponse")
394 }
395
396 func init() { proto.RegisterFile("bpfki.proto", fileDescriptor_62eed357eb71de0e) }
397
398 var fileDescriptor_62eed357eb71de0e = []byte{
399
400 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xa4, 0x54, 0x4d, 0x6f, 0xda, 0x40,
401 0x10, 0x8d, 0x31, 0xe6, 0x63, 0xdc, 0x00, 0x5a, 0xb5, 0x91, 0x8b, 0xa2, 0xd6, 0xe2, 0x52, 0x4e,
402 0x1c, 0x68, 0x7b, 0xa9, 0xd4, 0x48, 0x58, 0x0d, 0x15, 0x4a, 0x22, 0xd0, 0x3a, 0xaa, 0xd4, 0xe3,
403 0x62, 0x0f, 0x65, 0x55, 0xfc, 0xd1, 0xdd, 0x25, 0x12, 0x7f, 0x20, 0xb7, 0xfe, 0x87, 0xfe, 0xd4,
404 0x6a, 0x6d, 0x07, 0x1c, 0xa2, 0x48, 0x21, 0xb9, 0xcd, 0xbc, 0xdd, 0x7d, 0x7e, 0x6f, 0xe6, 0xc9,
405 0x60, 0xcf, 0xd3, 0xc5, 0x6f, 0x3e, 0x48, 0x45, 0xa2, 0x12, 0x62, 0x65, 0x4d, 0xef, 0xaf, 0x01,
406 0x6d, 0x6f, 0x1d, 0xa5, 0xd7, 0x3c, 0x42, 0x8a, 0x7f, 0xd6, 0x28, 0x15, 0xe9, 0x80, 0x99, 0xf2,
407 0xd0, 0x31, 0x5c, 0xa3, 0x7f, 0x4c, 0x75, 0xa9, 0x11, 0xc5, 0x43, 0xa7, 0x92, 0x23, 0x8a, 0x87,
408 0xe4, 0x04, 0x6a, 0x12, 0x83, 0x24, 0x0e, 0x1d, 0xd3, 0x35, 0xfa, 0x16, 0x2d, 0x3a, 0x72, 0x0a,
409 0x4d, 0xb9, 0x9e, 0x17, 0x47, 0xd5, 0xec, 0x68, 0x07, 0x10, 0x17, 0xec, 0x54, 0x24, 0x73, 0x36,
410 0xe7, 0x2b, 0xae, 0x36, 0x8e, 0xe5, 0x1a, 0xfd, 0x0a, 0x2d, 0x43, 0xbd, 0x5b, 0x13, 0xda, 0x63,
411 0xc6, 0x57, 0x17, 0x28, 0xe2, 0x43, 0xf4, 0x7c, 0x06, 0x6b, 0xa1, 0x36, 0x29, 0x66, 0x72, 0x5a,
412 0xc3, 0xf7, 0x83, 0xdc, 0xeb, 0x1e, 0xd5, 0x60, 0x3c, 0x9a, 0x5c, 0x5e, 0xff, 0x9c, 0x9d, 0xd3,
413 0xfc, 0x36, 0x71, 0xa0, 0xbe, 0x44, 0x16, 0xa2, 0x90, 0x4e, 0xd5, 0x35, 0xfb, 0x4d, 0x7a, 0xd7,
414 0x92, 0x2f, 0xd0, 0x0c, 0xd8, 0x6a, 0x15, 0x2c, 0x19, 0x8f, 0x1d, 0xcb, 0x35, 0xfb, 0xf6, 0xf0,
415 0xf4, 0x11, 0xd2, 0x85, 0x60, 0x11, 0xd2, 0xdd, 0xf5, 0x7d, 0x9b, 0xb5, 0x07, 0x36, 0xc9, 0x6b,
416 0xb0, 0x14, 0x8f, 0x50, 0x3a, 0xf5, 0xcc, 0x42, 0xde, 0x74, 0x19, 0x58, 0x19, 0x17, 0xe9, 0x42,
417 0x63, 0xb1, 0x8e, 0x83, 0x98, 0x45, 0x98, 0xd9, 0x6e, 0xd2, 0x6d, 0x4f, 0xde, 0x01, 0xa4, 0x4c,
418 0xdf, 0x52, 0x5a, 0x75, 0x25, 0x3b, 0x2d, 0x21, 0x7a, 0x03, 0xa9, 0xc0, 0x90, 0x07, 0x4c, 0xe5,
419 0xd3, 0x68, 0xd2, 0x1d, 0xd0, 0xfb, 0x00, 0x8d, 0xbb, 0x19, 0x90, 0x06, 0x54, 0xfd, 0xcb, 0x91,
420 0xd7, 0x39, 0xd2, 0xd5, 0x6c, 0xf4, 0xfd, 0xbc, 0x63, 0x90, 0x3a, 0x98, 0xde, 0x64, 0xda, 0xa9,
421 0xf4, 0x6e, 0x0d, 0x20, 0xda, 0xa8, 0xbf, 0x91, 0xda, 0xd8, 0x21, 0xbb, 0x70, 0xa0, 0x1e, 0xa1,
422 0x5a, 0x26, 0xa1, 0x74, 0xcc, 0x7c, 0xa8, 0x45, 0xab, 0xef, 0xa2, 0x10, 0x59, 0x2e, 0x8e, 0xa9,
423 0x2e, 0x9f, 0x90, 0x88, 0x4f, 0xd0, 0xf2, 0x15, 0x53, 0x6b, 0x49, 0x51, 0xa6, 0x49, 0x2c, 0x51,
424 0xb3, 0x08, 0x54, 0x99, 0x06, 0x8b, 0xea, 0x52, 0x23, 0x91, 0xfc, 0x55, 0x0c, 0x43, 0x97, 0xc3,
425 0x7f, 0x55, 0x78, 0xe5, 0xcd, 0xc6, 0x17, 0x13, 0x1f, 0xc5, 0x0d, 0x0f, 0x90, 0x7c, 0x05, 0xf0,
426 0x51, 0xe9, 0x98, 0xff, 0x60, 0x2b, 0x72, 0x52, 0xac, 0x72, 0x2f, 0xfa, 0xdd, 0x37, 0x05, 0x7e,
427 0xff, 0x8b, 0xbd, 0x23, 0x32, 0x82, 0x16, 0xc5, 0x20, 0xb9, 0x41, 0xf1, 0x6c, 0x8a, 0x33, 0xb0,
428 0x0b, 0x05, 0x7e, 0x8a, 0xc1, 0xe1, 0xef, 0x3d, 0x68, 0x97, 0x24, 0x3c, 0x8f, 0xe3, 0x0c, 0x6c,
429 0xbd, 0xd4, 0xab, 0xab, 0xa9, 0xf0, 0x26, 0xd3, 0xed, 0xfb, 0xbd, 0x44, 0x3f, 0x65, 0x0c, 0x2f,
430 0xa0, 0xb0, 0x4b, 0xb9, 0x22, 0x6f, 0x4b, 0xef, 0xef, 0x67, 0xed, 0x71, 0x8a, 0x6f, 0x5b, 0x15,
431 0x2f, 0x60, 0x99, 0xd7, 0xb2, 0x1f, 0xe1, 0xc7, 0xff, 0x01, 0x00, 0x00, 0xff, 0xff, 0x91, 0xa8,
432 0xf4, 0xbf, 0x17, 0x05, 0x00, 0x00,
433 }
434
435
436 var _ context.Context
437 var _ grpc.ClientConn
438
439
440
441 const _ = grpc.SupportPackageIsVersion4
442
443
444
445
446 type BPFKIServiceClient interface {
447 SetTimeVal(ctx context.Context, in *BumpTimeRequest, opts ...grpc.CallOption) (*StatusResponse, error)
448 RecoverTimeVal(ctx context.Context, in *BumpTimeRequest, opts ...grpc.CallOption) (*StatusResponse, error)
449 SetTimeSpec(ctx context.Context, in *BumpTimeRequest, opts ...grpc.CallOption) (*StatusResponse, error)
450 RecoverTimeSpec(ctx context.Context, in *BumpTimeRequest, opts ...grpc.CallOption) (*StatusResponse, error)
451 FailMMOrBIO(ctx context.Context, in *FailKernRequest, opts ...grpc.CallOption) (*StatusResponse, error)
452 RecoverMMOrBIO(ctx context.Context, in *FailKernRequest, opts ...grpc.CallOption) (*StatusResponse, error)
453 FailSyscall(ctx context.Context, in *FailSyscallRequest, opts ...grpc.CallOption) (*StatusResponse, error)
454 RecoverSyscall(ctx context.Context, in *FailSyscallRequest, opts ...grpc.CallOption) (*StatusResponse, error)
455 }
456
457 type bPFKIServiceClient struct {
458 cc *grpc.ClientConn
459 }
460
461 func NewBPFKIServiceClient(cc *grpc.ClientConn) BPFKIServiceClient {
462 return &bPFKIServiceClient{cc}
463 }
464
465 func (c *bPFKIServiceClient) SetTimeVal(ctx context.Context, in *BumpTimeRequest, opts ...grpc.CallOption) (*StatusResponse, error) {
466 out := new(StatusResponse)
467 err := c.cc.Invoke(ctx, "/bpfki.BPFKIService/SetTimeVal", in, out, opts...)
468 if err != nil {
469 return nil, err
470 }
471 return out, nil
472 }
473
474 func (c *bPFKIServiceClient) RecoverTimeVal(ctx context.Context, in *BumpTimeRequest, opts ...grpc.CallOption) (*StatusResponse, error) {
475 out := new(StatusResponse)
476 err := c.cc.Invoke(ctx, "/bpfki.BPFKIService/RecoverTimeVal", in, out, opts...)
477 if err != nil {
478 return nil, err
479 }
480 return out, nil
481 }
482
483 func (c *bPFKIServiceClient) SetTimeSpec(ctx context.Context, in *BumpTimeRequest, opts ...grpc.CallOption) (*StatusResponse, error) {
484 out := new(StatusResponse)
485 err := c.cc.Invoke(ctx, "/bpfki.BPFKIService/SetTimeSpec", in, out, opts...)
486 if err != nil {
487 return nil, err
488 }
489 return out, nil
490 }
491
492 func (c *bPFKIServiceClient) RecoverTimeSpec(ctx context.Context, in *BumpTimeRequest, opts ...grpc.CallOption) (*StatusResponse, error) {
493 out := new(StatusResponse)
494 err := c.cc.Invoke(ctx, "/bpfki.BPFKIService/RecoverTimeSpec", in, out, opts...)
495 if err != nil {
496 return nil, err
497 }
498 return out, nil
499 }
500
501 func (c *bPFKIServiceClient) FailMMOrBIO(ctx context.Context, in *FailKernRequest, opts ...grpc.CallOption) (*StatusResponse, error) {
502 out := new(StatusResponse)
503 err := c.cc.Invoke(ctx, "/bpfki.BPFKIService/FailMMOrBIO", in, out, opts...)
504 if err != nil {
505 return nil, err
506 }
507 return out, nil
508 }
509
510 func (c *bPFKIServiceClient) RecoverMMOrBIO(ctx context.Context, in *FailKernRequest, opts ...grpc.CallOption) (*StatusResponse, error) {
511 out := new(StatusResponse)
512 err := c.cc.Invoke(ctx, "/bpfki.BPFKIService/RecoverMMOrBIO", in, out, opts...)
513 if err != nil {
514 return nil, err
515 }
516 return out, nil
517 }
518
519 func (c *bPFKIServiceClient) FailSyscall(ctx context.Context, in *FailSyscallRequest, opts ...grpc.CallOption) (*StatusResponse, error) {
520 out := new(StatusResponse)
521 err := c.cc.Invoke(ctx, "/bpfki.BPFKIService/FailSyscall", in, out, opts...)
522 if err != nil {
523 return nil, err
524 }
525 return out, nil
526 }
527
528 func (c *bPFKIServiceClient) RecoverSyscall(ctx context.Context, in *FailSyscallRequest, opts ...grpc.CallOption) (*StatusResponse, error) {
529 out := new(StatusResponse)
530 err := c.cc.Invoke(ctx, "/bpfki.BPFKIService/RecoverSyscall", in, out, opts...)
531 if err != nil {
532 return nil, err
533 }
534 return out, nil
535 }
536
537
538 type BPFKIServiceServer interface {
539 SetTimeVal(context.Context, *BumpTimeRequest) (*StatusResponse, error)
540 RecoverTimeVal(context.Context, *BumpTimeRequest) (*StatusResponse, error)
541 SetTimeSpec(context.Context, *BumpTimeRequest) (*StatusResponse, error)
542 RecoverTimeSpec(context.Context, *BumpTimeRequest) (*StatusResponse, error)
543 FailMMOrBIO(context.Context, *FailKernRequest) (*StatusResponse, error)
544 RecoverMMOrBIO(context.Context, *FailKernRequest) (*StatusResponse, error)
545 FailSyscall(context.Context, *FailSyscallRequest) (*StatusResponse, error)
546 RecoverSyscall(context.Context, *FailSyscallRequest) (*StatusResponse, error)
547 }
548
549
550 type UnimplementedBPFKIServiceServer struct {
551 }
552
553 func (*UnimplementedBPFKIServiceServer) SetTimeVal(ctx context.Context, req *BumpTimeRequest) (*StatusResponse, error) {
554 return nil, status.Errorf(codes.Unimplemented, "method SetTimeVal not implemented")
555 }
556 func (*UnimplementedBPFKIServiceServer) RecoverTimeVal(ctx context.Context, req *BumpTimeRequest) (*StatusResponse, error) {
557 return nil, status.Errorf(codes.Unimplemented, "method RecoverTimeVal not implemented")
558 }
559 func (*UnimplementedBPFKIServiceServer) SetTimeSpec(ctx context.Context, req *BumpTimeRequest) (*StatusResponse, error) {
560 return nil, status.Errorf(codes.Unimplemented, "method SetTimeSpec not implemented")
561 }
562 func (*UnimplementedBPFKIServiceServer) RecoverTimeSpec(ctx context.Context, req *BumpTimeRequest) (*StatusResponse, error) {
563 return nil, status.Errorf(codes.Unimplemented, "method RecoverTimeSpec not implemented")
564 }
565 func (*UnimplementedBPFKIServiceServer) FailMMOrBIO(ctx context.Context, req *FailKernRequest) (*StatusResponse, error) {
566 return nil, status.Errorf(codes.Unimplemented, "method FailMMOrBIO not implemented")
567 }
568 func (*UnimplementedBPFKIServiceServer) RecoverMMOrBIO(ctx context.Context, req *FailKernRequest) (*StatusResponse, error) {
569 return nil, status.Errorf(codes.Unimplemented, "method RecoverMMOrBIO not implemented")
570 }
571 func (*UnimplementedBPFKIServiceServer) FailSyscall(ctx context.Context, req *FailSyscallRequest) (*StatusResponse, error) {
572 return nil, status.Errorf(codes.Unimplemented, "method FailSyscall not implemented")
573 }
574 func (*UnimplementedBPFKIServiceServer) RecoverSyscall(ctx context.Context, req *FailSyscallRequest) (*StatusResponse, error) {
575 return nil, status.Errorf(codes.Unimplemented, "method RecoverSyscall not implemented")
576 }
577
578 func RegisterBPFKIServiceServer(s *grpc.Server, srv BPFKIServiceServer) {
579 s.RegisterService(&_BPFKIService_serviceDesc, srv)
580 }
581
582 func _BPFKIService_SetTimeVal_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
583 in := new(BumpTimeRequest)
584 if err := dec(in); err != nil {
585 return nil, err
586 }
587 if interceptor == nil {
588 return srv.(BPFKIServiceServer).SetTimeVal(ctx, in)
589 }
590 info := &grpc.UnaryServerInfo{
591 Server: srv,
592 FullMethod: "/bpfki.BPFKIService/SetTimeVal",
593 }
594 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
595 return srv.(BPFKIServiceServer).SetTimeVal(ctx, req.(*BumpTimeRequest))
596 }
597 return interceptor(ctx, in, info, handler)
598 }
599
600 func _BPFKIService_RecoverTimeVal_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
601 in := new(BumpTimeRequest)
602 if err := dec(in); err != nil {
603 return nil, err
604 }
605 if interceptor == nil {
606 return srv.(BPFKIServiceServer).RecoverTimeVal(ctx, in)
607 }
608 info := &grpc.UnaryServerInfo{
609 Server: srv,
610 FullMethod: "/bpfki.BPFKIService/RecoverTimeVal",
611 }
612 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
613 return srv.(BPFKIServiceServer).RecoverTimeVal(ctx, req.(*BumpTimeRequest))
614 }
615 return interceptor(ctx, in, info, handler)
616 }
617
618 func _BPFKIService_SetTimeSpec_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
619 in := new(BumpTimeRequest)
620 if err := dec(in); err != nil {
621 return nil, err
622 }
623 if interceptor == nil {
624 return srv.(BPFKIServiceServer).SetTimeSpec(ctx, in)
625 }
626 info := &grpc.UnaryServerInfo{
627 Server: srv,
628 FullMethod: "/bpfki.BPFKIService/SetTimeSpec",
629 }
630 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
631 return srv.(BPFKIServiceServer).SetTimeSpec(ctx, req.(*BumpTimeRequest))
632 }
633 return interceptor(ctx, in, info, handler)
634 }
635
636 func _BPFKIService_RecoverTimeSpec_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
637 in := new(BumpTimeRequest)
638 if err := dec(in); err != nil {
639 return nil, err
640 }
641 if interceptor == nil {
642 return srv.(BPFKIServiceServer).RecoverTimeSpec(ctx, in)
643 }
644 info := &grpc.UnaryServerInfo{
645 Server: srv,
646 FullMethod: "/bpfki.BPFKIService/RecoverTimeSpec",
647 }
648 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
649 return srv.(BPFKIServiceServer).RecoverTimeSpec(ctx, req.(*BumpTimeRequest))
650 }
651 return interceptor(ctx, in, info, handler)
652 }
653
654 func _BPFKIService_FailMMOrBIO_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
655 in := new(FailKernRequest)
656 if err := dec(in); err != nil {
657 return nil, err
658 }
659 if interceptor == nil {
660 return srv.(BPFKIServiceServer).FailMMOrBIO(ctx, in)
661 }
662 info := &grpc.UnaryServerInfo{
663 Server: srv,
664 FullMethod: "/bpfki.BPFKIService/FailMMOrBIO",
665 }
666 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
667 return srv.(BPFKIServiceServer).FailMMOrBIO(ctx, req.(*FailKernRequest))
668 }
669 return interceptor(ctx, in, info, handler)
670 }
671
672 func _BPFKIService_RecoverMMOrBIO_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
673 in := new(FailKernRequest)
674 if err := dec(in); err != nil {
675 return nil, err
676 }
677 if interceptor == nil {
678 return srv.(BPFKIServiceServer).RecoverMMOrBIO(ctx, in)
679 }
680 info := &grpc.UnaryServerInfo{
681 Server: srv,
682 FullMethod: "/bpfki.BPFKIService/RecoverMMOrBIO",
683 }
684 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
685 return srv.(BPFKIServiceServer).RecoverMMOrBIO(ctx, req.(*FailKernRequest))
686 }
687 return interceptor(ctx, in, info, handler)
688 }
689
690 func _BPFKIService_FailSyscall_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
691 in := new(FailSyscallRequest)
692 if err := dec(in); err != nil {
693 return nil, err
694 }
695 if interceptor == nil {
696 return srv.(BPFKIServiceServer).FailSyscall(ctx, in)
697 }
698 info := &grpc.UnaryServerInfo{
699 Server: srv,
700 FullMethod: "/bpfki.BPFKIService/FailSyscall",
701 }
702 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
703 return srv.(BPFKIServiceServer).FailSyscall(ctx, req.(*FailSyscallRequest))
704 }
705 return interceptor(ctx, in, info, handler)
706 }
707
708 func _BPFKIService_RecoverSyscall_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
709 in := new(FailSyscallRequest)
710 if err := dec(in); err != nil {
711 return nil, err
712 }
713 if interceptor == nil {
714 return srv.(BPFKIServiceServer).RecoverSyscall(ctx, in)
715 }
716 info := &grpc.UnaryServerInfo{
717 Server: srv,
718 FullMethod: "/bpfki.BPFKIService/RecoverSyscall",
719 }
720 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
721 return srv.(BPFKIServiceServer).RecoverSyscall(ctx, req.(*FailSyscallRequest))
722 }
723 return interceptor(ctx, in, info, handler)
724 }
725
726 var _BPFKIService_serviceDesc = grpc.ServiceDesc{
727 ServiceName: "bpfki.BPFKIService",
728 HandlerType: (*BPFKIServiceServer)(nil),
729 Methods: []grpc.MethodDesc{
730 {
731 MethodName: "SetTimeVal",
732 Handler: _BPFKIService_SetTimeVal_Handler,
733 },
734 {
735 MethodName: "RecoverTimeVal",
736 Handler: _BPFKIService_RecoverTimeVal_Handler,
737 },
738 {
739 MethodName: "SetTimeSpec",
740 Handler: _BPFKIService_SetTimeSpec_Handler,
741 },
742 {
743 MethodName: "RecoverTimeSpec",
744 Handler: _BPFKIService_RecoverTimeSpec_Handler,
745 },
746 {
747 MethodName: "FailMMOrBIO",
748 Handler: _BPFKIService_FailMMOrBIO_Handler,
749 },
750 {
751 MethodName: "RecoverMMOrBIO",
752 Handler: _BPFKIService_RecoverMMOrBIO_Handler,
753 },
754 {
755 MethodName: "FailSyscall",
756 Handler: _BPFKIService_FailSyscall_Handler,
757 },
758 {
759 MethodName: "RecoverSyscall",
760 Handler: _BPFKIService_RecoverSyscall_Handler,
761 },
762 },
763 Streams: []grpc.StreamDesc{},
764 Metadata: "bpfki.proto",
765 }
766