1
2
3
4
5
6
7 package bpfki
8
9 import (
10 context "context"
11 reflect "reflect"
12 sync "sync"
13
14 proto "github.com/golang/protobuf/proto"
15 grpc "google.golang.org/grpc"
16 codes "google.golang.org/grpc/codes"
17 status "google.golang.org/grpc/status"
18 protoreflect "google.golang.org/protobuf/reflect/protoreflect"
19 protoimpl "google.golang.org/protobuf/runtime/protoimpl"
20 )
21
22 const (
23
24 _ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion)
25
26 _ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20)
27 )
28
29
30
31 const _ = proto.ProtoPackageIsVersion4
32
33 type FailKernRequest_FAILTYPE int32
34
35 const (
36 FailKernRequest_SLAB FailKernRequest_FAILTYPE = 0
37 FailKernRequest_PAGE FailKernRequest_FAILTYPE = 1
38 FailKernRequest_BIO FailKernRequest_FAILTYPE = 2
39 )
40
41
42 var (
43 FailKernRequest_FAILTYPE_name = map[int32]string{
44 0: "SLAB",
45 1: "PAGE",
46 2: "BIO",
47 }
48 FailKernRequest_FAILTYPE_value = map[string]int32{
49 "SLAB": 0,
50 "PAGE": 1,
51 "BIO": 2,
52 }
53 )
54
55 func (x FailKernRequest_FAILTYPE) Enum() *FailKernRequest_FAILTYPE {
56 p := new(FailKernRequest_FAILTYPE)
57 *p = x
58 return p
59 }
60
61 func (x FailKernRequest_FAILTYPE) String() string {
62 return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
63 }
64
65 func (FailKernRequest_FAILTYPE) Descriptor() protoreflect.EnumDescriptor {
66 return file_bpfki_proto_enumTypes[0].Descriptor()
67 }
68
69 func (FailKernRequest_FAILTYPE) Type() protoreflect.EnumType {
70 return &file_bpfki_proto_enumTypes[0]
71 }
72
73 func (x FailKernRequest_FAILTYPE) Number() protoreflect.EnumNumber {
74 return protoreflect.EnumNumber(x)
75 }
76
77
78 func (FailKernRequest_FAILTYPE) EnumDescriptor() ([]byte, []int) {
79 return file_bpfki_proto_rawDescGZIP(), []int{1, 0}
80 }
81
82 type BumpTimeRequest struct {
83 state protoimpl.MessageState
84 sizeCache protoimpl.SizeCache
85 unknownFields protoimpl.UnknownFields
86
87 Pid uint32 `protobuf:"varint,1,opt,name=pid,proto3" json:"pid,omitempty"`
88 Tid uint32 `protobuf:"varint,2,opt,name=tid,proto3" json:"tid,omitempty"`
89 Second int32 `protobuf:"varint,3,opt,name=second,proto3" json:"second,omitempty"`
90 Subsecond int32 `protobuf:"varint,4,opt,name=subsecond,proto3" json:"subsecond,omitempty"`
91 Probability float32 `protobuf:"fixed32,5,opt,name=probability,proto3" json:"probability,omitempty"`
92 }
93
94 func (x *BumpTimeRequest) Reset() {
95 *x = BumpTimeRequest{}
96 if protoimpl.UnsafeEnabled {
97 mi := &file_bpfki_proto_msgTypes[0]
98 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
99 ms.StoreMessageInfo(mi)
100 }
101 }
102
103 func (x *BumpTimeRequest) String() string {
104 return protoimpl.X.MessageStringOf(x)
105 }
106
107 func (*BumpTimeRequest) ProtoMessage() {}
108
109 func (x *BumpTimeRequest) ProtoReflect() protoreflect.Message {
110 mi := &file_bpfki_proto_msgTypes[0]
111 if protoimpl.UnsafeEnabled && x != nil {
112 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
113 if ms.LoadMessageInfo() == nil {
114 ms.StoreMessageInfo(mi)
115 }
116 return ms
117 }
118 return mi.MessageOf(x)
119 }
120
121
122 func (*BumpTimeRequest) Descriptor() ([]byte, []int) {
123 return file_bpfki_proto_rawDescGZIP(), []int{0}
124 }
125
126 func (x *BumpTimeRequest) GetPid() uint32 {
127 if x != nil {
128 return x.Pid
129 }
130 return 0
131 }
132
133 func (x *BumpTimeRequest) GetTid() uint32 {
134 if x != nil {
135 return x.Tid
136 }
137 return 0
138 }
139
140 func (x *BumpTimeRequest) GetSecond() int32 {
141 if x != nil {
142 return x.Second
143 }
144 return 0
145 }
146
147 func (x *BumpTimeRequest) GetSubsecond() int32 {
148 if x != nil {
149 return x.Subsecond
150 }
151 return 0
152 }
153
154 func (x *BumpTimeRequest) GetProbability() float32 {
155 if x != nil {
156 return x.Probability
157 }
158 return 0
159 }
160
161 type FailKernRequest struct {
162 state protoimpl.MessageState
163 sizeCache protoimpl.SizeCache
164 unknownFields protoimpl.UnknownFields
165
166 Pid uint32 `protobuf:"varint,1,opt,name=pid,proto3" json:"pid,omitempty"`
167 Tid uint32 `protobuf:"varint,2,opt,name=tid,proto3" json:"tid,omitempty"`
168 Ftype FailKernRequest_FAILTYPE `protobuf:"varint,3,opt,name=ftype,proto3,enum=bpfki.FailKernRequest_FAILTYPE" json:"ftype,omitempty"`
169 Headers []string `protobuf:"bytes,4,rep,name=headers,proto3" json:"headers,omitempty"`
170 Callchain []*FailKernRequestFrame `protobuf:"bytes,5,rep,name=callchain,proto3" json:"callchain,omitempty"`
171 Probability float32 `protobuf:"fixed32,6,opt,name=probability,proto3" json:"probability,omitempty"`
172 Times uint32 `protobuf:"varint,7,opt,name=times,proto3" json:"times,omitempty"`
173 }
174
175 func (x *FailKernRequest) Reset() {
176 *x = FailKernRequest{}
177 if protoimpl.UnsafeEnabled {
178 mi := &file_bpfki_proto_msgTypes[1]
179 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
180 ms.StoreMessageInfo(mi)
181 }
182 }
183
184 func (x *FailKernRequest) String() string {
185 return protoimpl.X.MessageStringOf(x)
186 }
187
188 func (*FailKernRequest) ProtoMessage() {}
189
190 func (x *FailKernRequest) ProtoReflect() protoreflect.Message {
191 mi := &file_bpfki_proto_msgTypes[1]
192 if protoimpl.UnsafeEnabled && x != nil {
193 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
194 if ms.LoadMessageInfo() == nil {
195 ms.StoreMessageInfo(mi)
196 }
197 return ms
198 }
199 return mi.MessageOf(x)
200 }
201
202
203 func (*FailKernRequest) Descriptor() ([]byte, []int) {
204 return file_bpfki_proto_rawDescGZIP(), []int{1}
205 }
206
207 func (x *FailKernRequest) GetPid() uint32 {
208 if x != nil {
209 return x.Pid
210 }
211 return 0
212 }
213
214 func (x *FailKernRequest) GetTid() uint32 {
215 if x != nil {
216 return x.Tid
217 }
218 return 0
219 }
220
221 func (x *FailKernRequest) GetFtype() FailKernRequest_FAILTYPE {
222 if x != nil {
223 return x.Ftype
224 }
225 return FailKernRequest_SLAB
226 }
227
228 func (x *FailKernRequest) GetHeaders() []string {
229 if x != nil {
230 return x.Headers
231 }
232 return nil
233 }
234
235 func (x *FailKernRequest) GetCallchain() []*FailKernRequestFrame {
236 if x != nil {
237 return x.Callchain
238 }
239 return nil
240 }
241
242 func (x *FailKernRequest) GetProbability() float32 {
243 if x != nil {
244 return x.Probability
245 }
246 return 0
247 }
248
249 func (x *FailKernRequest) GetTimes() uint32 {
250 if x != nil {
251 return x.Times
252 }
253 return 0
254 }
255
256 type FailSyscallRequest struct {
257 state protoimpl.MessageState
258 sizeCache protoimpl.SizeCache
259 unknownFields protoimpl.UnknownFields
260
261 Pid uint32 `protobuf:"varint,1,opt,name=pid,proto3" json:"pid,omitempty"`
262 Tid uint32 `protobuf:"varint,2,opt,name=tid,proto3" json:"tid,omitempty"`
263 Methods []string `protobuf:"bytes,3,rep,name=methods,proto3" json:"methods,omitempty"`
264 Err uint32 `protobuf:"varint,4,opt,name=err,proto3" json:"err,omitempty"`
265 Probability float32 `protobuf:"fixed32,5,opt,name=probability,proto3" json:"probability,omitempty"`
266 }
267
268 func (x *FailSyscallRequest) Reset() {
269 *x = FailSyscallRequest{}
270 if protoimpl.UnsafeEnabled {
271 mi := &file_bpfki_proto_msgTypes[2]
272 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
273 ms.StoreMessageInfo(mi)
274 }
275 }
276
277 func (x *FailSyscallRequest) String() string {
278 return protoimpl.X.MessageStringOf(x)
279 }
280
281 func (*FailSyscallRequest) ProtoMessage() {}
282
283 func (x *FailSyscallRequest) ProtoReflect() protoreflect.Message {
284 mi := &file_bpfki_proto_msgTypes[2]
285 if protoimpl.UnsafeEnabled && x != nil {
286 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
287 if ms.LoadMessageInfo() == nil {
288 ms.StoreMessageInfo(mi)
289 }
290 return ms
291 }
292 return mi.MessageOf(x)
293 }
294
295
296 func (*FailSyscallRequest) Descriptor() ([]byte, []int) {
297 return file_bpfki_proto_rawDescGZIP(), []int{2}
298 }
299
300 func (x *FailSyscallRequest) GetPid() uint32 {
301 if x != nil {
302 return x.Pid
303 }
304 return 0
305 }
306
307 func (x *FailSyscallRequest) GetTid() uint32 {
308 if x != nil {
309 return x.Tid
310 }
311 return 0
312 }
313
314 func (x *FailSyscallRequest) GetMethods() []string {
315 if x != nil {
316 return x.Methods
317 }
318 return nil
319 }
320
321 func (x *FailSyscallRequest) GetErr() uint32 {
322 if x != nil {
323 return x.Err
324 }
325 return 0
326 }
327
328 func (x *FailSyscallRequest) GetProbability() float32 {
329 if x != nil {
330 return x.Probability
331 }
332 return 0
333 }
334
335 type StatusResponse struct {
336 state protoimpl.MessageState
337 sizeCache protoimpl.SizeCache
338 unknownFields protoimpl.UnknownFields
339
340 Ret int32 `protobuf:"varint,1,opt,name=ret,proto3" json:"ret,omitempty"`
341 Msg string `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
342 }
343
344 func (x *StatusResponse) Reset() {
345 *x = StatusResponse{}
346 if protoimpl.UnsafeEnabled {
347 mi := &file_bpfki_proto_msgTypes[3]
348 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
349 ms.StoreMessageInfo(mi)
350 }
351 }
352
353 func (x *StatusResponse) String() string {
354 return protoimpl.X.MessageStringOf(x)
355 }
356
357 func (*StatusResponse) ProtoMessage() {}
358
359 func (x *StatusResponse) ProtoReflect() protoreflect.Message {
360 mi := &file_bpfki_proto_msgTypes[3]
361 if protoimpl.UnsafeEnabled && x != nil {
362 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
363 if ms.LoadMessageInfo() == nil {
364 ms.StoreMessageInfo(mi)
365 }
366 return ms
367 }
368 return mi.MessageOf(x)
369 }
370
371
372 func (*StatusResponse) Descriptor() ([]byte, []int) {
373 return file_bpfki_proto_rawDescGZIP(), []int{3}
374 }
375
376 func (x *StatusResponse) GetRet() int32 {
377 if x != nil {
378 return x.Ret
379 }
380 return 0
381 }
382
383 func (x *StatusResponse) GetMsg() string {
384 if x != nil {
385 return x.Msg
386 }
387 return ""
388 }
389
390 type FailKernRequestFrame struct {
391 state protoimpl.MessageState
392 sizeCache protoimpl.SizeCache
393 unknownFields protoimpl.UnknownFields
394
395 Funcname string `protobuf:"bytes,1,opt,name=funcname,proto3" json:"funcname,omitempty"`
396 Parameters string `protobuf:"bytes,2,opt,name=parameters,proto3" json:"parameters,omitempty"`
397 Predicate string `protobuf:"bytes,3,opt,name=predicate,proto3" json:"predicate,omitempty"`
398 }
399
400 func (x *FailKernRequestFrame) Reset() {
401 *x = FailKernRequestFrame{}
402 if protoimpl.UnsafeEnabled {
403 mi := &file_bpfki_proto_msgTypes[4]
404 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
405 ms.StoreMessageInfo(mi)
406 }
407 }
408
409 func (x *FailKernRequestFrame) String() string {
410 return protoimpl.X.MessageStringOf(x)
411 }
412
413 func (*FailKernRequestFrame) ProtoMessage() {}
414
415 func (x *FailKernRequestFrame) ProtoReflect() protoreflect.Message {
416 mi := &file_bpfki_proto_msgTypes[4]
417 if protoimpl.UnsafeEnabled && x != nil {
418 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
419 if ms.LoadMessageInfo() == nil {
420 ms.StoreMessageInfo(mi)
421 }
422 return ms
423 }
424 return mi.MessageOf(x)
425 }
426
427
428 func (*FailKernRequestFrame) Descriptor() ([]byte, []int) {
429 return file_bpfki_proto_rawDescGZIP(), []int{1, 0}
430 }
431
432 func (x *FailKernRequestFrame) GetFuncname() string {
433 if x != nil {
434 return x.Funcname
435 }
436 return ""
437 }
438
439 func (x *FailKernRequestFrame) GetParameters() string {
440 if x != nil {
441 return x.Parameters
442 }
443 return ""
444 }
445
446 func (x *FailKernRequestFrame) GetPredicate() string {
447 if x != nil {
448 return x.Predicate
449 }
450 return ""
451 }
452
453 var File_bpfki_proto protoreflect.FileDescriptor
454
455 var file_bpfki_proto_rawDesc = []byte{
456 0x0a, 0x0b, 0x62, 0x70, 0x66, 0x6b, 0x69, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x12, 0x05, 0x62,
457 0x70, 0x66, 0x6b, 0x69, 0x22, 0x8d, 0x01, 0x0a, 0x0f, 0x42, 0x75, 0x6d, 0x70, 0x54, 0x69, 0x6d,
458 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x10, 0x0a, 0x03, 0x70, 0x69, 0x64, 0x18,
459 0x01, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x03, 0x70, 0x69, 0x64, 0x12, 0x10, 0x0a, 0x03, 0x74, 0x69,
460 0x64, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x03, 0x74, 0x69, 0x64, 0x12, 0x16, 0x0a, 0x06,
461 0x73, 0x65, 0x63, 0x6f, 0x6e, 0x64, 0x18, 0x03, 0x20, 0x01, 0x28, 0x05, 0x52, 0x06, 0x73, 0x65,
462 0x63, 0x6f, 0x6e, 0x64, 0x12, 0x1c, 0x0a, 0x09, 0x73, 0x75, 0x62, 0x73, 0x65, 0x63, 0x6f, 0x6e,
463 0x64, 0x18, 0x04, 0x20, 0x01, 0x28, 0x05, 0x52, 0x09, 0x73, 0x75, 0x62, 0x73, 0x65, 0x63, 0x6f,
464 0x6e, 0x64, 0x12, 0x20, 0x0a, 0x0b, 0x70, 0x72, 0x6f, 0x62, 0x61, 0x62, 0x69, 0x6c, 0x69, 0x74,
465 0x79, 0x18, 0x05, 0x20, 0x01, 0x28, 0x02, 0x52, 0x0b, 0x70, 0x72, 0x6f, 0x62, 0x61, 0x62, 0x69,
466 0x6c, 0x69, 0x74, 0x79, 0x22, 0x86, 0x03, 0x0a, 0x0f, 0x46, 0x61, 0x69, 0x6c, 0x4b, 0x65, 0x72,
467 0x6e, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x10, 0x0a, 0x03, 0x70, 0x69, 0x64, 0x18,
468 0x01, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x03, 0x70, 0x69, 0x64, 0x12, 0x10, 0x0a, 0x03, 0x74, 0x69,
469 0x64, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x03, 0x74, 0x69, 0x64, 0x12, 0x35, 0x0a, 0x05,
470 0x66, 0x74, 0x79, 0x70, 0x65, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x1f, 0x2e, 0x62, 0x70,
471 0x66, 0x6b, 0x69, 0x2e, 0x46, 0x61, 0x69, 0x6c, 0x4b, 0x65, 0x72, 0x6e, 0x52, 0x65, 0x71, 0x75,
472 0x65, 0x73, 0x74, 0x2e, 0x46, 0x41, 0x49, 0x4c, 0x54, 0x59, 0x50, 0x45, 0x52, 0x05, 0x66, 0x74,
473 0x79, 0x70, 0x65, 0x12, 0x18, 0x0a, 0x07, 0x68, 0x65, 0x61, 0x64, 0x65, 0x72, 0x73, 0x18, 0x04,
474 0x20, 0x03, 0x28, 0x09, 0x52, 0x07, 0x68, 0x65, 0x61, 0x64, 0x65, 0x72, 0x73, 0x12, 0x3a, 0x0a,
475 0x09, 0x63, 0x61, 0x6c, 0x6c, 0x63, 0x68, 0x61, 0x69, 0x6e, 0x18, 0x05, 0x20, 0x03, 0x28, 0x0b,
476 0x32, 0x1c, 0x2e, 0x62, 0x70, 0x66, 0x6b, 0x69, 0x2e, 0x46, 0x61, 0x69, 0x6c, 0x4b, 0x65, 0x72,
477 0x6e, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x2e, 0x66, 0x72, 0x61, 0x6d, 0x65, 0x52, 0x09,
478 0x63, 0x61, 0x6c, 0x6c, 0x63, 0x68, 0x61, 0x69, 0x6e, 0x12, 0x20, 0x0a, 0x0b, 0x70, 0x72, 0x6f,
479 0x62, 0x61, 0x62, 0x69, 0x6c, 0x69, 0x74, 0x79, 0x18, 0x06, 0x20, 0x01, 0x28, 0x02, 0x52, 0x0b,
480 0x70, 0x72, 0x6f, 0x62, 0x61, 0x62, 0x69, 0x6c, 0x69, 0x74, 0x79, 0x12, 0x14, 0x0a, 0x05, 0x74,
481 0x69, 0x6d, 0x65, 0x73, 0x18, 0x07, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x05, 0x74, 0x69, 0x6d, 0x65,
482 0x73, 0x1a, 0x61, 0x0a, 0x05, 0x66, 0x72, 0x61, 0x6d, 0x65, 0x12, 0x1a, 0x0a, 0x08, 0x66, 0x75,
483 0x6e, 0x63, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x08, 0x66, 0x75,
484 0x6e, 0x63, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0x1e, 0x0a, 0x0a, 0x70, 0x61, 0x72, 0x61, 0x6d, 0x65,
485 0x74, 0x65, 0x72, 0x73, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0a, 0x70, 0x61, 0x72, 0x61,
486 0x6d, 0x65, 0x74, 0x65, 0x72, 0x73, 0x12, 0x1c, 0x0a, 0x09, 0x70, 0x72, 0x65, 0x64, 0x69, 0x63,
487 0x61, 0x74, 0x65, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52, 0x09, 0x70, 0x72, 0x65, 0x64, 0x69,
488 0x63, 0x61, 0x74, 0x65, 0x22, 0x27, 0x0a, 0x08, 0x46, 0x41, 0x49, 0x4c, 0x54, 0x59, 0x50, 0x45,
489 0x12, 0x08, 0x0a, 0x04, 0x53, 0x4c, 0x41, 0x42, 0x10, 0x00, 0x12, 0x08, 0x0a, 0x04, 0x50, 0x41,
490 0x47, 0x45, 0x10, 0x01, 0x12, 0x07, 0x0a, 0x03, 0x42, 0x49, 0x4f, 0x10, 0x02, 0x22, 0x86, 0x01,
491 0x0a, 0x12, 0x46, 0x61, 0x69, 0x6c, 0x53, 0x79, 0x73, 0x63, 0x61, 0x6c, 0x6c, 0x52, 0x65, 0x71,
492 0x75, 0x65, 0x73, 0x74, 0x12, 0x10, 0x0a, 0x03, 0x70, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28,
493 0x0d, 0x52, 0x03, 0x70, 0x69, 0x64, 0x12, 0x10, 0x0a, 0x03, 0x74, 0x69, 0x64, 0x18, 0x02, 0x20,
494 0x01, 0x28, 0x0d, 0x52, 0x03, 0x74, 0x69, 0x64, 0x12, 0x18, 0x0a, 0x07, 0x6d, 0x65, 0x74, 0x68,
495 0x6f, 0x64, 0x73, 0x18, 0x03, 0x20, 0x03, 0x28, 0x09, 0x52, 0x07, 0x6d, 0x65, 0x74, 0x68, 0x6f,
496 0x64, 0x73, 0x12, 0x10, 0x0a, 0x03, 0x65, 0x72, 0x72, 0x18, 0x04, 0x20, 0x01, 0x28, 0x0d, 0x52,
497 0x03, 0x65, 0x72, 0x72, 0x12, 0x20, 0x0a, 0x0b, 0x70, 0x72, 0x6f, 0x62, 0x61, 0x62, 0x69, 0x6c,
498 0x69, 0x74, 0x79, 0x18, 0x05, 0x20, 0x01, 0x28, 0x02, 0x52, 0x0b, 0x70, 0x72, 0x6f, 0x62, 0x61,
499 0x62, 0x69, 0x6c, 0x69, 0x74, 0x79, 0x22, 0x34, 0x0a, 0x0e, 0x53, 0x74, 0x61, 0x74, 0x75, 0x73,
500 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x10, 0x0a, 0x03, 0x72, 0x65, 0x74, 0x18,
501 0x01, 0x20, 0x01, 0x28, 0x05, 0x52, 0x03, 0x72, 0x65, 0x74, 0x12, 0x10, 0x0a, 0x03, 0x6d, 0x73,
502 0x67, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x03, 0x6d, 0x73, 0x67, 0x32, 0xa0, 0x04, 0x0a,
503 0x0c, 0x42, 0x50, 0x46, 0x4b, 0x49, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x12, 0x3d, 0x0a,
504 0x0a, 0x53, 0x65, 0x74, 0x54, 0x69, 0x6d, 0x65, 0x56, 0x61, 0x6c, 0x12, 0x16, 0x2e, 0x62, 0x70,
505 0x66, 0x6b, 0x69, 0x2e, 0x42, 0x75, 0x6d, 0x70, 0x54, 0x69, 0x6d, 0x65, 0x52, 0x65, 0x71, 0x75,
506 0x65, 0x73, 0x74, 0x1a, 0x15, 0x2e, 0x62, 0x70, 0x66, 0x6b, 0x69, 0x2e, 0x53, 0x74, 0x61, 0x74,
507 0x75, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x12, 0x41, 0x0a, 0x0e,
508 0x52, 0x65, 0x63, 0x6f, 0x76, 0x65, 0x72, 0x54, 0x69, 0x6d, 0x65, 0x56, 0x61, 0x6c, 0x12, 0x16,
509 0x2e, 0x62, 0x70, 0x66, 0x6b, 0x69, 0x2e, 0x42, 0x75, 0x6d, 0x70, 0x54, 0x69, 0x6d, 0x65, 0x52,
510 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x15, 0x2e, 0x62, 0x70, 0x66, 0x6b, 0x69, 0x2e, 0x53,
511 0x74, 0x61, 0x74, 0x75, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x12,
512 0x3e, 0x0a, 0x0b, 0x53, 0x65, 0x74, 0x54, 0x69, 0x6d, 0x65, 0x53, 0x70, 0x65, 0x63, 0x12, 0x16,
513 0x2e, 0x62, 0x70, 0x66, 0x6b, 0x69, 0x2e, 0x42, 0x75, 0x6d, 0x70, 0x54, 0x69, 0x6d, 0x65, 0x52,
514 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x15, 0x2e, 0x62, 0x70, 0x66, 0x6b, 0x69, 0x2e, 0x53,
515 0x74, 0x61, 0x74, 0x75, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x12,
516 0x42, 0x0a, 0x0f, 0x52, 0x65, 0x63, 0x6f, 0x76, 0x65, 0x72, 0x54, 0x69, 0x6d, 0x65, 0x53, 0x70,
517 0x65, 0x63, 0x12, 0x16, 0x2e, 0x62, 0x70, 0x66, 0x6b, 0x69, 0x2e, 0x42, 0x75, 0x6d, 0x70, 0x54,
518 0x69, 0x6d, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x15, 0x2e, 0x62, 0x70, 0x66,
519 0x6b, 0x69, 0x2e, 0x53, 0x74, 0x61, 0x74, 0x75, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73,
520 0x65, 0x22, 0x00, 0x12, 0x3e, 0x0a, 0x0b, 0x46, 0x61, 0x69, 0x6c, 0x4d, 0x4d, 0x4f, 0x72, 0x42,
521 0x49, 0x4f, 0x12, 0x16, 0x2e, 0x62, 0x70, 0x66, 0x6b, 0x69, 0x2e, 0x46, 0x61, 0x69, 0x6c, 0x4b,
522 0x65, 0x72, 0x6e, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x15, 0x2e, 0x62, 0x70, 0x66,
523 0x6b, 0x69, 0x2e, 0x53, 0x74, 0x61, 0x74, 0x75, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73,
524 0x65, 0x22, 0x00, 0x12, 0x41, 0x0a, 0x0e, 0x52, 0x65, 0x63, 0x6f, 0x76, 0x65, 0x72, 0x4d, 0x4d,
525 0x4f, 0x72, 0x42, 0x49, 0x4f, 0x12, 0x16, 0x2e, 0x62, 0x70, 0x66, 0x6b, 0x69, 0x2e, 0x46, 0x61,
526 0x69, 0x6c, 0x4b, 0x65, 0x72, 0x6e, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x15, 0x2e,
527 0x62, 0x70, 0x66, 0x6b, 0x69, 0x2e, 0x53, 0x74, 0x61, 0x74, 0x75, 0x73, 0x52, 0x65, 0x73, 0x70,
528 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x12, 0x41, 0x0a, 0x0b, 0x46, 0x61, 0x69, 0x6c, 0x53, 0x79,
529 0x73, 0x63, 0x61, 0x6c, 0x6c, 0x12, 0x19, 0x2e, 0x62, 0x70, 0x66, 0x6b, 0x69, 0x2e, 0x46, 0x61,
530 0x69, 0x6c, 0x53, 0x79, 0x73, 0x63, 0x61, 0x6c, 0x6c, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74,
531 0x1a, 0x15, 0x2e, 0x62, 0x70, 0x66, 0x6b, 0x69, 0x2e, 0x53, 0x74, 0x61, 0x74, 0x75, 0x73, 0x52,
532 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x12, 0x44, 0x0a, 0x0e, 0x52, 0x65, 0x63,
533 0x6f, 0x76, 0x65, 0x72, 0x53, 0x79, 0x73, 0x63, 0x61, 0x6c, 0x6c, 0x12, 0x19, 0x2e, 0x62, 0x70,
534 0x66, 0x6b, 0x69, 0x2e, 0x46, 0x61, 0x69, 0x6c, 0x53, 0x79, 0x73, 0x63, 0x61, 0x6c, 0x6c, 0x52,
535 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x15, 0x2e, 0x62, 0x70, 0x66, 0x6b, 0x69, 0x2e, 0x53,
536 0x74, 0x61, 0x74, 0x75, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x62,
537 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33,
538 }
539
540 var (
541 file_bpfki_proto_rawDescOnce sync.Once
542 file_bpfki_proto_rawDescData = file_bpfki_proto_rawDesc
543 )
544
545 func file_bpfki_proto_rawDescGZIP() []byte {
546 file_bpfki_proto_rawDescOnce.Do(func() {
547 file_bpfki_proto_rawDescData = protoimpl.X.CompressGZIP(file_bpfki_proto_rawDescData)
548 })
549 return file_bpfki_proto_rawDescData
550 }
551
552 var file_bpfki_proto_enumTypes = make([]protoimpl.EnumInfo, 1)
553 var file_bpfki_proto_msgTypes = make([]protoimpl.MessageInfo, 5)
554 var file_bpfki_proto_goTypes = []interface{}{
555 (FailKernRequest_FAILTYPE)(0),
556 (*BumpTimeRequest)(nil),
557 (*FailKernRequest)(nil),
558 (*FailSyscallRequest)(nil),
559 (*StatusResponse)(nil),
560 (*FailKernRequestFrame)(nil),
561 }
562 var file_bpfki_proto_depIdxs = []int32{
563 0,
564 5,
565 1,
566 1,
567 1,
568 1,
569 2,
570 2,
571 3,
572 3,
573 4,
574 4,
575 4,
576 4,
577 4,
578 4,
579 4,
580 4,
581 10,
582 2,
583 2,
584 2,
585 0,
586 }
587
588 func init() { file_bpfki_proto_init() }
589 func file_bpfki_proto_init() {
590 if File_bpfki_proto != nil {
591 return
592 }
593 if !protoimpl.UnsafeEnabled {
594 file_bpfki_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} {
595 switch v := v.(*BumpTimeRequest); i {
596 case 0:
597 return &v.state
598 case 1:
599 return &v.sizeCache
600 case 2:
601 return &v.unknownFields
602 default:
603 return nil
604 }
605 }
606 file_bpfki_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} {
607 switch v := v.(*FailKernRequest); i {
608 case 0:
609 return &v.state
610 case 1:
611 return &v.sizeCache
612 case 2:
613 return &v.unknownFields
614 default:
615 return nil
616 }
617 }
618 file_bpfki_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} {
619 switch v := v.(*FailSyscallRequest); i {
620 case 0:
621 return &v.state
622 case 1:
623 return &v.sizeCache
624 case 2:
625 return &v.unknownFields
626 default:
627 return nil
628 }
629 }
630 file_bpfki_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} {
631 switch v := v.(*StatusResponse); i {
632 case 0:
633 return &v.state
634 case 1:
635 return &v.sizeCache
636 case 2:
637 return &v.unknownFields
638 default:
639 return nil
640 }
641 }
642 file_bpfki_proto_msgTypes[4].Exporter = func(v interface{}, i int) interface{} {
643 switch v := v.(*FailKernRequestFrame); i {
644 case 0:
645 return &v.state
646 case 1:
647 return &v.sizeCache
648 case 2:
649 return &v.unknownFields
650 default:
651 return nil
652 }
653 }
654 }
655 type x struct{}
656 out := protoimpl.TypeBuilder{
657 File: protoimpl.DescBuilder{
658 GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
659 RawDescriptor: file_bpfki_proto_rawDesc,
660 NumEnums: 1,
661 NumMessages: 5,
662 NumExtensions: 0,
663 NumServices: 1,
664 },
665 GoTypes: file_bpfki_proto_goTypes,
666 DependencyIndexes: file_bpfki_proto_depIdxs,
667 EnumInfos: file_bpfki_proto_enumTypes,
668 MessageInfos: file_bpfki_proto_msgTypes,
669 }.Build()
670 File_bpfki_proto = out.File
671 file_bpfki_proto_rawDesc = nil
672 file_bpfki_proto_goTypes = nil
673 file_bpfki_proto_depIdxs = nil
674 }
675
676
677 var _ context.Context
678 var _ grpc.ClientConnInterface
679
680
681
682 const _ = grpc.SupportPackageIsVersion6
683
684
685
686
687 type BPFKIServiceClient interface {
688 SetTimeVal(ctx context.Context, in *BumpTimeRequest, opts ...grpc.CallOption) (*StatusResponse, error)
689 RecoverTimeVal(ctx context.Context, in *BumpTimeRequest, opts ...grpc.CallOption) (*StatusResponse, error)
690 SetTimeSpec(ctx context.Context, in *BumpTimeRequest, opts ...grpc.CallOption) (*StatusResponse, error)
691 RecoverTimeSpec(ctx context.Context, in *BumpTimeRequest, opts ...grpc.CallOption) (*StatusResponse, error)
692 FailMMOrBIO(ctx context.Context, in *FailKernRequest, opts ...grpc.CallOption) (*StatusResponse, error)
693 RecoverMMOrBIO(ctx context.Context, in *FailKernRequest, opts ...grpc.CallOption) (*StatusResponse, error)
694 FailSyscall(ctx context.Context, in *FailSyscallRequest, opts ...grpc.CallOption) (*StatusResponse, error)
695 RecoverSyscall(ctx context.Context, in *FailSyscallRequest, opts ...grpc.CallOption) (*StatusResponse, error)
696 }
697
698 type bPFKIServiceClient struct {
699 cc grpc.ClientConnInterface
700 }
701
702 func NewBPFKIServiceClient(cc grpc.ClientConnInterface) BPFKIServiceClient {
703 return &bPFKIServiceClient{cc}
704 }
705
706 func (c *bPFKIServiceClient) SetTimeVal(ctx context.Context, in *BumpTimeRequest, opts ...grpc.CallOption) (*StatusResponse, error) {
707 out := new(StatusResponse)
708 err := c.cc.Invoke(ctx, "/bpfki.BPFKIService/SetTimeVal", in, out, opts...)
709 if err != nil {
710 return nil, err
711 }
712 return out, nil
713 }
714
715 func (c *bPFKIServiceClient) RecoverTimeVal(ctx context.Context, in *BumpTimeRequest, opts ...grpc.CallOption) (*StatusResponse, error) {
716 out := new(StatusResponse)
717 err := c.cc.Invoke(ctx, "/bpfki.BPFKIService/RecoverTimeVal", in, out, opts...)
718 if err != nil {
719 return nil, err
720 }
721 return out, nil
722 }
723
724 func (c *bPFKIServiceClient) SetTimeSpec(ctx context.Context, in *BumpTimeRequest, opts ...grpc.CallOption) (*StatusResponse, error) {
725 out := new(StatusResponse)
726 err := c.cc.Invoke(ctx, "/bpfki.BPFKIService/SetTimeSpec", in, out, opts...)
727 if err != nil {
728 return nil, err
729 }
730 return out, nil
731 }
732
733 func (c *bPFKIServiceClient) RecoverTimeSpec(ctx context.Context, in *BumpTimeRequest, opts ...grpc.CallOption) (*StatusResponse, error) {
734 out := new(StatusResponse)
735 err := c.cc.Invoke(ctx, "/bpfki.BPFKIService/RecoverTimeSpec", in, out, opts...)
736 if err != nil {
737 return nil, err
738 }
739 return out, nil
740 }
741
742 func (c *bPFKIServiceClient) FailMMOrBIO(ctx context.Context, in *FailKernRequest, opts ...grpc.CallOption) (*StatusResponse, error) {
743 out := new(StatusResponse)
744 err := c.cc.Invoke(ctx, "/bpfki.BPFKIService/FailMMOrBIO", in, out, opts...)
745 if err != nil {
746 return nil, err
747 }
748 return out, nil
749 }
750
751 func (c *bPFKIServiceClient) RecoverMMOrBIO(ctx context.Context, in *FailKernRequest, opts ...grpc.CallOption) (*StatusResponse, error) {
752 out := new(StatusResponse)
753 err := c.cc.Invoke(ctx, "/bpfki.BPFKIService/RecoverMMOrBIO", in, out, opts...)
754 if err != nil {
755 return nil, err
756 }
757 return out, nil
758 }
759
760 func (c *bPFKIServiceClient) FailSyscall(ctx context.Context, in *FailSyscallRequest, opts ...grpc.CallOption) (*StatusResponse, error) {
761 out := new(StatusResponse)
762 err := c.cc.Invoke(ctx, "/bpfki.BPFKIService/FailSyscall", in, out, opts...)
763 if err != nil {
764 return nil, err
765 }
766 return out, nil
767 }
768
769 func (c *bPFKIServiceClient) RecoverSyscall(ctx context.Context, in *FailSyscallRequest, opts ...grpc.CallOption) (*StatusResponse, error) {
770 out := new(StatusResponse)
771 err := c.cc.Invoke(ctx, "/bpfki.BPFKIService/RecoverSyscall", in, out, opts...)
772 if err != nil {
773 return nil, err
774 }
775 return out, nil
776 }
777
778
779 type BPFKIServiceServer interface {
780 SetTimeVal(context.Context, *BumpTimeRequest) (*StatusResponse, error)
781 RecoverTimeVal(context.Context, *BumpTimeRequest) (*StatusResponse, error)
782 SetTimeSpec(context.Context, *BumpTimeRequest) (*StatusResponse, error)
783 RecoverTimeSpec(context.Context, *BumpTimeRequest) (*StatusResponse, error)
784 FailMMOrBIO(context.Context, *FailKernRequest) (*StatusResponse, error)
785 RecoverMMOrBIO(context.Context, *FailKernRequest) (*StatusResponse, error)
786 FailSyscall(context.Context, *FailSyscallRequest) (*StatusResponse, error)
787 RecoverSyscall(context.Context, *FailSyscallRequest) (*StatusResponse, error)
788 }
789
790
791 type UnimplementedBPFKIServiceServer struct {
792 }
793
794 func (*UnimplementedBPFKIServiceServer) SetTimeVal(context.Context, *BumpTimeRequest) (*StatusResponse, error) {
795 return nil, status.Errorf(codes.Unimplemented, "method SetTimeVal not implemented")
796 }
797 func (*UnimplementedBPFKIServiceServer) RecoverTimeVal(context.Context, *BumpTimeRequest) (*StatusResponse, error) {
798 return nil, status.Errorf(codes.Unimplemented, "method RecoverTimeVal not implemented")
799 }
800 func (*UnimplementedBPFKIServiceServer) SetTimeSpec(context.Context, *BumpTimeRequest) (*StatusResponse, error) {
801 return nil, status.Errorf(codes.Unimplemented, "method SetTimeSpec not implemented")
802 }
803 func (*UnimplementedBPFKIServiceServer) RecoverTimeSpec(context.Context, *BumpTimeRequest) (*StatusResponse, error) {
804 return nil, status.Errorf(codes.Unimplemented, "method RecoverTimeSpec not implemented")
805 }
806 func (*UnimplementedBPFKIServiceServer) FailMMOrBIO(context.Context, *FailKernRequest) (*StatusResponse, error) {
807 return nil, status.Errorf(codes.Unimplemented, "method FailMMOrBIO not implemented")
808 }
809 func (*UnimplementedBPFKIServiceServer) RecoverMMOrBIO(context.Context, *FailKernRequest) (*StatusResponse, error) {
810 return nil, status.Errorf(codes.Unimplemented, "method RecoverMMOrBIO not implemented")
811 }
812 func (*UnimplementedBPFKIServiceServer) FailSyscall(context.Context, *FailSyscallRequest) (*StatusResponse, error) {
813 return nil, status.Errorf(codes.Unimplemented, "method FailSyscall not implemented")
814 }
815 func (*UnimplementedBPFKIServiceServer) RecoverSyscall(context.Context, *FailSyscallRequest) (*StatusResponse, error) {
816 return nil, status.Errorf(codes.Unimplemented, "method RecoverSyscall not implemented")
817 }
818
819 func RegisterBPFKIServiceServer(s *grpc.Server, srv BPFKIServiceServer) {
820 s.RegisterService(&_BPFKIService_serviceDesc, srv)
821 }
822
823 func _BPFKIService_SetTimeVal_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
824 in := new(BumpTimeRequest)
825 if err := dec(in); err != nil {
826 return nil, err
827 }
828 if interceptor == nil {
829 return srv.(BPFKIServiceServer).SetTimeVal(ctx, in)
830 }
831 info := &grpc.UnaryServerInfo{
832 Server: srv,
833 FullMethod: "/bpfki.BPFKIService/SetTimeVal",
834 }
835 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
836 return srv.(BPFKIServiceServer).SetTimeVal(ctx, req.(*BumpTimeRequest))
837 }
838 return interceptor(ctx, in, info, handler)
839 }
840
841 func _BPFKIService_RecoverTimeVal_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
842 in := new(BumpTimeRequest)
843 if err := dec(in); err != nil {
844 return nil, err
845 }
846 if interceptor == nil {
847 return srv.(BPFKIServiceServer).RecoverTimeVal(ctx, in)
848 }
849 info := &grpc.UnaryServerInfo{
850 Server: srv,
851 FullMethod: "/bpfki.BPFKIService/RecoverTimeVal",
852 }
853 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
854 return srv.(BPFKIServiceServer).RecoverTimeVal(ctx, req.(*BumpTimeRequest))
855 }
856 return interceptor(ctx, in, info, handler)
857 }
858
859 func _BPFKIService_SetTimeSpec_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
860 in := new(BumpTimeRequest)
861 if err := dec(in); err != nil {
862 return nil, err
863 }
864 if interceptor == nil {
865 return srv.(BPFKIServiceServer).SetTimeSpec(ctx, in)
866 }
867 info := &grpc.UnaryServerInfo{
868 Server: srv,
869 FullMethod: "/bpfki.BPFKIService/SetTimeSpec",
870 }
871 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
872 return srv.(BPFKIServiceServer).SetTimeSpec(ctx, req.(*BumpTimeRequest))
873 }
874 return interceptor(ctx, in, info, handler)
875 }
876
877 func _BPFKIService_RecoverTimeSpec_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
878 in := new(BumpTimeRequest)
879 if err := dec(in); err != nil {
880 return nil, err
881 }
882 if interceptor == nil {
883 return srv.(BPFKIServiceServer).RecoverTimeSpec(ctx, in)
884 }
885 info := &grpc.UnaryServerInfo{
886 Server: srv,
887 FullMethod: "/bpfki.BPFKIService/RecoverTimeSpec",
888 }
889 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
890 return srv.(BPFKIServiceServer).RecoverTimeSpec(ctx, req.(*BumpTimeRequest))
891 }
892 return interceptor(ctx, in, info, handler)
893 }
894
895 func _BPFKIService_FailMMOrBIO_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
896 in := new(FailKernRequest)
897 if err := dec(in); err != nil {
898 return nil, err
899 }
900 if interceptor == nil {
901 return srv.(BPFKIServiceServer).FailMMOrBIO(ctx, in)
902 }
903 info := &grpc.UnaryServerInfo{
904 Server: srv,
905 FullMethod: "/bpfki.BPFKIService/FailMMOrBIO",
906 }
907 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
908 return srv.(BPFKIServiceServer).FailMMOrBIO(ctx, req.(*FailKernRequest))
909 }
910 return interceptor(ctx, in, info, handler)
911 }
912
913 func _BPFKIService_RecoverMMOrBIO_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
914 in := new(FailKernRequest)
915 if err := dec(in); err != nil {
916 return nil, err
917 }
918 if interceptor == nil {
919 return srv.(BPFKIServiceServer).RecoverMMOrBIO(ctx, in)
920 }
921 info := &grpc.UnaryServerInfo{
922 Server: srv,
923 FullMethod: "/bpfki.BPFKIService/RecoverMMOrBIO",
924 }
925 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
926 return srv.(BPFKIServiceServer).RecoverMMOrBIO(ctx, req.(*FailKernRequest))
927 }
928 return interceptor(ctx, in, info, handler)
929 }
930
931 func _BPFKIService_FailSyscall_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
932 in := new(FailSyscallRequest)
933 if err := dec(in); err != nil {
934 return nil, err
935 }
936 if interceptor == nil {
937 return srv.(BPFKIServiceServer).FailSyscall(ctx, in)
938 }
939 info := &grpc.UnaryServerInfo{
940 Server: srv,
941 FullMethod: "/bpfki.BPFKIService/FailSyscall",
942 }
943 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
944 return srv.(BPFKIServiceServer).FailSyscall(ctx, req.(*FailSyscallRequest))
945 }
946 return interceptor(ctx, in, info, handler)
947 }
948
949 func _BPFKIService_RecoverSyscall_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
950 in := new(FailSyscallRequest)
951 if err := dec(in); err != nil {
952 return nil, err
953 }
954 if interceptor == nil {
955 return srv.(BPFKIServiceServer).RecoverSyscall(ctx, in)
956 }
957 info := &grpc.UnaryServerInfo{
958 Server: srv,
959 FullMethod: "/bpfki.BPFKIService/RecoverSyscall",
960 }
961 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
962 return srv.(BPFKIServiceServer).RecoverSyscall(ctx, req.(*FailSyscallRequest))
963 }
964 return interceptor(ctx, in, info, handler)
965 }
966
967 var _BPFKIService_serviceDesc = grpc.ServiceDesc{
968 ServiceName: "bpfki.BPFKIService",
969 HandlerType: (*BPFKIServiceServer)(nil),
970 Methods: []grpc.MethodDesc{
971 {
972 MethodName: "SetTimeVal",
973 Handler: _BPFKIService_SetTimeVal_Handler,
974 },
975 {
976 MethodName: "RecoverTimeVal",
977 Handler: _BPFKIService_RecoverTimeVal_Handler,
978 },
979 {
980 MethodName: "SetTimeSpec",
981 Handler: _BPFKIService_SetTimeSpec_Handler,
982 },
983 {
984 MethodName: "RecoverTimeSpec",
985 Handler: _BPFKIService_RecoverTimeSpec_Handler,
986 },
987 {
988 MethodName: "FailMMOrBIO",
989 Handler: _BPFKIService_FailMMOrBIO_Handler,
990 },
991 {
992 MethodName: "RecoverMMOrBIO",
993 Handler: _BPFKIService_RecoverMMOrBIO_Handler,
994 },
995 {
996 MethodName: "FailSyscall",
997 Handler: _BPFKIService_FailSyscall_Handler,
998 },
999 {
1000 MethodName: "RecoverSyscall",
1001 Handler: _BPFKIService_RecoverSyscall_Handler,
1002 },
1003 },
1004 Streams: []grpc.StreamDesc{},
1005 Metadata: "bpfki.proto",
1006 }
1007