blob: 53849d51fca2c52758f23ff8beaef1701e47b1c0 [file] [log] [blame]
mlumish156e67d2015-01-02 14:59:16 -08001<?php
Craig Tiller2e498aa2015-02-16 12:09:31 -08002/*
3 *
4 * Copyright 2015, Google Inc.
5 * All rights reserved.
6 *
7 * Redistribution and use in source and binary forms, with or without
8 * modification, are permitted provided that the following conditions are
9 * met:
10 *
11 * * Redistributions of source code must retain the above copyright
12 * notice, this list of conditions and the following disclaimer.
13 * * Redistributions in binary form must reproduce the above
14 * copyright notice, this list of conditions and the following disclaimer
15 * in the documentation and/or other materials provided with the
16 * distribution.
17 * * Neither the name of Google Inc. nor the names of its
18 * contributors may be used to endorse or promote products derived from
19 * this software without specific prior written permission.
20 *
21 * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
22 * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
23 * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
24 * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
25 * OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
26 * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
27 * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
28 * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
29 * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
30 * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
31 * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
32 *
33 */
Stanley Cheungd5b20562015-10-27 13:27:05 -070034
mlumish156e67d2015-01-02 14:59:16 -080035namespace Grpc;
murgatroid999140a062015-03-26 11:27:58 -070036
Stanley Cheungd5b20562015-10-27 13:27:05 -070037abstract class AbstractCall
38{
39 protected $call;
40 protected $deserialize;
41 protected $metadata;
murgatroid999140a062015-03-26 11:27:58 -070042
Stanley Cheungd5b20562015-10-27 13:27:05 -070043 /**
44 * Create a new Call wrapper object.
45 *
46 * @param Channel $channel The channel to communicate on
47 * @param string $method The method to call on the
48 * remote server
49 * @param callback $deserialize A callback function to deserialize
50 * the response
51 * @param (optional) long $timeout Timeout in microseconds
52 */
53 public function __construct(Channel $channel,
54 $method,
55 $deserialize,
56 $timeout = false)
57 {
58 if ($timeout) {
59 $now = Timeval::now();
60 $delta = new Timeval($timeout);
61 $deadline = $now->add($delta);
62 } else {
63 $deadline = Timeval::infFuture();
64 }
65 $this->call = new Call($channel, $method, $deadline);
66 $this->deserialize = $deserialize;
67 $this->metadata = null;
Stanley Cheungcc019af2015-06-15 11:45:00 -070068 }
mlumish156e67d2015-01-02 14:59:16 -080069
Stanley Cheungd5b20562015-10-27 13:27:05 -070070 /**
71 * @return The metadata sent by the server.
72 */
73 public function getMetadata()
74 {
75 return $this->metadata;
murgatroid999140a062015-03-26 11:27:58 -070076 }
Stanley Cheungd5b20562015-10-27 13:27:05 -070077
78 /**
79 * @return string The URI of the endpoint.
80 */
81 public function getPeer()
82 {
83 return $this->call->getPeer();
84 }
85
86 /**
87 * Cancels the call.
88 */
89 public function cancel()
90 {
91 $this->call->cancel();
92 }
93
94 /**
95 * Deserialize a response value to an object.
96 *
97 * @param string $value The binary value to deserialize
98 *
99 * @return The deserialized value
100 */
101 protected function deserializeResponse($value)
102 {
103 if ($value === null) {
104 return;
105 }
106
107 return call_user_func($this->deserialize, $value);
108 }
Stanley Cheung3ab8e792015-08-24 16:58:42 -0700109}