rust/src/rt/rust_port.h

#ifndef RUST_PORT_H
#define RUST_PORT_H

class rust_port : public kernel_owned<rust_port>, public rust_cond {

public:
    RUST_REFCOUNTED(rust_port);

    rust_kernel *kernel;
    rust_task *task;
    size_t unit_sz;
    ptr_vec<rust_token> writers;
    ptr_vec<rust_chan> chans;

    lock_and_signal lock;

    rust_port(rust_task *task, size_t unit_sz);
    ~rust_port();
    void log_state();
    bool receive(void *dptr);
};

//
// Local Variables:
// mode: C++
// fill-column: 78;
// indent-tabs-mode: nil
// c-basic-offset: 4
// buffer-file-coding-system: utf-8-unix
// compile-command: "make -k -C $RBUILD 2>&1 | sed -e 's/\\/x\\//x:\\//g'";
// End:
//

#endif /* RUST_PORT_H */
Move ports out into their own file, add data_message and make communication system use it (and proxies) instead of existing token scheme. 2010-07-28 18:46:13 -05:00			`#ifndef RUST_PORT_H`
			`#define RUST_PORT_H`

Removing proxies and message queues. 2011-07-29 13:00:44 -05:00			`class rust_port : public kernel_owned<rust_port>, public rust_cond {`
Move ports out into their own file, add data_message and make communication system use it (and proxies) instead of existing token scheme. 2010-07-28 18:46:13 -05:00
			`public:`
Removing proxies and message queues. 2011-07-29 13:00:44 -05:00			`RUST_REFCOUNTED(rust_port);`

Work on debugging race conditions. Ports and channels have been moved to the kernel pool, since they've been known to outlive their associated task. This probably isn't the right thing to do, the life cycle needs fixed instead. Some refactorying in memory_region.cpp. Added a helper function to increment and decrement the allocation counter. This makes it easier to switch between atomic and non-atomic increments. Using atomic increments for now, although this still does not fix the problem. 2011-07-07 13:53:08 -05:00			`rust_kernel *kernel;`
Move ports out into their own file, add data_message and make communication system use it (and proxies) instead of existing token scheme. 2010-07-28 18:46:13 -05:00			`rust_task *task;`
			`size_t unit_sz;`
			`ptr_vec<rust_token> writers;`
			`ptr_vec<rust_chan> chans;`

Work on debugging race conditions. Ports and channels have been moved to the kernel pool, since they've been known to outlive their associated task. This probably isn't the right thing to do, the life cycle needs fixed instead. Some refactorying in memory_region.cpp. Added a helper function to increment and decrement the allocation counter. This makes it easier to switch between atomic and non-atomic increments. Using atomic increments for now, although this still does not fix the problem. 2011-07-07 13:53:08 -05:00			`lock_and_signal lock;`

Move ports out into their own file, add data_message and make communication system use it (and proxies) instead of existing token scheme. 2010-07-28 18:46:13 -05:00			`rust_port(rust_task *task, size_t unit_sz);`
			`~rust_port();`
Some pretty printing in the runtime. 2010-08-09 09:52:07 -05:00			`void log_state();`
Synthesize a flush_chan upcall right before a channel's ref_count drops to zero. This should only happen in the Rust code and not in the drop glue, or on the unwind path. This change allows the task owning the channel to block on a flush and delete its own channel. This change also cleans up some code around rust_port and rust_chan. 2010-08-09 10:15:34 -05:00			`bool receive(void *dptr);`
Move ports out into their own file, add data_message and make communication system use it (and proxies) instead of existing token scheme. 2010-07-28 18:46:13 -05:00			`};`

			`//`
			`// Local Variables:`
			`// mode: C++`
			`// fill-column: 78;`
			`// indent-tabs-mode: nil`
			`// c-basic-offset: 4`
			`// buffer-file-coding-system: utf-8-unix`
Fix compile-command lines in rt. 2011-07-13 15:51:20 -05:00			`// compile-command: "make -k -C $RBUILD 2>&1 \| sed -e 's/\\/x\\//x:\\//g'";`
Move ports out into their own file, add data_message and make communication system use it (and proxies) instead of existing token scheme. 2010-07-28 18:46:13 -05:00			`// End:`
			`//`

			`#endif /* RUST_PORT_H */`