Udostępnij za pośrednictwem

Wysyłanie odpowiedzi asynchronicznej

  • Artykuł

Po zakończeniu wywołania asynchronicznego serwer wysyła odpowiedź do klienta, wywołując funkcję RpcAsyncCompleteCall i przekazując jej asynchroniczny uchwyt. To wywołanie jest konieczne, nawet jeśli wywołanie asynchroniczne ma wartość zwracaną void i nie ma parametrów [out]. Jeśli funkcja ma wartość zwracaną, jest przekazywana przez odwołanie do RpcAsyncCompleteCall.

Gdy serwer wywołuje RpcAsyncCompleteCall albo RpcAsyncAbortCall, albo gdy wywołanie zostaje zakończone z powodu zgłoszenia wyjątku w procedurze zarządzającej serwerem, biblioteka czasu wykonywania RPC automatycznie niszczy asynchroniczne dojście serwera.

Nota

Serwer musi zakończyć aktualizowanie parametrów [in, out] i [out] przed wywołaniem RpcAsyncCompleteCall. Nie można wprowadzać żadnych zmian w tych parametrach ani w asynchronicznym dojściu po wywołaniu RpcAsyncCompleteCall. Jeśli wywołanie funkcji RpcAsyncCompleteCall zakończy się niepowodzeniem, środowisko uruchomieniowe RPC zwalnia parametry.

 

W poniższym przykładzie pokazano proste wywołanie procedury asynchronicznej.

#define DEFAULT_ASYNC_DELAY 20;
#define ASYNC_CANCEL_CHECK 100;

void AsyncFunc(IN PRPC_ASYNC_STATE pAsync,
               IN RPC_BINDING_HANDLE hBinding,
               IN OUT unsigned long nAsychDelay)
{
    int nReply = 1;
    RPC_STATUS status;
    unsigned long nTmpAsychDelay;
    int i;
 
    if (nAsychDelay < 0){
        nAsychDelay = DEFAULT_ASYNC_DELAY;
    }else if (nAsychDelay < 100){
        nAsychDelay = 100;
    }

    // We only call RpcServerTestCancel if the call
    // takes longer than ASYNC_CANCEL_CHECK ms
    if(nAsychDelay > ASYNC_CANCEL_CHECK){
        
        nTmpAsychDelay = nAsychDelay/100;
 
        for (i = 0; i < 100; i++){
            Sleep(nTmpAsychDelay);
 
            if (i%5 == 0){
                fprintf(stderr, 
                        "\rRunning AsyncFunc (%lu ms) (%d%c) ... ",
                        nAsychDelay, i+5, PERCENT);
 
                status = 
                    RpcServerTestCancel(
                        RpcAsyncGetCallHandle(pAsync));
                if (status == RPC_S_OK){
                    fprintf(stderr, 
                            "\nAsyncFunc has been canceled!!!\n");
                    break;
                }else if (status != RPC_S_CALL_IN_PROGRESS){
                    printf(
                        "RpcAsyncInitializeHandle returned 0x%x\n", 
                        status);
                    exit(status); 
                }
            }
        }
    }else{
        Sleep(nAsychDelay);
    }
 
    printf("\nCalling RpcAsyncCompleteCall\n");
    status = RpcAsyncCompleteCall(pAsync, &nReply);
    printf("RpcAsyncCompleteCall returned 0x%x\n", status);
    if (status){
        exit(status);
    }
}

Dla uproszczenia ta asynchroniczna procedura serwera nie przetwarza rzeczywistych danych. To po prostu kładzie się spać na jakiś czas.

Notatka

Funkcja RpcAsyncCompleteCall może być wywoływana w wątku, który odebrał wywołanie, lub na dowolnym innym wątku w procesie. Jeśli wszystkie dane niezbędne do ukończenia wywołania są łatwo dostępne, serwer może wypełnić je w tym samym wątku i wywołać RpcAsyncCompleteCall w tym samym wątku. Takie podejście pozwala zaoszczędzić pewne przełączanie kontekstu i poprawić wydajność. Takie wywołania są nazywane oportunistycznie asynchronicznymi.

 

RPC_ASYNC_STATE

RpcAsyncCompleteCall

RpcAsyncAbortCall

RpcServerTestCancel