| /external/chromium-trace/catapult/third_party/gsutil/third_party/protorpc/protorpc/ |
| D | remote_test.py | 33 from protorpc import remote
43 MODULE = remote
58 class MyService(remote.Service):
60 @remote.method(Request, Response)
78 class BasicService(remote.Service):
84 @remote.method(SimpleRequest, SimpleResponse)
93 for state in remote.RpcState:
94 exception = remote.RpcError.from_state
95 self.assertEquals(remote.ServerError,
96 remote.RpcError.from_state('SERVER_ERROR'))
[all …]
|
| D | transport_test.py | 27 from protorpc import remote
49 class Service(remote.Service):
51 @remote.method(Message, Message)
70 self.status = remote.RpcStatus(state=remote.RpcState.APPLICATION_ERROR,
78 self.assertEquals(remote.RpcState.RUNNING, self.rpc.state)
91 self.assertEquals(remote.RpcState.OK, self.rpc.state)
118 self.assertEquals(remote.RpcState.APPLICATION_ERROR, self.rpc.state)
121 self.assertRaisesWithRegexpMatch(remote.ApplicationError,
153 remote.RpcStatus())
159 remote.Protocols.set_default(remote.Protocols.new_default())
[all …]
|
| D | transport.py | 35 from . import remote
69 self.__state = remote.RpcState.RUNNING
104 if self.__state == remote.RpcState.RUNNING:
112 error_class = remote.RpcError.from_state(self.__state)
114 if error_class is remote.ApplicationError:
120 if self.__state != remote.RpcState.RUNNING:
123 if state == remote.RpcState.RUNNING:
135 self.__set_state(remote.RpcState.OK)
165 protocols = remote.Protocols.get_default()
170 if isinstance(protocol, remote.ProtocolConfig):
[all …]
|
| D | webapp_test_util.py | 33 from . import remote
40 class TestService(remote.Service):
43 @remote.method(test_util.OptionalMessage,
235 class TestService(remote.Service):
241 @remote.method(test_util.OptionalMessage, test_util.OptionalMessage)
247 @remote.method(response_type=test_util.OptionalMessage)
251 @remote.method(test_util.NestedMessage, test_util.NestedMessage)
256 @remote.method()
258 raise remote.ApplicationError('This is an application error', 'ERROR_NAME')
260 @remote.method()
[all …]
|
| D | end2end_test.py | 26 from protorpc import remote
66 self.assertRaisesWithRegexpMatch(remote.ServerError,
91 self.assertRaisesWithRegexpMatch(remote.MethodNotFoundError,
100 expected_content = protojson.encode_message(remote.RpcStatus(
101 state=remote.RpcState.REQUEST_ERROR,
112 except remote.ApplicationError as err:
121 except remote.ServerError as err:
129 except remote.ServerError as err:
137 except remote.ServerError as err:
|
| /external/chromium-trace/catapult/devil/devil/android/sdk/ |
| D | gce_adb_wrapper.py | 34 def Push(self, local, remote, **kwargs): argument
44 self.Shell('mkdir -p %s' % cmd_helper.SingleQuote(remote))
49 self._PushObject(os.path.join(local, f), os.path.join(remote, f))
51 cmd_helper.SingleQuote(os.path.join(remote, f)))
53 parent_dir = remote[0:remote.rfind('/')]
56 self._PushObject(local, remote)
57 self.Shell('chmod 777 %s' % cmd_helper.SingleQuote(remote))
59 def _PushObject(self, local, remote): argument
73 'root@%s:%s' % (self._instance_ip, remote)
82 def Pull(self, remote, local, **kwargs): argument
[all …]
|
| /external/ipsec-tools/src/racoon/ |
| D | isakmp.c | 212 struct sockaddr_storage remote; local
214 unsigned int remote_len = sizeof(remote);
222 MSG_PEEK, (struct sockaddr *)&remote, &remote_len,
236 0, (struct sockaddr *)&remote, &remote_len)) != 1) {
279 plog(LLV_ERROR, LOCATION, (struct sockaddr *)&remote,
284 0, (struct sockaddr *)&remote, &remote_len)) < 0) {
297 0, (struct sockaddr *)&remote, &remote_len)) < 0) {
312 0, (struct sockaddr *)&remote, &remote_len)) < 0) {
321 0, (struct sockaddr *)&remote, &remote_len,
343 plog(LLV_ERROR, LOCATION, (struct sockaddr *)&remote,
[all …]
|
| D | handler.c | 145 getph1byaddr(local, remote, established) in getph1byaddr() argument
146 struct sockaddr *local, *remote; in getph1byaddr()
153 plog(LLV_DEBUG2, LOCATION, NULL, "remote: %s\n", saddr2str(remote));
159 plog(LLV_DEBUG2, LOCATION, NULL, "p->remote: %s\n", saddr2str(p->remote));
166 && CMPSADDR(remote, p->remote) == 0){
178 getph1byaddrwop(local, remote) in getph1byaddrwop() argument
179 struct sockaddr *local, *remote; in getph1byaddrwop()
187 && cmpsaddrwop(remote, p->remote) == 0)
200 getph1bydstaddrwop(remote) in getph1bydstaddrwop() argument
201 struct sockaddr *remote; in getph1bydstaddrwop()
[all …]
|
| D | remoteconf.c | 97 getrmconf_strict(remote, allow_anon) in getrmconf_strict() argument
98 struct sockaddr *remote; in getrmconf_strict()
119 if (remote->sa_family != AF_UNSPEC &&
120 extract_port(remote) != IPSEC_PORT_ANY)
124 if (remote->sa_family == AF_UNSPEC)
127 GETNAMEINFO(remote, addr, port);
135 if ((remote->sa_family == AF_UNSPEC
136 && remote->sa_family == p->remote->sa_family)
137 || (!withport && cmpsaddrwop(remote, p->remote) == 0)
138 || (withport && cmpsaddrstrict(remote, p->remote) == 0)) {
[all …]
|
| D | isakmp_inf.c | 272 plog(LLV_ERROR, LOCATION, iph1->remote,
304 plog(LLV_ERROR, LOCATION, iph1->remote,
310 plog(LLV_ERROR, LOCATION, iph1->remote,
377 plog(LLV_ERROR, LOCATION, iph1->remote,
382 plog(LLV_ERROR, LOCATION, iph1->remote,
387 plog(LLV_ERROR, LOCATION, iph1->remote,
394 plog(LLV_ERROR, LOCATION, iph1->remote,
406 plog(LLV_ERROR, LOCATION, iph1->remote,
412 plog(LLV_DEBUG, LOCATION, iph1->remote,
430 plog(LLV_ERROR, LOCATION, iph1->remote,
[all …]
|
| /external/webrtc/webrtc/base/ |
| D | socketpool.cc | 42 const SocketAddress& remote, int* err) { in RequestConnectedStream() argument
43 LOG_F(LS_VERBOSE) << "(" << remote << ")"; in RequestConnectedStream()
46 if (remote == it->first) { in RequestConnectedStream()
57 if (StreamInterface* stream = pool_->RequestConnectedStream(remote, err)) { in RequestConnectedStream()
59 active_.push_front(ConnectedStream(remote, stream)); in RequestConnectedStream()
120 NewSocketPool::RequestConnectedStream(const SocketAddress& remote, int* err) { in RequestConnectedStream() argument
122 factory_->CreateAsyncSocket(remote.family(), SOCK_STREAM); in RequestConnectedStream()
128 if ((socket->Connect(remote) != 0) && !socket->IsBlocking()) { in RequestConnectedStream()
158 ReuseSocketPool::RequestConnectedStream(const SocketAddress& remote, int* err) { in RequestConnectedStream() argument
163 int family = remote.family(); in RequestConnectedStream()
[all …]
|
| /external/parameter-framework/ |
| D | LibRemoteProcessor.mk | 38 upstream/remote-processor/RequestMessage.cpp \
39 upstream/remote-processor/Message.cpp \
40 upstream/remote-processor/AnswerMessage.cpp \
41 upstream/remote-processor/RemoteProcessorServer.cpp \
42 upstream/remote-processor/BackgroundRemoteProcessorServer.cpp
45 $(LOCAL_PATH)/upstream/remote-processor/ \
46 $(LOCAL_PATH)/support/android/remote-processor/
|
| /external/llvm/utils/bugpoint/ |
| D | RemoteRunSafely.sh | 93 remote="./"$PROGRAM
97 'rm -f '$remote' ; ' \
98 'cat > '$remote' ; chmod +x '$remote' ; '$remote' '$*' ; ' \
99 'err=$? ; rm -f '$remote' ; exit $err'
|
| /external/chromium-trace/catapult/third_party/gsutil/third_party/protorpc/protorpc/wsgi/ |
| D | service_test.py | 28 from protorpc import remote
41 remote.Protocols.set_default(remote.Protocols.new_default())
60 self.protocols = remote.Protocols()
63 global_protocols = remote.Protocols()
65 remote.Protocols.set_default(global_protocols)
75 new_protocols = remote.Protocols()
83 remote.ServerError,
87 remote.Protocols.set_default(new_protocols)
145 remote.ServerError,
171 remote.ServiceConfigurationError,
|
| D | service.py | 37 from .. import remote
107 local_protocols = protocols or remote.Protocols.get_default()
128 status = remote.RpcStatus(state=state,
141 remote.RpcState.METHOD_NOT_FOUND_ERROR,
146 remote_info = method.remote
152 remote.RpcState.REQUEST_ERROR,
170 request_state = remote.HttpRequestState(
184 except remote.ApplicationError as err:
186 remote.RpcState.APPLICATION_ERROR,
194 remote.RpcState.SERVER_ERROR,
[all …]
|
| /external/testng/src/test/java/test/remote/ |
| D | RemoteTest.java | 1 package test.remote;
6 import org.testng.remote.RemoteTestNG;
7 import org.testng.remote.strprotocol.IMessage;
8 import org.testng.remote.strprotocol.IMessageSender;
9 import org.testng.remote.strprotocol.MessageHub;
10 import org.testng.remote.strprotocol.SerializedMessageSender;
11 import org.testng.remote.strprotocol.StringMessageSender;
|
| /external/autotest/site_utils/ |
| D | test_runner_utils_unittest.py | 74 remote = 'etomer'
121 '-m', remote, '--no_console_prefix', '-l', 'gilbert',
134 '-m', remote, '--no_console_prefix', '-l', 'sullivan',
147 job1, remote, autotest_path,results_dir, fast_mode, id_digits,
152 job2, remote, autotest_path, results_dir, fast_mode, id_digits,
166 remote = 'remoat'
193 afe, test_arg=test_arg, remote=remote, build=build,
197 ).AndReturn(fake_suite(suite_control_files, [remote]))
202 test_runner_utils._auto_detect_labels(afe, remote)
206 'cros-version:' + build, remote, autotest_path,
[all …]
|
| /external/vogar/src/vogar/ |
| D | Target.java | 41 public abstract void push(File local, File remote); in push() argument
42 public abstract void pull(File remote, File local); in pull() argument
44 public final Task pushTask(final File local, final File remote) { in pushTask() argument
45 return new Task("push " + remote) { in pushTask()
47 push(local, remote); in pushTask()
53 public final Task rmTask(final File remote) {
54 return new Task("rm " + remote) {
56 rm(remote);
|
| D | LocalTarget.java | 82 @Override public void push(File local, File remote) { in push() argument
83 if (remote.equals(local)) { in push()
87 if (remote.exists()) { in push()
90 new Command(log, "cp", "-r", local.toString(), remote.toString()).execute(); in push()
93 @Override public void pull(File remote, File local) { in pull() argument
94 new Command(log, "cp", remote.getPath(), local.getPath()).execute(); in pull()
|
| /external/chromium-trace/catapult/third_party/webapp2/tests/resources/ |
| D | protorpc_services.py | 2 from protorpc import remote
10 class BonjourService(remote.Service):
11 @remote.method(BonjourRequest, BonjourResponse)
22 class CiaoService(remote.Service):
23 @remote.method(CiaoRequest, CiaoResponse)
|
| /external/curl/tests/data/ |
| D | test1421 | 36 --proxy http://%HOSTIP:%HTTPPORT http://test.remote.haxx.se.1421:8990/ http://different.remote.haxx…
59 GET http://test.remote.haxx.se.1421:8990/ HTTP/1.1
60 Host: test.remote.haxx.se.1421:8990
64 GET http://different.remote.haxx.se.1421:8990/ HTTP/1.1
65 Host: different.remote.haxx.se.1421:8990
|
| D | test1241 | 41 …STIP:%HTTPPORT http://test.remote.haxx.se.1241:8990/../../hej/but/who/../1241?stupid=me/../1241#so…
52 GET http://test.remote.haxx.se.1241:8990/../../hej/but/who/../1241?stupid=me/../1241 HTTP/1.1
53 Host: test.remote.haxx.se.1241:8990
57 GET http://test.remote.haxx.se.1241:8990/../../hej/but/who/../12410001 HTTP/1.1
58 Host: test.remote.haxx.se.1241:8990
|
| D | test1232 | 42 …STIP:%HTTPPORT http://test.remote.haxx.se.1232:8990/../../hej/but/who/../1232?stupid=me/../1232#so…
53 GET http://test.remote.haxx.se.1232:8990/hej/but/1232?stupid=me/../1232 HTTP/1.1
54 Host: test.remote.haxx.se.1232:8990
58 GET http://test.remote.haxx.se.1232:8990/hej/but/12320001 HTTP/1.1
59 Host: test.remote.haxx.se.1232:8990
|
| /external/autotest/contrib/ |
| D | servo-stat | 43 remote() { function
86 if ! remote $SERVO true >/dev/null 2>&1
92 remote $SERVO grep CHROMEOS_RELEASE_VERSION /etc/lsb-release 2>&1)
102 if remote $SERVO test -f $CONFIG
105 BOARD=$(remote $SERVO grep BOARD= $CONFIG)
114 JOB=$(remote $SERVO status servod | sed 's/,.*//')
|
| /external/parameter-framework/upstream/remote-process/ |
| D | README.md | 1 # remote-process
3 `remote-process` is an executable used to communicate with an instance of the
15 remote-process may also be used to communicate with test-platform
21 remote-process <host> <port> <command>
25 You may also run a batch of commands by passing them on remote-process'
28 remote-process <host> <port> < file
|