Использование "oneway void" в определениях Thrift-функций - PullRequest
Новая
       19

Использование "oneway void" в определениях Thrift-функций

2 голосов
/ 02 сентября 2010

Я использую модификатор oneway в одном из моих определений функции Thrift: 

...
oneway void secret_function(1: string x, 2: string y),
...

При создании соответствующего кода Эрланга через Thrift это переводится в: 

...
function_info('secret_function', reply_type) ->
  oneway_void;
function_info('secret_function', exceptions) ->
  {struct, []};
...

Обратите внимание на атом oneway_void.

Когда выполняется функция secret_function, я получаю следующую ошибку: 

=ERROR REPORT==== 2-Sep-2010::18:17:08 ===
oneway void secret_function threw error which must be ignored: {error,
                                                             function_clause,
                                                             [{thrift_protocol,
                                                               term_to_typeid,
                                                               [oneway_void]},
                                                              {thrift_protocol,
                                                               struct_write_loop,
                                                               3},
                                                              {thrift_protocol,
                                                               write,2},
                                                              {thrift_processor,
                                                               send_reply,
                                                               4},
                                                              {thrift_processor,
                                                               handle_function,
                                                               2},
                                                              {thrift_processor,
                                                               loop,1}]}

Независимо от возможных ошибок, содержащихся в пользователекод, здесь функция thrift_protocol:term_to_typeid/1 вызывается с атомом oneway_void в качестве аргумента, что вызывает предложение функции.На самом деле, чтение из кода (thrift_protocol.erl): 

...
term_to_typeid(void) -> ?tType_VOID;
term_to_typeid(bool) -> ?tType_BOOL;
term_to_typeid(byte) -> ?tType_BYTE;
term_to_typeid(double) -> ?tType_DOUBLE;
term_to_typeid(i16) -> ?tType_I16;
term_to_typeid(i32) -> ?tType_I32;
term_to_typeid(i64) -> ?tType_I64;
term_to_typeid(string) -> ?tType_STRING;
term_to_typeid({struct, _}) -> ?tType_STRUCT;
term_to_typeid({map, _, _}) -> ?tType_MAP;
term_to_typeid({set, _}) -> ?tType_SET;
term_to_typeid({list, _}) -> ?tType_LIST.
...

Ошибка?Любое другое объяснение?Почему oneway_void передается этой функции?

1 Ответ

0 голосов
/ 07 сентября 2010

Мне кажется, я знаю, что происходит за кулисами.

Мой код Erlang (secret_function/2) возвращал {ok, pid ()}, а не просто ok.Даже если это концептуально неправильно с тех пор, как я объявил функцию oneway_void, мне потребовалось некоторое время, чтобы определить причину проблемы.Возможно, мы могли бы настроить функцию handle_succes в Thrift, чтобы она работала так же, как h andle_function_catch уже.Вот как выглядит handle_function_catch на данный момент: 

...
case {ErrType, ErrData} of
    _ when IsOneway ->
        Stack = erlang:get_stacktrace(),
        error_logger:warning_msg(
          "oneway void ~p threw error which must be ignored: ~p",
          [Function, {ErrType, ErrData, Stack}]),
        {State, ok};
...

Даже если функция объявлена ​​как oneway_void, когда возникает исключение, сообщается о проблеме.Потенциальная новая функция handle_success, следуя тому же рассуждению, может выглядеть следующим образом: 

handle_success(State = #thrift_processor{service = Service},
               Function,
               Result) ->
    ReplyType  = Service:function_info(Function, reply_type),
    StructName = atom_to_list(Function) ++ "_result",

    case Result of
        {reply, ReplyData} when ReplyType =:= oneway_void ->
            Stack = erlang:get_stacktrace(),
            error_logger:warning_msg(
              "oneway void ~p sent reply which must be ignored: ~p",
              [Function, {ReplyData, Stack}]),
            {State, ok};
                {reply, ReplyData} ->
            Reply = {{struct, [{0, ReplyType}]}, {StructName, ReplyData}},
            send_reply(State, Function, ?tMessageType_REPLY, Reply);

        ok when ReplyType == {struct, []} ->
            send_reply(State, Function, ?tMessageType_REPLY, {ReplyType, {StructName}});

        ok when ReplyType == oneway_void ->
            %% no reply for oneway void
            {State, ok}
    end.

Здесь я просто проверяю, определена ли функция как oneway_void и верно ли это, и я до сих порполучить возвращаемое значение, отличное от атома ok, я сообщаю об аварии, все еще игнорируя возвращаемое значение.

Это то, что разработчик увидел бы с обновленной функцией handle_success: 

=ERROR REPORT==== 7-Sep-2010::11:06:43 ===
oneway void secret_function sent reply which must be ignored: {{ok,
                                                                  <0.262.0>},
                                                                 []}

И это может спасти вашу жизнь хотя бы один раз (цит.).

...