(reqinfo *RequestInfo)
| 114 | } |
| 115 | |
| 116 | func (s *RuntimeClient) waitRuntime(reqinfo *RequestInfo) (err error) { |
| 117 | runtime := reqinfo.Runtime |
| 118 | input := reqinfo.Input |
| 119 | ok := runtime.Wait(s.config.WaitRuntimeAliveTimeout) |
| 120 | if !ok { |
| 121 | err = fmt.Errorf("runtime %s not ready", runtime.RuntimeID) |
| 122 | return |
| 123 | } |
| 124 | |
| 125 | if input.Configuration.CommitID != nil && |
| 126 | *(input.Configuration.CommitID) != runtime.CommitID { |
| 127 | err = fmt.Errorf("commitid [%s] [%s] mismatch, ", *input.Configuration.CommitID, runtime.CommitID) |
| 128 | return |
| 129 | } |
| 130 | |
| 131 | if input.Configuration.MemorySize != nil { |
| 132 | reqinfo.MemorySpecSize = *(input.Configuration.MemorySize) |
| 133 | } else { |
| 134 | reqinfo.MemorySpecSize = api.MinMemorySize |
| 135 | } |
| 136 | runtime.UserID = input.User.ID |
| 137 | return |
| 138 | } |
| 139 | |
| 140 | func (s *RuntimeClient) invokeCleanup(reqinfo *RequestInfo, runtime *RuntimeInfo) { |
| 141 | runtime.InvokeDone(reqinfo, false) |
no test coverage detected