(ctx context.Context, in *pb.QuantizationRequest)
| 804 | } |
| 805 | |
| 806 | func (s *server) StartQuantization(ctx context.Context, in *pb.QuantizationRequest) (*pb.QuantizationJobResult, error) { |
| 807 | if s.llm.Locking() { |
| 808 | s.llm.Lock() |
| 809 | defer s.llm.Unlock() |
| 810 | } |
| 811 | res, err := s.llm.StartQuantization(in) |
| 812 | if err != nil { |
| 813 | return &pb.QuantizationJobResult{Success: false, Message: fmt.Sprintf("Error starting quantization: %s", err.Error())}, err |
| 814 | } |
| 815 | return res, nil |
| 816 | } |
| 817 | |
| 818 | func (s *server) QuantizationProgress(in *pb.QuantizationProgressRequest, stream pb.Backend_QuantizationProgressServer) error { |
| 819 | if s.llm.Locking() { |
nothing calls this directly
no test coverage detected