9.1/sources/libs/nvdsinferserver/infer_trtis_utils.h

Go to the documentation of this file.

/*
 * SPDX-FileCopyrightText: Copyright (c) 2020-2026 NVIDIA CORPORATION & AFFILIATES. All rights reserved.
 * SPDX-License-Identifier: Apache-2.0
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 * http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */
 
#ifndef __NVDSINFER_TRTIS_UTILS_H__
#define __NVDSINFER_TRTIS_UTILS_H__
 
#include <string>
#include <thread>
#include <vector>
#include <memory>
#include <functional>
 
#include "infer_common.h"
#include "infer_datatypes.h"
#include "infer_utils.h"
 
#include "model_config.pb.h"
#include "tritonserver.h"
 
#define CHECK_TRTIS_ERR_W_ACTION(trtisExpr, action, fmt, ...)              \
    do {                                                                   \
        UniqTritonT<TRITONSERVER_Error> errPtr(                            \
            (trtisExpr), TRITONSERVER_ErrorDelete);                        \
        if (errPtr) {                                                      \
            InferError(                                                    \
                "Triton: " fmt ", triton_err_str:%s, err_msg:%s",          \
                ##__VA_ARGS__, TRITONSERVER_ErrorCodeString(errPtr.get()), \
                TRITONSERVER_ErrorMessage(errPtr.get()));                  \
            action;                                                        \
        }                                                                  \
    } while (0)
 
#define RETURN_TRTIS_ERROR(trtisExpr, fmt, ...) \
    CHECK_TRTIS_ERR_W_ACTION(trtisExpr, return NVDSINFER_TRITON_ERROR, fmt, ##__VA_ARGS__)
 
#define CONTINUE_TRTIS_ERROR(trtisExpr, fmt, ...) \
    CHECK_TRTIS_ERR_W_ACTION(trtisExpr, , fmt, ##__VA_ARGS__)
 
namespace ni = inference;
 
namespace nvdsinferserver {
 
InferDataType DataTypeFromTriton(TRITONSERVER_DataType type);
 
TRITONSERVER_DataType DataTypeToTriton(InferDataType type);
 
InferDataType DataTypeFromTritonPb(ni::DataType type);
 
InferTensorOrder TensorOrderFromTritonPb(ni::ModelInput::Format order);
 
InferTensorOrder TensorOrderFromTritonMeta(const std::string& format);
 
TRITONSERVER_MemoryType MemTypeToTriton(InferMemType type);
InferMemType MemTypeFromTriton(TRITONSERVER_MemoryType type);
 
template <typename VecDims>
InferDims
DimsFromTriton(const VecDims& shape)
{
    InferDims ret{0};
    assert((int)shape.size() <= NVDSINFER_MAX_DIMS);
    uint32_t i = 0;
    for (const auto &v : shape) {
        if (v < 0) {
            ret.d[i] = -1;
        } else {
            ret.d[i] = v;
        }
        ++i;
    }
    ret.numDims = i;
    if (!hasWildcard(ret)) {
        normalizeDims(ret);
    }
    return ret;
}
 
const char* TritonControlModeToStr(int32_t mode);
 
} // namespace nvdsinferserver
 
#endif /* __NVDSINFER_TRTIS_UTILS_H__ */