← Back to branch summary

~ubuntu-branches/debian/squeeze/erlang/squeeze

« back to all changes in this revision

Viewing changes to lib/cosNotification/src/PusherConsumer_impl.erl

  • Committer: Bazaar Package Importer
  • Author(s): Sergei Golovan
  • Date: 2009-08-05 20:54:29 UTC
  • mfrom: (6.1.2 sid)
  • Revision ID: james.westby@ubuntu.com-20090805205429-pm4pnwew8axraosl
Tags: 1:13.b.1-dfsg-5
http://bugs.debian.org/536891
* Fixed parentheses in Emacs mode (closes: #536891).
* Removed unnecessary conflicts with erlang-manpages package.
* Added workaround for #475459: disabled threads on sparc architecture.
  This breaks wxErlang, so it's only a temporary solution.

Show diffs side-by-side

added added

removed removed

Lines of Context:
lib/cosNotification/src/PusherConsumer_impl.erl
485
485
%% Arguments: FilterID - long
486
486
%% Returns  : ok
487
487
%%-----------------------------------------------------------
488
 
remove_filter(_OE_THIS, _OE_FROM, State, FilterID) when integer(FilterID) ->
 
488
remove_filter(_OE_THIS, _OE_FROM, State, FilterID) when is_integer(FilterID) ->
489
489
    {reply, ok, ?del_Filter(State, FilterID)};
490
490
remove_filter(_,_,_,What) ->
491
491
    orber:dbg("[~p] PusherConsumer:remove_filter(~p); Not an integer", 
498
498
%% Returns  : Filter - CosNotifyFilter::Filter |
499
499
%%            {'EXCEPTION', #'CosNotifyFilter_FilterNotFound'{}}
500
500
%%-----------------------------------------------------------
501
 
get_filter(_OE_THIS, _OE_FROM, State, FilterID) when integer(FilterID) ->
 
501
get_filter(_OE_THIS, _OE_FROM, State, FilterID) when is_integer(FilterID) ->
502
502
    {reply, ?get_Filter(State, FilterID), State};
503
503
get_filter(_,_,_,What) ->
504
504
    orber:dbg("[~p] PusherConsumer:get_filter(~p); Not an integer", 
672
672
        ok ->
673
673
            ?DBG("PROXY FORWARD ANY: ~p~n",[Event]),
674
674
            {noreply, State};
675
 
        {'EXCEPTION', E} when record(E, 'OBJECT_NOT_EXIST') ;
676
 
                              record(E, 'NO_PERMISSION') ;
677
 
                              record(E, 'CosEventComm_Disconnected') ->
 
675
        {'EXCEPTION', E} when is_record(E, 'OBJECT_NOT_EXIST') orelse
 
676
                              is_record(E, 'NO_PERMISSION') orelse
 
677
                              is_record(E, 'CosEventComm_Disconnected') ->
678
678
            orber:dbg("[~p] PusherConsumer:forward();~n"
679
679
                      "Admin/Channel no longer exists; terminating and dropping: ~p", 
680
680
                      [?LINE, Event], ?DEBUG_LEVEL),
701
701
    case catch oe_CosNotificationComm_Event:callSeq(SendTo, Event, Status) of
702
702
        ok ->
703
703
            {noreply, State};
704
 
        {'EXCEPTION', E} when record(E, 'OBJECT_NOT_EXIST') ;
705
 
                              record(E, 'NO_PERMISSION') ;
706
 
                              record(E, 'CosEventComm_Disconnected') ->
 
704
        {'EXCEPTION', E} when is_record(E, 'OBJECT_NOT_EXIST') orelse
 
705
                              is_record(E, 'NO_PERMISSION') orelse
 
706
                              is_record(E, 'CosEventComm_Disconnected') ->
707
707
            ?DBG("ADMIN NO LONGER EXIST; DROPPING: ~p~n", [Event]),
708
708
            'CosNotification_Common':notify([{proxy, OE_THIS},
709
709
                                             {client, ?get_Client(State)},