@@ -43,7 +43,6 @@ typedef struct {
4343 * object. */
4444 plasma_connection * plasma_conn ;
4545 client_connection * client_conn ;
46- client_object_connection * object_conn ;
4746} plasma_mock ;
4847
4948plasma_mock * init_plasma_mock (int port , plasma_mock * remote_mock ) {
@@ -66,31 +65,22 @@ plasma_mock *init_plasma_mock(int port, plasma_mock *remote_mock) {
6665 mock -> write_conn = NULL ;
6766 mock -> read_conn = NULL ;
6867 }
69-
70- mock -> plasma_conn = NULL ;
71- mock -> client_conn = NULL ;
72- mock -> object_conn = NULL ;
73- return mock ;
74- }
75-
76- void add_client_conn (plasma_mock * mock ) {
7768 /* Connect a new client to the local plasma manager and mock a request to an
7869 * object. */
7970 mock -> plasma_conn = plasma_connect (store_socket_name , manager_socket_name );
8071 mock -> client_conn =
8172 new_client_connection (mock -> loop , mock -> manager_local_fd , mock -> state , 0 );
73+ return mock ;
8274}
8375
8476void destroy_plasma_mock (plasma_mock * mock ) {
85- if (mock -> object_conn != NULL ) {
86- free (mock -> client_conn );
87- free (mock -> plasma_conn );
88- }
8977 if (mock -> read_conn != NULL ) {
9078 close (get_client_sock (mock -> read_conn ));
9179 free (mock -> read_conn );
9280 }
9381 destroy_plasma_manager_state (mock -> state );
82+ free (mock -> client_conn );
83+ free (mock -> plasma_conn );
9484 close (mock -> local_store );
9585 close (mock -> manager_local_fd );
9686 close (mock -> manager_remote_fd );
@@ -109,7 +99,6 @@ void destroy_plasma_mock(plasma_mock *mock) {
10999 */
110100TEST request_transfer_test (void ) {
111101 plasma_mock * local_mock = init_plasma_mock (manager_port , NULL );
112- add_client_conn (local_mock );
113102 plasma_mock * remote_mock = init_plasma_mock (12346 , local_mock );
114103 const char * * manager_vector = malloc (sizeof (char * ));
115104 manager_vector [0 ] = "127.0.0.1:12346" ;
@@ -146,7 +135,6 @@ TEST request_transfer_test(void) {
146135 */
147136TEST request_transfer_retry_test (void ) {
148137 plasma_mock * local_mock = init_plasma_mock (manager_port , NULL );
149- add_client_conn (local_mock );
150138 plasma_mock * remote_mock1 = init_plasma_mock (12346 , local_mock );
151139 plasma_mock * remote_mock2 = init_plasma_mock (12347 , local_mock );
152140 const char * * manager_vector = malloc (sizeof (char * ) * 2 );
@@ -186,7 +174,6 @@ TEST request_transfer_retry_test(void) {
186174 */
187175TEST request_transfer_timeout_test (void ) {
188176 plasma_mock * local_mock = init_plasma_mock (manager_port , NULL );
189- add_client_conn (local_mock );
190177 plasma_mock * remote_mock = init_plasma_mock (12346 , local_mock );
191178 const char * * manager_vector = malloc (sizeof (char * ));
192179 manager_vector [0 ] = "127.0.0.1:12346" ;
0 commit comments