diff options
| author |  ridiculousfish <corydoras@ridiculousfish.com> | 2011-12-26 21:39:08 -0800 |
|---|---|---|
| committer | ridiculousfish <corydoras@ridiculousfish.com> | 2011-12-26 21:39:08 -0800 |
| commit | 7c7aba1202a2c205facd64ab728dcb9472a0b6e1 (patch) | |
| tree | dd96494b7229fcc6e1a5a6954bf33728ebadc0b4 /env_universal.cpp | |
| parent | 74a1d70b8a713db1c56b0e521e7e62dbda7e7a37 (diff) | |
Fix to migrate the universal variable server off of dyn_queue_t
Diffstat (limited to 'env_universal.cpp')
| -rw-r--r-- | env_universal.cpp | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/env_universal.cpp b/env_universal.cpp index e3b95b30..d1726aa5 100644 --- a/env_universal.cpp +++ b/env_universal.cpp @@ -358,7 +358,7 @@ void env_universal_barrier() */ msg= create_message( BARRIER, 0, 0); msg->count=1; - q_put( &env_universal_server.unsent, msg ); + env_universal_server.unsent->push(msg); /* Wait until barrier request has been sent @@ -369,7 +369,7 @@ void env_universal_barrier() try_send_all( &env_universal_server ); check_connection(); - if( q_empty( &env_universal_server.unsent ) ) + if( env_universal_server.unsent->empty() ) break; if( env_universal_server.fd == -1 ) @@ -433,7 +433,7 @@ void env_universal_set( const wchar_t *name, const wchar_t *value, int exportv ) } msg->count=1; - q_put( &env_universal_server.unsent, msg ); + env_universal_server.unsent->push(msg); env_universal_barrier(); } } @@ -461,7 +461,7 @@ int env_universal_remove( const wchar_t *name ) { msg= create_message( ERASE, name, 0); msg->count=1; - q_put( &env_universal_server.unsent, msg ); + env_universal_server.unsent->push(msg); env_universal_barrier(); } |