
    g	                     F    d dl Z d dlmZmZmZ d dlmZ d Zd Z	d Z
d ZdS )    N)FlaskrequestResponse)APIFunctionsc                  P    t                      } |                     dd           d S )N0.0.0.0  hostport)create_app_least_conn_1run)app_least_conn_1s    F/Users/user/workspace/sujinbaek/cqa-test-app/testapps/lb_least_conn.pyrun_app_least_conn_1r      -    .00id33333    c                  P    t                      } |                     dd           d S )Nr   x#  r
   )create_app_least_conn_2r   )app_least_conn_2s    r   run_app_least_conn_2r      r   r   c                      t          t                    } |                     d          d             }|                     d          d             }| S )N/connectionsc                      t           j                            d          } t          j        t          |                     }d                    |          }t          |d          S )NSERVER_PORTzQI'm a #1 server(keep-connection-server)
Current established connection count: {}

text/plainmimetyper   environgetapi_function!get_established_connections_countintformatr   r   countmessages      r   connections_handler_holdz9create_app_least_conn_1.<locals>.connections_handler_hold   sV     ""=11>s4yyIIgnnotuu,7777r   /inject-loadc                      d} d}d}t          j        t          j        | ||f          }|                                 t          dd          S )N	localhostr	   x   targetargsz9Injecting load... to a #1 server(keep-connection-server)
r   r   )	threadingThreadr#   establish_connectionstartr   r   r   durationthreads       r   inject_load_1z.create_app_least_conn_1.<locals>.inject_load_1   sW     !)JRVX\^fQghhhT_kllllr   r   __name__route)r   r*   r9   s      r   r   r      sk    XN++8 8 ,+8 N++m m ,+m r   c                      t          t                    } |                     d          d             }|                     d          d             }| S )Nr   c                      t           j                            d          } t          j        t          |                     }d                    |          }t          |d          S )Nr   zTI'm a #2 server(release-connection-server)
Current established connection count: {}
r   r   r    r'   s      r   connections_handler_releasez<create_app_least_conn_2.<locals>.connections_handler_release-   sV     ""=11>s4yyIIjqqrwxx,7777r   r+   c                      d} d}d}t          j        t          j        | ||f          }d|_        |                                 t          dd          S )	Nr-   r   r   r/   Tz<Injecting load... to a #2 server(release-connection-server)
r   r   )r2   r3   r#   r4   daemonr5   r   r6   s       r   inject_load_2z.create_app_least_conn_2.<locals>.inject_load_25   s^     !)JRVX\^fQghhhWbnoooor   r:   )r   r?   rB   s      r   r   r   *   sk    XN++8 8 ,+8 N++	p 	p ,+	p r   )r2   flaskr   r   r   functions.APIFunctionsr   r#   r   r   r   r    r   r   <module>rF      s        * * * * * * * * * * ? ? ? ? ? ?4 4 4
4 4 4
  2    r   