Searched refs:stateResponse (Results 1 – 5 of 5) sorted by relevance
19 stateResponse, err := r.agentClient.GetState()24 if stateResponse.JobState == "running" {28 return true, bosherr.Errorf("Received non-running job state: '%s'", stateResponse.JobState)
71 val stateResponse = new MasterStateResponse( constant74 val output = JsonProtocol.writeMasterState(stateResponse)85 val stateResponse = new WorkerStateResponse("host", 8080, "workerId", executors, constant87 val output = JsonProtocol.writeWorkerState(stateResponse)
628 QSharedPointer<Responses::State> stateResponse = resp.dynamicCast<Responses::State>(); in queueResponse() local630 if (stateResponse && stateResponse->tag == literalCommandTag) { in queueResponse()635 if (stateResponse->kind != Responses::NO && stateResponse->kind != Responses::BAD) { in queueResponse()
370 StateAwareResponse stateResponse = (StateAwareResponse) response; in invokeHandlerMethod() local373 stateResponse.setRenderParameter(IMPLICIT_MODEL_RENDER_PARAMETER, Boolean.TRUE.toString()); in invokeHandlerMethod()
171 if (Responses::State *stateResponse = dynamic_cast<Responses::State *>(resp.data())) { in responseReceived() local172 if (stateResponse->kind == Responses::BAD) { in responseReceived()175 s << *stateResponse; in responseReceived()