/external/mockftpserver/branches/1.x_Branch/src/test/java/org/mockftpserver/core/command/ |
StaticReplyCommandHandlerTest.java | 87 session.sendReply(250, replyTextFor(250));
88 replay(session);
90 commandHandler.handleCommand(COMMAND, session);
91 verify(session);
105 session.sendReply(REPLY_CODE, REPLY_TEXT);
106 replay(session);
108 commandHandler.handleCommand(COMMAND, session);
109 verify(session);
122 commandHandler.handleCommand(COMMAND, session);
|
/external/mockftpserver/branches/1.x_Branch/src/test/java/org/mockftpserver/stub/command/ |
AcctCommandHandlerTest.java | 44 session.sendReply(ReplyCodes.ACCT_OK, replyTextFor(ReplyCodes.ACCT_OK));
45 session.sendReply(ReplyCodes.ACCT_OK, replyTextFor(ReplyCodes.ACCT_OK));
46 replay(session);
48 commandHandler.handleCommand(command1, session);
49 commandHandler.handleCommand(command2, session);
50 verify(session);
|
ModeCommandHandlerTest.java | 44 session.sendReply(ReplyCodes.MODE_OK, replyTextFor(ReplyCodes.MODE_OK));
45 session.sendReply(ReplyCodes.MODE_OK, replyTextFor(ReplyCodes.MODE_OK));
46 replay(session);
48 commandHandler.handleCommand(command1, session);
49 commandHandler.handleCommand(command2, session);
50 verify(session);
|
PassCommandHandlerTest.java | 44 session.sendReply(ReplyCodes.PASS_OK, replyTextFor(ReplyCodes.PASS_OK));
45 session.sendReply(ReplyCodes.PASS_OK, replyTextFor(ReplyCodes.PASS_OK));
46 replay(session);
48 commandHandler.handleCommand(command1, session);
49 commandHandler.handleCommand(command2, session);
50 verify(session);
|
RestCommandHandlerTest.java | 44 session.sendReply(ReplyCodes.REST_OK, replyTextFor(ReplyCodes.REST_OK));
45 session.sendReply(ReplyCodes.REST_OK, replyTextFor(ReplyCodes.REST_OK));
46 replay(session);
48 commandHandler.handleCommand(command1, session);
49 commandHandler.handleCommand(command2, session);
50 verify(session);
|
SiteCommandHandlerTest.java | 39 * Test the handleCommand(Command,Session) method
43 session.sendReply(ReplyCodes.SITE_OK, replyTextFor(ReplyCodes.SITE_OK));
44 session.sendReply(ReplyCodes.SITE_OK, replyTextFor(ReplyCodes.SITE_OK));
45 replay(session);
47 commandHandler.handleCommand(command1, session);
48 commandHandler.handleCommand(command2, session);
49 verify(session);
|
StruCommandHandlerTest.java | 44 session.sendReply(ReplyCodes.STRU_OK, replyTextFor(ReplyCodes.STRU_OK));
45 session.sendReply(ReplyCodes.STRU_OK, replyTextFor(ReplyCodes.STRU_OK));
46 replay(session);
48 commandHandler.handleCommand(command1, session);
49 commandHandler.handleCommand(command2, session);
50 verify(session);
|
UserCommandHandlerTest.java | 44 session.sendReply(ReplyCodes.USER_NEED_PASSWORD_OK, replyTextFor(ReplyCodes.USER_NEED_PASSWORD_OK));
45 session.sendReply(ReplyCodes.USER_LOGGED_IN_OK, replyTextFor(ReplyCodes.USER_LOGGED_IN_OK));
46 replay(session);
48 commandHandler.handleCommand(command1, session);
50 commandHandler.handleCommand(command2, session);
51 verify(session);
|
/external/nanohttpd/websocket/src/test/java/fi/iki/elonen/ |
WebSocketResponseHandlerTest.java | 61 private IHTTPSession session; field in class:WebSocketResponseHandlerTest 115 when(this.session.getHeaders()).thenReturn(this.headers); 121 Response handshakeResponse = this.nanoWebSocketServer.serve(this.session); 128 Response handshakeResponse = this.nanoWebSocketServer.serve(this.session); 140 Response handshakeResponse = this.nanoWebSocketServer.serve(this.session); 149 Response handshakeResponse = this.nanoWebSocketServer.serve(this.session); 156 Response handshakeResponse = this.nanoWebSocketServer.serve(this.session); 164 Response handshakeResponse = this.nanoWebSocketServer.serve(this.session);
|
/external/nanohttpd/websocket/src/test/java/fi/iki/elonen/samples/echo/ |
SimpleEchoSocket.java | 42 import org.eclipse.jetty.websocket.api.Session; 84 public void onConnect(Session session) { 85 System.out.printf("Got connect: %s%n", session); 90 fut = session.getRemote().sendStringByFuture(message); 93 session.close(StatusCode.NORMAL, "I'm done");
|
/external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/internal/tls/ |
HostnameVerifierTest.java | 42 FakeSSLSession session = new FakeSSLSession(); local 43 assertFalse(verifier.verify("localhost", session)); 48 SSLSession session = session("" local 75 // assertTrue(verifier.verify("foo.com", session)); 76 assertFalse(verifier.verify("foo.com", session)); 77 assertFalse(verifier.verify("a.foo.com", session)); 78 assertFalse(verifier.verify("bar.com", session)); 83 SSLSession session = session("" local 117 SSLSession session = session("" local 158 SSLSession session = session("" local 199 SSLSession session = session("" local 233 SSLSession session = session("" local 272 SSLSession session = session("" local 311 SSLSession session = session("" local 353 SSLSession session = session("" local 422 FakeSSLSession session = new FakeSSLSession(certificate); local 433 SSLSession session = session("" local 456 SSLSession session = session("" local 486 SSLSession session = session("" local 516 SSLSession session = session("" local 566 private SSLSession session(String certificate) throws Exception { method in class:HostnameVerifierTest [all...] |
/external/tensorflow/tensorflow/c/eager/ |
c_api_internal.h | 49 session(s), 52 session->device_mgr, opts.session_options.options.env, 64 TF_Session* const session; member in struct:TFE_Context 73 // session->devices[i]. 85 const std::vector<tensorflow::Device*>& devices() { return session->devices; }
|
/external/tensorflow/tensorflow/core/distributed_runtime/ |
graph_mgr.h | 62 // TF_CHECK_OK(gmgr.Register("session", { graph computes c = a + b }, 76 Status Register(const string& session, const GraphDef& gdef, 89 WorkerSession* session, const ExecutorOpts& opts, 124 // Session handle. 125 string session; member in struct:tensorflow::GraphMgr::Item 176 Status InitItem(const string& session, const GraphDef& gdef,
|
session_mgr_test.cc | 72 auto session = mgr_.WorkerSessionForSession(session_handle); local 73 EXPECT_NE(nullptr, session) << "Session for " << session_handle << "was null"; 74 EXPECT_NE(mgr_.LegacySession(), session); 112 auto session = mgr_.WorkerSessionForSession(session_handle); local 113 EXPECT_EQ(mgr_.LegacySession(), session);
|
/external/tensorflow/tensorflow/core/platform/ |
device_tracer_test.cc | 45 std::unique_ptr<Session> CreateSession() { 50 return std::unique_ptr<Session>(NewSession(options)); 154 auto session = CreateSession(); local 155 ASSERT_TRUE(session != nullptr); 156 TF_ASSERT_OK(session->Create(def_)); 165 Status s = session->Run(inputs, output_names, target_nodes, &outputs); 181 auto session = CreateSession(); local 182 ASSERT_TRUE(session != nullptr); 183 TF_ASSERT_OK(session->Create(def_)); 192 Status s = session->Run(inputs, output_names, target_nodes, &outputs) 207 auto session = CreateSession(); local [all...] |
/external/tensorflow/tensorflow/java/src/main/native/ |
session_jni.cc | 29 "close() has been called on the Session"); 133 TF_Session* session = TF_NewSession(graph, opts, status); local 144 return ok ? reinterpret_cast<jlong>(session) : 0; 150 TF_Session* session = requireHandle(env, handle); local 151 if (session == nullptr) return; 153 TF_CloseSession(session, status); 155 TF_DeleteSession(session, status); 166 TF_Session* session = requireHandle(env, handle); local 167 if (session == nullptr) return nullptr; 204 TF_SessionRun(session, run_options.get(), inputs.get(), input_values.get() [all...] |
/frameworks/av/drm/mediacas/plugins/mock/ |
MockCasPlugin.cpp | 115 sp<MockCasSession> session = local 117 if (session == NULL) { 131 sp<MockCasSession> session = local 133 if (session == NULL) { 144 sp<MockCasSession> session = local 146 if (session == NULL) { 199 sp<MockCasSession> session = local 202 if (session == NULL) { 203 ALOGE("MockDescramblerPlugin: session not found");
|
/frameworks/av/packages/MediaComponents/src/com/android/media/ |
MediaLibraryService2Impl.java | 56 MediaSession2 session = getSession(); local 57 if (!(session instanceof MediaLibrarySession)) { 78 // System service will recognize this session inside of the super constructor and would 79 // connect to this session assuming that initialization is finished. However, if any
|
/frameworks/av/services/audiopolicy/common/managerdefinitions/include/ |
AudioSession.h | 35 AudioSession(audio_session_t session, 48 audio_session_t session() const { return mRecordClientInfo.session; } function in class:android::AudioSession 88 status_t addSession(audio_session_t session, 92 status_t removeSession(audio_session_t session);
|
/frameworks/base/core/java/android/se/omapi/ |
Reader.java | 81 * before the Session object is returned (e.g. powers the Secure Element by 88 * @return a Session object to be used to create Channels. 90 public @NonNull Session openSession() throws IOException { 96 ISecureElementSession session; local 98 session = mReader.openSession(); 104 if (session == null) { 105 throw new IOException("service session is null."); 107 return new Session(mService, session, this);
|
/frameworks/base/services/autofill/java/com/android/server/autofill/ |
AutofillManagerServiceImpl.java | 155 * Cache of pending {@link Session}s, keyed by sessionId. 158 * occurs, or the session is abandoned. 161 private final SparseArray<Session> mSessions = new SparseArray<>(); 294 final Session session = mSessions.valueAt(i); local 295 session.removeSelfLocked(); 323 final Session session = mSessions.get(sessionId); local 324 if (session != null && uid == session.uid) 333 final Session session = mSessions.get(sessionId); local 413 final Session session = mSessions.get(sessionId); local 427 final Session session = mSessions.get(sessionId); local 451 final Session session = mSessions.get(sessionId); local 566 final Session session = mSessions.get(sessionId); local 582 final Session session = mSessions.get(sessionId); local 623 final Session session = mSessions.valueAt(i); local 1051 final Session session = mSessions.valueAt(i); local 1126 final Session session = mSessions.valueAt(i); local 1293 Session session = mSessions.valueAt(i); local [all...] |
/frameworks/base/services/core/java/com/android/server/broadcastradio/hal2/ |
BroadcastRadioService.java | 103 TunerSession session = module.openSession(callback); local 105 session.setConfiguration(legacyConfig); 107 return session;
|
/frameworks/support/media/api21/android/support/v4/media/session/ |
PlaybackStateCompatApi21.java | 17 package android.support.v4.media.session; 19 import android.media.session.PlaybackState;
|
/libcore/harmony-tests/src/test/java/org/apache/harmony/tests/javax/net/ssl/ |
HostnameVerifierTest.java | 35 * session) 38 mySSLSession session = new mySSLSession("localhost", 1080, null); local 40 assertFalse(hv.verify("localhost", session)); 52 mySSLSession session = new mySSLSession(new X509Certificate[] {x509}); local 53 assertFalse(verifier.verify("foo.com", session)); 54 assertFalse(verifier.verify("a.foo.com", session)); 55 assertFalse(verifier.verify("bar.com", session)); 60 session = new mySSLSession(new X509Certificate[] {x509}); 61 assertFalse(verifier.verify("\u82b1\u5b50.co.jp", session)); 62 assertFalse(verifier.verify("a.\u82b1\u5b50.co.jp", session)); 145 mySSLSession session = new mySSLSession(new X509Certificate[] {x509}); local 159 mySSLSession session = new mySSLSession(new X509Certificate[] { x509 }); local 182 mySSLSession session = new mySSLSession(new X509Certificate[] { x509 }); local 219 mySSLSession session = new mySSLSession(new X509Certificate[] { x509 }); local 252 mySSLSession session = new mySSLSession(new X509Certificate[] { x509 }); local 289 mySSLSession session = new mySSLSession(new X509Certificate[] { x509 }); local [all...] |
/packages/apps/Camera2/src/com/android/camera/one/v2/commands/ |
ZslPreviewCommand.java | 76 try (FrameServer.Session session = mFrameServer.createExclusiveSession()) { 85 session.submitRequest(previewWarming, RequestType.NON_REPEATING); 91 session.submitRequest(zslWarmingBurst, RequestType.NON_REPEATING); 100 session.submitRequest(zslAndPreviewRepeating, RequestType.REPEATING);
|