trAvis - MANAGER
Edit File: ajx_load_balancer.js
/** * Extend _wpbc with new methods //FixIn: 9.8.6.2 * * @type {*|{}} * @private */ _wpbc = (function ( obj, $) { // Load Balancer ----------------------------------------------------------------------------------------------- var p_balancer = obj.balancer_obj = obj.balancer_obj || { 'max_threads': 2, 'in_process' : [], 'wait' : [] }; /** * Set max parallel request to load * * @param max_threads */ obj.balancer__set_max_threads = function ( max_threads ){ p_balancer[ 'max_threads' ] = max_threads; }; /** * Check if balancer for specific booking resource defined :: true | false * * @param {string|int} resource_id * @returns {boolean} */ obj.balancer__is_defined = function ( resource_id ) { return ('undefined' !== typeof( p_balancer[ 'balancer_' + resource_id ] ) ); }; /** * Create balancer initializing * * @param {string|int} resource_id */ obj.balancer__init = function ( resource_id, function_name , params ={}) { var balance_obj = {}; balance_obj[ 'resource_id' ] = resource_id; balance_obj[ 'priority' ] = 1; balance_obj[ 'function_name' ] = function_name; balance_obj[ 'params' ] = wpbc_clone_obj( params ); if ( obj.balancer__is_already_run( resource_id, function_name ) ){ return 'run'; } if ( obj.balancer__is_already_wait( resource_id, function_name ) ){ return 'wait'; } if ( obj.balancer__can_i_run() ){ obj.balancer__add_to__run( balance_obj ); return 'run'; } else { obj.balancer__add_to__wait( balance_obj ); return 'wait'; } }; /** * Can I Run ? * @returns {boolean} */ obj.balancer__can_i_run = function (){ return ( p_balancer[ 'in_process' ].length < p_balancer[ 'max_threads' ] ); } /** * Add to WAIT * @param balance_obj */ obj.balancer__add_to__wait = function ( balance_obj ) { p_balancer['wait'].push( balance_obj ); } /** * Remove from Wait * * @param resource_id * @param function_name * @returns {*|boolean} */ obj.balancer__remove_from__wait_list = function ( resource_id, function_name ){ var removed_el = false; if ( p_balancer[ 'wait' ].length ){ //FixIn: 9.8.10.1 for ( var i in p_balancer[ 'wait' ] ){ if ( (resource_id === p_balancer[ 'wait' ][ i ][ 'resource_id' ]) && (function_name === p_balancer[ 'wait' ][ i ][ 'function_name' ]) ){ removed_el = p_balancer[ 'wait' ].splice( i, 1 ); removed_el = removed_el.pop(); p_balancer[ 'wait' ] = p_balancer[ 'wait' ].filter( function ( v ){ return v; } ); // Reindex array return removed_el; } } } return removed_el; } /** * Is already WAIT * * @param resource_id * @param function_name * @returns {boolean} */ obj.balancer__is_already_wait = function ( resource_id, function_name ){ if ( p_balancer[ 'wait' ].length ){ //FixIn: 9.8.10.1 for ( var i in p_balancer[ 'wait' ] ){ if ( (resource_id === p_balancer[ 'wait' ][ i ][ 'resource_id' ]) && (function_name === p_balancer[ 'wait' ][ i ][ 'function_name' ]) ){ return true; } } } return false; } /** * Add to RUN * @param balance_obj */ obj.balancer__add_to__run = function ( balance_obj ) { p_balancer['in_process'].push( balance_obj ); } /** * Remove from RUN list * * @param resource_id * @param function_name * @returns {*|boolean} */ obj.balancer__remove_from__run_list = function ( resource_id, function_name ){ var removed_el = false; if ( p_balancer[ 'in_process' ].length ){ //FixIn: 9.8.10.1 for ( var i in p_balancer[ 'in_process' ] ){ if ( (resource_id === p_balancer[ 'in_process' ][ i ][ 'resource_id' ]) && (function_name === p_balancer[ 'in_process' ][ i ][ 'function_name' ]) ){ removed_el = p_balancer[ 'in_process' ].splice( i, 1 ); removed_el = removed_el.pop(); p_balancer[ 'in_process' ] = p_balancer[ 'in_process' ].filter( function ( v ){ return v; } ); // Reindex array return removed_el; } } } return removed_el; } /** * Is already RUN * * @param resource_id * @param function_name * @returns {boolean} */ obj.balancer__is_already_run = function ( resource_id, function_name ){ if ( p_balancer[ 'in_process' ].length ){ //FixIn: 9.8.10.1 for ( var i in p_balancer[ 'in_process' ] ){ if ( (resource_id === p_balancer[ 'in_process' ][ i ][ 'resource_id' ]) && (function_name === p_balancer[ 'in_process' ][ i ][ 'function_name' ]) ){ return true; } } } return false; } obj.balancer__run_next = function (){ // Get 1st from Wait list var removed_el = false; if ( p_balancer[ 'wait' ].length ){ //FixIn: 9.8.10.1 for ( var i in p_balancer[ 'wait' ] ){ removed_el = obj.balancer__remove_from__wait_list( p_balancer[ 'wait' ][ i ][ 'resource_id' ], p_balancer[ 'wait' ][ i ][ 'function_name' ] ); break; } } if ( false !== removed_el ){ // Run obj.balancer__run( removed_el ); } } /** * Run * @param balance_obj */ obj.balancer__run = function ( balance_obj ){ switch ( balance_obj[ 'function_name' ] ){ case 'wpbc_calendar__load_data__ajx': // Add to run list obj.balancer__add_to__run( balance_obj ); wpbc_calendar__load_data__ajx( balance_obj[ 'params' ] ) break; default: } } return obj; }( _wpbc || {}, jQuery )); /** * -- Help functions ---------------------------------------------------------------------------------------------- */ function wpbc_balancer__is_wait( params, function_name ){ //console.log('::wpbc_balancer__is_wait',params , function_name ); if ( 'undefined' !== typeof (params[ 'resource_id' ]) ){ var balancer_status = _wpbc.balancer__init( params[ 'resource_id' ], function_name, params ); return ( 'wait' === balancer_status ); } return false; } function wpbc_balancer__completed( resource_id , function_name ){ //console.log('::wpbc_balancer__completed',resource_id , function_name ); _wpbc.balancer__remove_from__run_list( resource_id, function_name ); _wpbc.balancer__run_next(); }